Uses of Interface
org.apache.flink.datastream.api.stream.NonKeyedPartitionStream
-
Packages that use NonKeyedPartitionStream Package Description org.apache.flink.datastream.api org.apache.flink.datastream.api.stream -
-
Uses of NonKeyedPartitionStream in org.apache.flink.datastream.api
Methods in org.apache.flink.datastream.api that return NonKeyedPartitionStream Modifier and Type Method Description <OUT> NonKeyedPartitionStream<OUT>ExecutionEnvironment. fromSource(org.apache.flink.api.connector.dsv2.Source<OUT> source, String sourceName) -
Uses of NonKeyedPartitionStream in org.apache.flink.datastream.api.stream
Subinterfaces of NonKeyedPartitionStream in org.apache.flink.datastream.api.stream Modifier and Type Interface Description static interfaceNonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T>This interface represents a configurableNonKeyedPartitionStream.Methods in org.apache.flink.datastream.api.stream that return NonKeyedPartitionStream Modifier and Type Method Description NonKeyedPartitionStream<T>GlobalStream. shuffle()Transform this stream to a newNonKeyedPartitionStream, data will be shuffled between these two streams.NonKeyedPartitionStream<T>KeyedPartitionStream. shuffle()Transform this stream to a newNonKeyedPartitionStream, data will be shuffled between these two streams.NonKeyedPartitionStream<T>NonKeyedPartitionStream. shuffle()Transform this stream to a newNonKeyedPartitionStream, data will be shuffled between these two streams.Methods in org.apache.flink.datastream.api.stream with parameters of type NonKeyedPartitionStream Modifier and Type Method Description <T_OTHER,OUT>
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT>BroadcastStream. connectAndProcess(NonKeyedPartitionStream<T_OTHER> other, TwoInputBroadcastStreamProcessFunction<T_OTHER,T,OUT> processFunction)Apply a two input operation to this and otherNonKeyedPartitionStream.<T_OTHER,OUT>
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT>NonKeyedPartitionStream. connectAndProcess(NonKeyedPartitionStream<T_OTHER> other, TwoInputNonBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)Apply to a two input operation on this and otherNonKeyedPartitionStream.
-