Package org.apache.flink.datastream.impl.stream

Class ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl<OUT1,OUT2>

java.lang.Object

org.apache.flink.datastream.impl.stream.ProcessConfigureHandle<OUT1,NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>>

org.apache.flink.datastream.impl.stream.ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl<OUT1,OUT2>

All Implemented Interfaces:

NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>, ProcessConfigurable<NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>>

public class ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl<OUT1,OUT2>
extends ProcessConfigureHandle<OUT1,NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>>
implements NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>

ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl is used to hold the two output non-keyed streams and provide methods used for configuration.

Field Summary

Fields inherited from class org.apache.flink.datastream.impl.stream.ProcessConfigureHandle

environment, transformation

Constructor Summary

Constructors

Constructor	Description
ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl(ExecutionEnvironmentImpl environment, Transformation<OUT1> transformation, NonKeyedPartitionStreamImpl<OUT1> firstStream, NonKeyedPartitionStreamImpl<OUT2> secondStream)

Method Summary

Modifier and Type	Method	Description
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT1>	getFirst()	Get the first stream.
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT2>	getSecond()	Get the second stream.

Methods inherited from class org.apache.flink.datastream.impl.stream.ProcessConfigureHandle

canBeParallel, withMaxParallelism, withName, withParallelism, withSlotSharingGroup, withUid

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.datastream.api.stream.ProcessConfigurable

withMaxParallelism, withName, withParallelism, withSlotSharingGroup, withUid

Constructor Detail

ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl

public ProcessConfigurableAndTwoNonKeyedPartitionStreamImpl(ExecutionEnvironmentImpl environment,
                                                            Transformation<OUT1> transformation,
                                                            NonKeyedPartitionStreamImpl<OUT1> firstStream,
                                                            NonKeyedPartitionStreamImpl<OUT2> secondStream)

Method Detail

getFirst

public NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT1> getFirst()

Description copied from interface: NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream

Get the first stream.

Specified by:

getFirst in interface NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>

getSecond

public NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT2> getSecond()

Description copied from interface: NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream

Get the second stream.

Specified by:

getSecond in interface NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>