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

Class NonKeyedPartitionStreamImpl<T>

java.lang.Object

org.apache.flink.datastream.impl.stream.AbstractDataStream<T>

org.apache.flink.datastream.impl.stream.NonKeyedPartitionStreamImpl<T>

All Implemented Interfaces:

DataStream, NonKeyedPartitionStream<T>

public class NonKeyedPartitionStreamImpl<T>
extends AbstractDataStream<T>
implements NonKeyedPartitionStream<T>

The implementation of NonKeyedPartitionStream.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream

NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T>, NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>

Field Summary

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

environment, requestedSideOutputs, transformation

Constructor Summary

Constructors

Constructor	Description
NonKeyedPartitionStreamImpl(ExecutionEnvironmentImpl environment, Transformation<T> transformation)

Method Summary

Modifier and Type	Method	Description
BroadcastStream<T>	broadcast()	Transform this stream to a new BroadcastStream.
<T_OTHER,OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT>	connectAndProcess(BroadcastStream<T_OTHER> other, TwoInputBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)	Apply a two input operation to this and other BroadcastStream.
<T_OTHER,OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT>	connectAndProcess(NonKeyedPartitionStream<T_OTHER> other, TwoInputNonBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)	Apply to a two input operation on this and other NonKeyedPartitionStream.
GlobalStream<T>	global()	Coalesce this stream to a GlobalStream.
<K> KeyedPartitionStream<K,T>	keyBy(KeySelector<T,K> keySelector)	Transform this stream to a KeyedPartitionStream.
<OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT>	process(OneInputStreamProcessFunction<T,OUT> processFunction)	Apply an operation to this NonKeyedPartitionStream.
<OUT1,OUT2> NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2>	process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction)	Apply a two output operation to this NonKeyedPartitionStream.
NonKeyedPartitionStream<T>	shuffle()	Transform this stream to a new NonKeyedPartitionStream, data will be shuffled between these two streams.
ProcessConfigurable<?>	toSink(Sink<T> sink)

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

getEnvironment, getSideOutputTransform, getTransformation, getType

Methods inherited from class java.lang.Object

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

Constructor Detail

NonKeyedPartitionStreamImpl

public NonKeyedPartitionStreamImpl(ExecutionEnvironmentImpl environment,
                                   Transformation<T> transformation)

Method Detail

process

public <OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT> process(OneInputStreamProcessFunction<T,OUT> processFunction)

Description copied from interface: NonKeyedPartitionStream

Apply an operation to this NonKeyedPartitionStream.

Specified by:

process in interface NonKeyedPartitionStream<T>

Parameters:

processFunction - to perform operation.

Returns:

new stream with this operation.

process

public <OUT1,OUT2> NonKeyedPartitionStream.ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2> process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction)

Description copied from interface: NonKeyedPartitionStream

Apply a two output operation to this NonKeyedPartitionStream.

Specified by:

process in interface NonKeyedPartitionStream<T>

Parameters:

processFunction - to perform two output operation.

Returns:

new stream with this operation.

connectAndProcess

public <T_OTHER,OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT> connectAndProcess(NonKeyedPartitionStream<T_OTHER> other,
                                                                                                                        TwoInputNonBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)

Description copied from interface: NonKeyedPartitionStream

Apply to a two input operation on this and other NonKeyedPartitionStream.

Specified by:

connectAndProcess in interface NonKeyedPartitionStream<T>

Parameters:

other - NonKeyedPartitionStream to perform operation with two input.

processFunction - to perform operation.

Returns:

new stream with this operation.

connectAndProcess

public <T_OTHER,OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT> connectAndProcess(BroadcastStream<T_OTHER> other,
                                                                                                                        TwoInputBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)

Description copied from interface: NonKeyedPartitionStream

Apply a two input operation to this and other BroadcastStream.

Specified by:

connectAndProcess in interface NonKeyedPartitionStream<T>

processFunction - to perform operation.

Returns:

new stream with this operation.

toSink

public ProcessConfigurable<?> toSink(Sink<T> sink)

Specified by:

toSink in interface NonKeyedPartitionStream<T>

global

public GlobalStream<T> global()

Description copied from interface: NonKeyedPartitionStream

Coalesce this stream to a GlobalStream.

Specified by:

global in interface NonKeyedPartitionStream<T>

Returns:

the coalesced global stream.

keyBy

public <K> KeyedPartitionStream<K,T> keyBy(KeySelector<T,K> keySelector)

Description copied from interface: NonKeyedPartitionStream

Transform this stream to a KeyedPartitionStream.

Specified by:

keyBy in interface NonKeyedPartitionStream<T>

Parameters:

keySelector - to decide how to map data to partition.

Returns:

the transformed stream partitioned by key.

shuffle

public NonKeyedPartitionStream<T> shuffle()

Description copied from interface: NonKeyedPartitionStream

Transform this stream to a new NonKeyedPartitionStream, data will be shuffled between these two streams.

Specified by:

shuffle in interface NonKeyedPartitionStream<T>

Returns:

the transformed stream after shuffle.

broadcast

public BroadcastStream<T> broadcast()

Description copied from interface: NonKeyedPartitionStream

Transform this stream to a new BroadcastStream.

Specified by:

broadcast in interface NonKeyedPartitionStream<T>

Returns:

the transformed BroadcastStream.