This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3bf5786 [FLINK-19824][table-api] Refactor and merge
SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces
add 29dde69 [FLINK-19835] Rename TimestampsAndWatermarks implementations
to better reflect their purpose
add ba9ebcf [FLINK-19835] Turn SourceTransformation into a logical
Transformation
add 16e40b6 [FLINK-19835] Make SourceOperator aware of BATCH/STREAMING
execution mode
add 1c4e5c4 [refactor] Add a DEFAULT_CHAINING_STRATEGY
No new revisions were added by this update.
Summary of changes:
.../streaming/api/datastream/DataStreamSource.java | 6 +-
.../operators/AbstractStreamOperatorFactory.java | 2 +-
.../streaming/api/operators/ChainingStrategy.java | 2 +
.../streaming/api/operators/SourceOperator.java | 31 ++++--
.../api/operators/SourceOperatorFactory.java | 30 +++++-
...marks.java => NoOpTimestampsAndWatermarks.java} | 16 ++--
...ava => ProgressiveTimestampsAndWatermarks.java} | 8 +-
.../source/SourceOutputWithWatermarks.java | 9 +-
.../operators/source/TimestampsAndWatermarks.java | 8 +-
.../api/transformations/SourceTransformation.java | 56 +++++++----
.../SourceTransformationTranslator.java | 34 ++++---
.../StreamGraphGeneratorBatchExecutionTest.java | 6 +-
...amGraphGeneratorExecutionModeDetectionTest.java | 20 ++--
.../api/operators/SourceOperatorTest.java | 2 +-
.../source/SourceOperatorEventTimeTest.java | 105 ++++++++++++++-------
.../operators/source/TestingSourceOperator.java | 16 ++--
16 files changed, 231 insertions(+), 120 deletions(-)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/{BatchTimestampsAndWatermarks.java
=> NoOpTimestampsAndWatermarks.java} (87%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/{StreamingTimestampsAndWatermarks.java
=> ProgressiveTimestampsAndWatermarks.java} (95%)
