| Package | Description | 
|---|---|
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.impl.spark.collect | 
| Modifier and Type | Method and Description | 
|---|---|
| <K,V> BaseInputTable<K,V> | PCollectionFactory. createInputTable(TableSource<K,V> source,
                String named,
                DistributedPipeline distributedPipeline,
                ParallelDoOptions doOpts) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | InputTable<K,V> | 
| Modifier and Type | Method and Description | 
|---|---|
| <K,V> BaseInputTable<K,V> | SparkCollectFactory. createInputTable(TableSource<K,V> source,
                String named,
                DistributedPipeline pipeline,
                ParallelDoOptions doOpts) | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.