MCPcopy Create free account
hub / github.com/apache/pig / removeToLoad

Method removeToLoad

src/org/apache/pig/PigServer.java:1719–1732  ·  view source on GitHub ↗
(Operator toRemove)

Source from the content-addressed store, hash-verified

1717 }
1718
1719 private void removeToLoad(Operator toRemove) throws IOException {
1720 List<Operator> successors = lp.getSuccessors(toRemove);
1721 List<Operator> succToRemove = new ArrayList<Operator>();
1722 if (successors != null && successors.size() > 0) {
1723 succToRemove.addAll(successors);
1724 for (Operator succ : succToRemove) {
1725 lp.disconnect( toRemove, succ );
1726 if (!(succ instanceof LOLoad)) {
1727 removeToLoad(succ);
1728 lp.remove(succ);
1729 }
1730 }
1731 }
1732 }
1733
1734 /**
1735 * Accumulate the given statement to previous query statements and generate

Callers 1

skipStoresMethod · 0.95

Calls 5

getSuccessorsMethod · 0.65
sizeMethod · 0.65
addAllMethod · 0.65
disconnectMethod · 0.65
removeMethod · 0.65

Tested by

no test coverage detected