|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use PCollectionFactory | |
---|---|
org.apache.crunch.impl.dist | |
org.apache.crunch.impl.spark.collect |
Uses of PCollectionFactory in org.apache.crunch.impl.dist |
---|
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.spark.collect |
---|
Classes in org.apache.crunch.impl.spark.collect that implement PCollectionFactory | |
---|---|
class |
SparkCollectFactory
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |