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

Uses of Interface
org.apache.crunch.impl.dist.collect.PCollectionFactory

Packages that use PCollectionFactory

org.apache.crunch.impl.dist
org.apache.crunch.impl.mr.collect
org.apache.crunch.impl.spark.collect

Uses of PCollectionFactory in org.apache.crunch.impl.dist

Fields in org.apache.crunch.impl.dist declared as PCollectionFactory

protected PCollectionFactory

DistributedPipeline.factory

Methods in org.apache.crunch.impl.dist that return PCollectionFactory

PCollectionFactory

DistributedPipeline.getFactory()

Constructors in org.apache.crunch.impl.dist with parameters of type PCollectionFactory

DistributedPipeline(String name, org.apache.hadoop.conf.Configuration conf, PCollectionFactory factory)
Instantiate with a custom name and configuration.

Uses of PCollectionFactory in org.apache.crunch.impl.mr.collect

Classes in org.apache.crunch.impl.mr.collect that implement PCollectionFactory

class

MRCollectionFactory

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

Classes in org.apache.crunch.impl.spark.collect that implement PCollectionFactory

class

SparkCollectFactory