Package | Description |
---|---|
org.apache.crunch |
Client-facing API and core abstractions.
|
Modifier and Type | Method and Description |
---|---|
ParallelDoOptions |
ParallelDoOptions.Builder.build() |
Modifier and Type | Method and Description |
---|---|
<K,V> PTable<K,V> |
PCollection.parallelDo(String name,
DoFn<S,Pair<K,V>> doFn,
PTableType<K,V> type,
ParallelDoOptions options)
Similar to the other
parallelDo instance, but returns a
PTable instance instead of a PCollection . |
<T> PCollection<T> |
PCollection.parallelDo(String name,
DoFn<S,T> doFn,
PType<T> type,
ParallelDoOptions options)
Applies the given doFn to the elements of this
PCollection and
returns a new PCollection that is the output of this processing. |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.