This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b60c1f9 [FLINK-19793][connector-kafka] Harden
KafkaTableITCase.testKafkaSourceSinkWithMetadata
add 19884a8 [hotfix][testing] Add common test utility for collecting all
elements from a stream
add 3a08d33 [FLINK-13095][state-processor-api] Expose trigger state in
window reader
add eeb0ec5 [FLINK-13095][state-processor-api] Introduce window bootstrap
writer for writing window operator state
No new revisions were added by this update.
Summary of changes:
docs/dev/libs/state_processor_api.md | 57 ++-
docs/dev/libs/state_processor_api.zh.md | 125 ++++--
.../flink/state/api/BootstrapTransformation.java | 11 +-
.../state/api/KeyedOperatorTransformation.java | 28 +-
.../state/api/OneInputOperatorTransformation.java | 35 +-
.../state/api/WindowedOperatorTransformation.java | 464 +++++++++++++++++++++
.../flink/state/api/functions/Timestamper.java | 16 +-
.../state/api/functions/WindowReaderFunction.java | 14 +
.../api/input/operator/WindowReaderOperator.java | 9 +
.../output/BoundedOneInputStreamTaskRunner.java | 10 +-
.../flink/state/api/output/BoundedStreamTask.java | 18 +-
.../state/api/output/TimestampAssignerWrapper.java | 22 +-
.../operators/StateBootstrapWrapperOperator.java | 208 +++++++++
.../state/api/SavepointWindowReaderITCase.java | 57 +++
.../flink/state/api/SavepointWriterITCase.java | 42 +-
.../state/api/SavepointWriterWindowITCase.java | 415 ++++++++++++++++++
.../flink/state/api/utils/MaxWatermarkSource.java | 24 +-
.../flink/streaming/util/StreamCollector.java | 146 +++++++
18 files changed, 1580 insertions(+), 121 deletions(-)
create mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/WindowedOperatorTransformation.java
copy
flink-core/src/main/java/org/apache/flink/api/connector/source/SourceSplit.java
=>
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/Timestamper.java
(74%)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DayTimeIntervalDurationConverter.java
=>
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/TimestampAssignerWrapper.java
(63%)
create mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/StateBootstrapWrapperOperator.java
create mode 100644
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/SavepointWriterWindowITCase.java
copy
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BasePathBucketer.java
=>
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/MaxWatermarkSource.java
(63%)
create mode 100644
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/StreamCollector.java
