|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ParallelDoOptions | |
---|---|
org.apache.crunch | Client-facing API and core abstractions. |
Uses of ParallelDoOptions in org.apache.crunch |
---|
Methods in org.apache.crunch that return ParallelDoOptions | |
---|---|
ParallelDoOptions |
ParallelDoOptions.Builder.build()
|
Methods in org.apache.crunch with parameters of type ParallelDoOptions | ||
---|---|---|
|
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 . |
|
|
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. |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |