@Experimental public interface NonKeyedPartitionStream<T> extends DataStream
Modifier and Type | Interface and Description |
---|---|
static interface |
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T>
This interface represents a configurable
NonKeyedPartitionStream . |
static interface |
NonKeyedPartitionStream.TwoNonKeyedPartitionStreams<T1,T2>
This interface represents a combination of two
NonKeyedPartitionStream . |
<OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT> process(OneInputStreamProcessFunction<T,OUT> processFunction)
NonKeyedPartitionStream
.processFunction
- to perform operation.<OUT1,OUT2> NonKeyedPartitionStream.TwoNonKeyedPartitionStreams<OUT1,OUT2> process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction)
NonKeyedPartitionStream
.processFunction
- to perform two output operation.<T_OTHER,OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT> connectAndProcess(NonKeyedPartitionStream<T_OTHER> other, TwoInputNonBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)
NonKeyedPartitionStream
.other
- NonKeyedPartitionStream
to perform operation with two input.processFunction
- to perform operation.<T_OTHER,OUT> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<OUT> connectAndProcess(BroadcastStream<T_OTHER> other, TwoInputBroadcastStreamProcessFunction<T,T_OTHER,OUT> processFunction)
BroadcastStream
.processFunction
- to perform operation.GlobalStream<T> global()
GlobalStream
.<K> KeyedPartitionStream<K,T> keyBy(KeySelector<T,K> keySelector)
KeyedPartitionStream
.keySelector
- to decide how to map data to partition.NonKeyedPartitionStream<T> shuffle()
NonKeyedPartitionStream
, data will be shuffled between
these two streams.BroadcastStream<T> broadcast()
BroadcastStream
.BroadcastStream
.ProcessConfigurable<?> toSink(Sink<T> sink)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.