|
|||||||||
PREV NEXT | FRAMES NO FRAMES All Classes |
Packages that use DoNode | |
---|---|
org.apache.crunch.impl.dist.collect | |
org.apache.crunch.impl.mr.collect | |
org.apache.crunch.impl.mr.plan |
Uses of DoNode in org.apache.crunch.impl.dist.collect |
---|
Methods in org.apache.crunch.impl.dist.collect that return DoNode | |
---|---|
DoNode |
MRCollection.createDoNode()
|
Uses of DoNode in org.apache.crunch.impl.mr.collect |
---|
Methods in org.apache.crunch.impl.mr.collect that return DoNode | |
---|---|
DoNode |
DoTable.createCombineNode()
|
DoNode |
PGroupedTableImpl.createDoNode()
|
DoNode |
InputTable.createDoNode()
|
DoNode |
InputCollection.createDoNode()
|
DoNode |
DoTable.createDoNode()
|
DoNode |
DoCollection.createDoNode()
|
DoNode |
PGroupedTableImpl.getGroupingNode()
|
Uses of DoNode in org.apache.crunch.impl.mr.plan |
---|
Methods in org.apache.crunch.impl.mr.plan that return DoNode | ||
---|---|---|
DoNode |
DoNode.addChild(DoNode node)
|
|
static DoNode |
DoNode.createFnNode(String name,
DoFn<?,?> function,
PType<?> ptype,
ParallelDoOptions options)
|
|
static
|
DoNode.createGroupingNode(String name,
PGroupedTableType<K,V> ptype)
|
|
static
|
DoNode.createInputNode(Source<S> source)
|
|
static DoNode |
DoNode.createOutputNode(String name,
Converter outputConverter,
PType<?> ptype)
|
Methods in org.apache.crunch.impl.mr.plan that return types with arguments of type DoNode | |
---|---|
List<DoNode> |
DoNode.getChildren()
|
Methods in org.apache.crunch.impl.mr.plan with parameters of type DoNode | |
---|---|
DoNode |
DoNode.addChild(DoNode node)
|
void |
MSCROutputHandler.configureNode(DoNode node,
Target target)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES All Classes |