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 00a94ad50ba [FLINK-36416][table][runtime] Enable splittable timers for
temporal join, temporal sort and windowed aggregations
new b2d7a908ff2 [FLINK-36355][runtime] Remove deprecated
WindowedStream#apply
new a75df8776fe [FLINK-36355][runtime] Remove deprecated TimestampAssigner
new e54bbc0a517 [FLINK-36355][runtime] Remove deprecated
WindowAssigner#getDefaultTrigger
new d7c87f23fa3 [FLINK-36355][runtime] Remove deprecated TimeCharacteristic
The 4 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:
.../file/table/stream/StreamingFileWriterTest.java | 2 -
.../flink/api/common/state/StateTtlConfig.java | 5 +-
.../datastream/impl/ExecutionEnvironmentImpl.java | 7 +-
.../tests/DataStreamAllroundTestJobFactory.java | 4 +-
.../tests/DataStreamAllroundTestProgram.java | 4 +-
.../python/datastream/data_stream_job.py | 3 +-
.../RocksDBStateMemoryControlTestProgram.java | 4 +-
.../tests/StatefulStreamJobUpgradeTestProgram.java | 6 +-
.../ContinuousFileProcessingMigrationTest.java | 3 -
.../hdfstests/ContinuousFileProcessingTest.java | 191 ---------------------
.../test/java/org/apache/flink/cep/CEPITCase.java | 17 +-
.../stream_execution_environment.rst | 2 -
.../docs/reference/pyflink.datastream/timer.rst | 11 --
flink-python/pyflink/datastream/__init__.py | 5 -
flink-python/pyflink/datastream/functions.py | 15 +-
.../datastream/stream_execution_environment.py | 35 ----
.../pyflink/datastream/tests/test_data_stream.py | 6 +-
.../pyflink/datastream/time_characteristic.py | 95 ----------
.../flink/streaming/api/TimeCharacteristic.java | 98 -----------
.../api/datastream/AllWindowedStream.java | 145 ----------------
.../flink/streaming/api/datastream/DataStream.java | 50 ------
.../streaming/api/datastream/WindowedStream.java | 51 ------
.../environment/StreamExecutionEnvironment.java | 54 ------
.../api/functions/KeyedProcessFunction.java | 3 +-
.../streaming/api/functions/ProcessFunction.java | 3 +-
.../streaming/api/functions/TimestampAssigner.java | 50 ------
.../functions/co/BaseBroadcastProcessFunction.java | 3 +-
.../api/functions/co/CoProcessFunction.java | 3 +-
.../api/functions/co/KeyedCoProcessFunction.java | 3 +-
.../source/ContinuousFileReaderOperator.java | 1 -
.../flink/streaming/api/graph/StreamConfig.java | 18 --
.../flink/streaming/api/graph/StreamGraph.java | 11 --
.../streaming/api/graph/StreamGraphGenerator.java | 12 --
.../api/graph/StreamingJobGraphGenerator.java | 2 -
.../streaming/api/operators/StreamSource.java | 4 -
.../api/operators/StreamSourceContexts.java | 51 +-----
.../api/windowing/assigners/GlobalWindows.java | 7 -
.../assigners/SlidingEventTimeWindows.java | 10 +-
.../assigners/SlidingProcessingTimeWindows.java | 7 -
.../assigners/TumblingEventTimeWindows.java | 10 +-
.../assigners/TumblingProcessingTimeWindows.java | 7 -
.../api/windowing/assigners/WindowAssigner.java | 22 +--
.../AssignerWithPeriodicWatermarksAdapter.java | 84 ---------
.../AssignerWithPunctuatedWatermarksAdapter.java | 87 ----------
.../WatermarkStrategyWithPeriodicWatermarks.java} | 50 +++++-
...WatermarkStrategyWithPunctuatedWatermarks.java} | 51 +++++-
.../flink/streaming/runtime/tasks/StreamTask.java | 5 +-
.../source/ContinuousFileReaderOperatorTest.java | 3 -
.../StreamSourceContextIdleDetectionTests.java | 173 -------------------
.../ContinuousFileProcessingRescalingTest.java | 2 -
.../StreamSourceOperatorLatencyMetricsTest.java | 2 -
.../windowing/TimeWindowTranslationTest.java | 4 -
.../tasks/InterruptSensitiveRestoreTest.java | 2 -
.../util/AbstractStreamOperatorTestHarness.java | 9 -
.../timestamps/AscendingTimestampExtractor.java | 5 +-
.../BoundedOutOfOrdernessTimestampExtractor.java | 9 +-
.../assigners/DynamicEventTimeSessionWindows.java | 8 -
.../DynamicProcessingTimeSessionWindows.java | 8 -
.../assigners/EventTimeSessionWindows.java | 7 -
.../assigners/ProcessingTimeSessionWindows.java | 7 -
.../apache/flink/streaming/api/DataStreamTest.java | 4 +-
.../AbstractUdfStreamOperatorLifecycleTest.java | 3 -
.../StreamSourceOperatorWatermarksTest.java | 100 -----------
.../windowing/AllWindowTranslationTest.java | 2 +-
.../operators/windowing/MergingWindowSetTest.java | 7 -
.../operators/windowing/WindowTranslationTest.java | 4 +-
.../runtime/tasks/SourceStreamTaskTest.java | 7 -
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 3 -
.../runtime/tasks/StreamTaskSystemExitTest.java | 2 -
.../streaming/runtime/tasks/StreamTaskTest.java | 5 -
.../runtime/tasks/StreamTaskTestHarness.java | 2 -
.../AbstractStreamTableEnvironmentImpl.java | 9 +-
.../java/internal/StreamTableEnvironmentImpl.java | 8 -
.../internal/StreamTableEnvironmentImpl.scala | 17 --
.../stream/StreamExecLegacyTableSourceScan.java | 6 +-
.../utils/DummyStreamExecutionEnvironment.java | 12 --
.../runtime/stream/sql/AggregateITCase.scala | 5 -
.../runtime/stream/sql/IntervalJoinITCase.scala | 6 +-
.../planner/runtime/stream/sql/JoinITCase.scala | 5 -
.../sql/TemporalTableFunctionJoinITCase.scala | 6 -
.../table/planner/runtime/utils/TimeTestUtil.scala | 4 +-
.../flink/table/planner/utils/TableTestBase.scala | 13 +-
.../PeriodicWatermarkAssignerWrapper.java | 5 +-
.../ProcTimeMiniBatchAssignerOperator.java | 5 +-
...ava => PunctuatedWatermarkStrategyWrapper.java} | 8 +-
.../streaming/runtime/BroadcastStateITCase.java | 4 +-
.../test/streaming/runtime/CoGroupJoinITCase.java | 6 +-
.../test/streaming/runtime/SideOutputITCase.java | 4 +-
.../streaming/runtime/StreamTaskTimerITCase.java | 27 ---
.../test/streaming/runtime/TimestampITCase.java | 28 ---
90 files changed, 174 insertions(+), 1699 deletions(-)
delete mode 100644 flink-python/pyflink/datastream/time_characteristic.py
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/streaming/api/TimeCharacteristic.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/TimestampAssigner.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/operators/util/AssignerWithPeriodicWatermarksAdapter.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/operators/util/AssignerWithPunctuatedWatermarksAdapter.java
rename
flink-runtime/src/main/java/org/apache/flink/streaming/{api/functions/AssignerWithPeriodicWatermarks.java
=> runtime/operators/util/WatermarkStrategyWithPeriodicWatermarks.java} (62%)
rename
flink-runtime/src/main/java/org/apache/flink/streaming/{api/functions/AssignerWithPunctuatedWatermarks.java
=> runtime/operators/util/WatermarkStrategyWithPunctuatedWatermarks.java} (66%)
rename
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/{PunctuatedWatermarkAssignerWrapper.java
=> PunctuatedWatermarkStrategyWrapper.java} (91%)
