Package | Description |
---|---|
org.apache.flink.streaming.api.datastream |
Constructor and Description |
---|
KeyedStream(DataStream<T> stream,
PartitionTransformation<T> partitionTransformation,
KeySelector<T,KEY> keySelector,
TypeInformation<KEY> keyType)
Creates a new
KeyedStream using the given KeySelector and TypeInformation
to partition operator state by key, where the partitioning is defined by a PartitionTransformation . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.