Uses of Class
org.apache.crunch.impl.dist.collect.BaseInputCollection

Packages that use BaseInputCollection

Package	Description
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.spark.collect

Uses of BaseInputCollection in org.apache.crunch.impl.dist.collect

Methods in org.apache.crunch.impl.dist.collect that return BaseInputCollection

Modifier and Type	Method and Description
<S> BaseInputCollection<S>	PCollectionFactory.createInputCollection(Source<S> source, String named, DistributedPipeline distributedPipeline, ParallelDoOptions doOpts)

Methods in org.apache.crunch.impl.dist.collect with parameters of type BaseInputCollection

Modifier and Type	Method and Description
void	PCollectionImpl.Visitor.visitInputCollection(BaseInputCollection<?> collection)

Uses of BaseInputCollection in org.apache.crunch.impl.spark.collect

Subclasses of BaseInputCollection in org.apache.crunch.impl.spark.collect

Modifier and Type	Class and Description
class	InputCollection<S>

Methods in org.apache.crunch.impl.spark.collect that return BaseInputCollection

Modifier and Type	Method and Description
<S> BaseInputCollection<S>	SparkCollectFactory.createInputCollection(Source<S> source, String named, DistributedPipeline pipeline, ParallelDoOptions doOpts)