This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from aa7158934bb [FLINK-34660][checkpoint] Avoid randomizing
changelog-related config when it's pre-defined (#24488)
new 4762311e284 [FLINK-34543][datastream] Introduce the
PartitionWindowedStream
new cfbd41ecaa1 [FLINK-34543][datastream] Introduce the MapPartition API
on PartitionWindowedStream
new fe88e16faf5 [FLINK-34543][datastream] Introduce the Reduce API on
PartitionWindowedStream
new 46ec4b02ec2 [FLINK-34543][datastream] Introduce the Aggregate API on
PartitionWindowedStream
new a021db68a85 [FLINK-34543][datastream] Introduce the SortPartition API
on PartitionWindowedStream
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../generated/execution_configuration.html | 12 +
.../flink/configuration/ExecutionOptions.java | 18 +
.../flink/streaming/api/datastream/DataStream.java | 12 +
.../streaming/api/datastream/IterativeStream.java | 6 +
.../datastream/KeyedPartitionWindowedStream.java | 175 +++++++
.../streaming/api/datastream/KeyedStream.java | 13 +
.../NonKeyedPartitionWindowedStream.java | 167 +++++++
.../api/datastream/PartitionWindowedStream.java | 127 +++++
.../api/operators/MapPartitionIterator.java | 217 +++++++++
.../api/operators/MapPartitionOperator.java | 77 +++
.../api/operators/PartitionAggregateOperator.java | 65 +++
.../api/operators/PartitionReduceOperator.java | 60 +++
.../FixedLengthByteKeyAndValueComparator.java | 180 +++++++
.../sortpartition/KeyAndValueSerializer.java | 175 +++++++
.../sortpartition/KeyedSortPartitionOperator.java | 355 ++++++++++++++
.../sortpartition/SortPartitionOperator.java | 286 +++++++++++
.../VariableLengthByteKeyAndValueComparator.java | 189 ++++++++
.../OneInputTransformationTranslator.java | 12 +
.../api/operators/MapPartitionIteratorTest.java | 278 +++++++++++
.../api/operators/MapPartitionOperatorTest.java | 117 +++++
.../operators/PartitionAggregateOperatorTest.java | 137 ++++++
.../api/operators/PartitionReduceOperatorTest.java | 108 +++++
.../FixedLengthByteKeyAndValueComparatorTest.java | 63 +++
.../sortpartition/KeyAndValueSerializerTest.java | 71 +++
.../KeyedSortPartitionOperatorTest.java | 187 ++++++++
.../SerializerComparatorTestData.java | 101 ++++
.../sortpartition/SortPartitionOperatorTest.java | 168 +++++++
...ariableLengthByteKeyAndValueComparatorTest.java | 64 +++
.../scala/StreamingScalaAPICompletenessTest.scala | 7 +-
.../TypeSerializerTestCoverageTest.java | 5 +-
.../KeyedPartitionWindowedStreamITCase.java | 521 +++++++++++++++++++++
.../NonKeyedPartitionWindowedStreamITCase.java | 366 +++++++++++++++
32 files changed, 4337 insertions(+), 2 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedPartitionWindowedStream.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/NonKeyedPartitionWindowedStream.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MapPartitionIterator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MapPartitionOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/PartitionAggregateOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/PartitionReduceOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sortpartition/FixedLengthByteKeyAndValueComparator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sortpartition/KeyAndValueSerializer.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sortpartition/KeyedSortPartitionOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sortpartition/SortPartitionOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sortpartition/VariableLengthByteKeyAndValueComparator.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/MapPartitionIteratorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/MapPartitionOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/PartitionAggregateOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/PartitionReduceOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sortpartition/FixedLengthByteKeyAndValueComparatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sortpartition/KeyAndValueSerializerTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sortpartition/KeyedSortPartitionOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sortpartition/SerializerComparatorTestData.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sortpartition/SortPartitionOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sortpartition/VariableLengthByteKeyAndValueComparatorTest.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/KeyedPartitionWindowedStreamITCase.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/NonKeyedPartitionWindowedStreamITCase.java
