Modifier and Type | Method and Description |
---|---|
void |
Transform.prepare(Transform.Context context,
OutputCollector<O> outputCollector)
Prepare the transform.
|
void |
RelayTransform.prepare(Transform.Context context,
OutputCollector<T> oc) |
Modifier and Type | Method and Description |
---|---|
void |
GroupByKeyTransform.prepare(Transform.Context context,
OutputCollector<org.apache.beam.sdk.values.KV<Object,List>> oc) |
void |
CreateViewTransform.prepare(Transform.Context context,
OutputCollector<O> oc) |
void |
DoTransform.prepare(Transform.Context context,
OutputCollector<O> oc) |
void |
FlattenTransform.prepare(Transform.Context context,
OutputCollector<T> oc) |
void |
WindowTransform.prepare(Transform.Context context,
OutputCollector<T> oc) |
Modifier and Type | Method and Description |
---|---|
void |
MapTransform.prepare(Transform.Context context,
OutputCollector<O> outputCollector) |
void |
CollectTransform.prepare(Transform.Context context,
OutputCollector<T> outputCollector) |
void |
ReduceTransform.prepare(Transform.Context context,
OutputCollector<T> outputCollector) |
void |
GroupByKeyTransform.prepare(Transform.Context context,
OutputCollector<scala.Tuple2<K,Iterable<V>>> outputCollector) |
void |
ReduceByKeyTransform.prepare(Transform.Context context,
OutputCollector<scala.Tuple2<K,V>> outputCollector) |
void |
MapToPairTransform.prepare(Transform.Context context,
OutputCollector<scala.Tuple2<K,V>> outputCollector) |
void |
FlatMapTransform.prepare(Transform.Context context,
OutputCollector<U> outputCollector) |
Modifier and Type | Method and Description |
---|---|
void |
EmptyComponents.EmptyTransform.prepare(Transform.Context context,
OutputCollector<O> outputCollector) |
Modifier and Type | Class and Description |
---|---|
class |
OutputCollectorImpl<O>
Output Collector Implementation.
|
Copyright © 2018. All rights reserved.