org.apache.beam.runners.gearpump.translators.functions

Class DoFnFunction<InputT,OutputT>

java.lang.Object

org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction

org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<java.util.List<TranslatorUtils.RawUnionValue>,TranslatorUtils.RawUnionValue>

org.apache.beam.runners.gearpump.translators.functions.DoFnFunction<InputT,OutputT>

All Implemented Interfaces:

java.io.Serializable

public class DoFnFunction<InputT,OutputT>
extends org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<java.util.List<TranslatorUtils.RawUnionValue>,TranslatorUtils.RawUnionValue>

Gearpump FlatMapFunction wrapper over Beam DoFn.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DoFnFunction(GearpumpPipelineOptions pipelineOptions, DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, java.util.Collection<PCollectionView<?>> sideInputs, java.util.Map<java.lang.String,PCollectionView<?>> sideInputTagMapping, TupleTag<OutputT> mainOutput, java.util.Map<TupleTag<?>,Coder<?>> outputCoders, java.util.List<TupleTag<?>> sideOutputs)

Method Summary

Modifier and Type	Method and Description
java.util.Iterator<TranslatorUtils.RawUnionValue>	flatMap(java.util.List<TranslatorUtils.RawUnionValue> inputs)
void	setup()
void	teardown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DoFnFunction

public DoFnFunction(GearpumpPipelineOptions pipelineOptions,
                    DoFn<InputT,OutputT> doFn,
                    WindowingStrategy<?,?> windowingStrategy,
                    java.util.Collection<PCollectionView<?>> sideInputs,
                    java.util.Map<java.lang.String,PCollectionView<?>> sideInputTagMapping,
                    TupleTag<OutputT> mainOutput,
                    java.util.Map<TupleTag<?>,Coder<?>> outputCoders,
                    java.util.List<TupleTag<?>> sideOutputs)

Method Detail

setup

public void setup()

Overrides:

setup in class org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction

teardown

public void teardown()

Overrides:

teardown in class org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction

flatMap

public java.util.Iterator<TranslatorUtils.RawUnionValue> flatMap(java.util.List<TranslatorUtils.RawUnionValue> inputs)

Specified by:

flatMap in class org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction<java.util.List<TranslatorUtils.RawUnionValue>,TranslatorUtils.RawUnionValue>