Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.connectors.kafka.shuffle |
Modifier and Type | Method and Description |
---|---|
KeyedStream<T,Tuple> |
DataStream.keyBy(int... fields)
Deprecated.
|
<K> KeyedStream<T,K> |
DataStream.keyBy(KeySelector<T,K> key)
It creates a new
KeyedStream that uses the provided key for partitioning its operator
states. |
<K> KeyedStream<T,K> |
DataStream.keyBy(KeySelector<T,K> key,
TypeInformation<K> keyType)
It creates a new
KeyedStream that uses the provided key with explicit type
information for partitioning its operator states. |
KeyedStream<T,Tuple> |
DataStream.keyBy(String... fields)
Deprecated.
|
static <T,K> KeyedStream<T,K> |
DataStreamUtils.reinterpretAsKeyedStream(DataStream<T> stream,
KeySelector<T,K> keySelector)
|
static <T,K> KeyedStream<T,K> |
DataStreamUtils.reinterpretAsKeyedStream(DataStream<T> stream,
KeySelector<T,K> keySelector,
TypeInformation<K> typeInfo)
|
Modifier and Type | Method and Description |
---|---|
<T1> KeyedStream.IntervalJoin<T,T1,KEY> |
KeyedStream.intervalJoin(KeyedStream<T1,KEY> otherStream)
Join elements of this
KeyedStream with elements of another KeyedStream over a
time interval that can be specified with KeyedStream.IntervalJoin.between(Time, Time) . |
Constructor and Description |
---|
IntervalJoined(KeyedStream<IN1,KEY> left,
KeyedStream<IN2,KEY> right,
long lowerBound,
long upperBound,
boolean lowerBoundInclusive,
boolean upperBoundInclusive) |
IntervalJoined(KeyedStream<IN1,KEY> left,
KeyedStream<IN2,KEY> right,
long lowerBound,
long upperBound,
boolean lowerBoundInclusive,
boolean upperBoundInclusive) |
WindowedStream(KeyedStream<T,K> input,
WindowAssigner<? super T,W> windowAssigner) |
Modifier and Type | Method and Description |
---|---|
static <T> KeyedStream<T,Tuple> |
FlinkKafkaShuffle.persistentKeyBy(DataStream<T> dataStream,
String topic,
int producerParallelism,
int numberOfPartitions,
Properties properties,
int... fields)
Uses Kafka as a message bus to persist keyBy shuffle.
|
static <T,K> KeyedStream<T,K> |
FlinkKafkaShuffle.persistentKeyBy(DataStream<T> dataStream,
String topic,
int producerParallelism,
int numberOfPartitions,
Properties properties,
KeySelector<T,K> keySelector)
Uses Kafka as a message bus to persist keyBy shuffle.
|
static <T,K> KeyedStream<T,K> |
FlinkKafkaShuffle.readKeyBy(String topic,
StreamExecutionEnvironment env,
TypeInformation<T> typeInformation,
Properties kafkaProperties,
KeySelector<T,K> keySelector)
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.