Package org.apache.beam.runners.flink.translation.wrappers.streaming

Class DoFnOperator.MultiOutputOutputManagerFactory<OutputT>

java.lang.Object

org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.MultiOutputOutputManagerFactory<OutputT>

All Implemented Interfaces:

Serializable

Enclosing class:

DoFnOperator<PreInputT,InputT,OutputT>

public static class DoFnOperator.MultiOutputOutputManagerFactory<OutputT>
extends Object

Implementation of DoFnOperator.OutputManagerFactory that creates an DoFnOperator.BufferedOutputManager that can write to multiple logical outputs by Flink side output.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
MultiOutputOutputManagerFactory(TupleTag<OutputT> mainTag, Map<TupleTag<?>,org.apache.flink.util.OutputTag<WindowedValue<?>>> tagsToOutputTags, Map<TupleTag<?>,Coder<WindowedValue<?>>> tagsToCoders, Map<TupleTag<?>,Integer> tagsToIds, org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions)
MultiOutputOutputManagerFactory(TupleTag<OutputT> mainTag, Coder<WindowedValue<OutputT>> mainCoder, org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions)

Method Summary

Modifier and Type	Method	Description
DoFnOperator.BufferedOutputManager<OutputT>	create(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<WindowedValue<OutputT>>> output, Lock bufferLock, org.apache.flink.runtime.state.OperatorStateBackend operatorStateBackend)

Methods inherited from class java.lang.Object

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

Constructor Details

MultiOutputOutputManagerFactory

public MultiOutputOutputManagerFactory(TupleTag<OutputT> mainTag,
 Coder<WindowedValue<OutputT>> mainCoder,
 org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions)

MultiOutputOutputManagerFactory

public MultiOutputOutputManagerFactory(TupleTag<OutputT> mainTag,
 Map<TupleTag<?>,org.apache.flink.util.OutputTag<WindowedValue<?>>> tagsToOutputTags,
 Map<TupleTag<?>,Coder<WindowedValue<?>>> tagsToCoders,
 Map<TupleTag<?>,Integer> tagsToIds,
 org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions)

Method Details

create

public DoFnOperator.BufferedOutputManager<OutputT> create(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<WindowedValue<OutputT>>> output,
 Lock bufferLock,
 org.apache.flink.runtime.state.OperatorStateBackend operatorStateBackend)
                                                   throws Exception

Throws:

Exception