|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.crunch.impl.dist.collect.PCollectionImpl<S>
org.apache.crunch.impl.dist.collect.BaseInputCollection<S>
org.apache.crunch.impl.mr.collect.InputCollection<S>
public class InputCollection<S>
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl |
---|
PCollectionImpl.Visitor |
Field Summary |
---|
Fields inherited from class org.apache.crunch.impl.dist.collect.BaseInputCollection |
---|
source |
Fields inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl |
---|
doOptions, materializedAt, pipeline |
Constructor Summary | |
---|---|
InputCollection(Source<S> source,
MRPipeline pipeline)
|
Method Summary | |
---|---|
DoNode |
createDoNode()
|
protected ReadableData<S> |
getReadableDataInternal()
|
Methods inherited from class org.apache.crunch.impl.dist.collect.BaseInputCollection |
---|
acceptInternal, equals, getLastModifiedAt, getParents, getPType, getSizeInternal, getSource, hashCode |
Methods inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl |
---|
accept, asCollection, asReadable, by, by, cache, cache, count, filter, filter, getChainingCollection, getDepth, getMaterializedAt, getName, getOnlyParent, getParallelDoOptions, getPipeline, getSize, getTargetDependencies, getTypeFamily, isBreakpoint, length, materialize, materializeAt, materializedData, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, setBreakpoint, toString, union, union, write, write |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public InputCollection(Source<S> source, MRPipeline pipeline)
Method Detail |
---|
protected ReadableData<S> getReadableDataInternal()
getReadableDataInternal
in class BaseInputCollection<S>
public DoNode createDoNode()
createDoNode
in interface MRCollection
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |