| Package | Description |
|---|---|
| org.apache.crunch.impl.dist | |
| org.apache.crunch.impl.spark.collect |
| Modifier and Type | Method and Description |
|---|---|
PCollectionFactory |
DistributedPipeline.getFactory() |
| Constructor and Description |
|---|
DistributedPipeline(String name,
org.apache.hadoop.conf.Configuration conf,
PCollectionFactory factory)
Instantiate with a custom name and configuration.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SparkCollectFactory |
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.