| Package | Description | 
|---|---|
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.impl.spark.collect | 
| Modifier and Type | Method and Description | 
|---|---|
| <S,T> BaseDoCollection<T> | PCollectionFactory. createDoCollection(String name,
                  PCollectionImpl<S> chainingCollection,
                  DoFn<S,T> fn,
                  PType<T> type,
                  ParallelDoOptions options) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | PCollectionImpl.Visitor. visitDoCollection(BaseDoCollection<?> collection) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DoCollection<S> | 
| Modifier and Type | Method and Description | 
|---|---|
| <S,T> BaseDoCollection<T> | SparkCollectFactory. createDoCollection(String name,
                  PCollectionImpl<S> parent,
                  DoFn<S,T> fn,
                  PType<T> type,
                  ParallelDoOptions options) | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.