This project has retired. For details please refer to its Attic page.

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

Packages that use BaseInputCollection

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

<S> BaseInputCollection<S>

PCollectionFactory.createInputCollection(Source<S> source, DistributedPipeline distributedPipeline, ParallelDoOptions doOpts)

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

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

class

InputCollection<S>

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

<S> BaseInputCollection<S>

SparkCollectFactory.createInputCollection(Source<S> source, DistributedPipeline pipeline, ParallelDoOptions doOpts)