This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6faaa37 [FLINK-21519] Temporarily disable SQLClientHBaseITCase
add 276e847 [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime
attribute
No new revisions were added by this update.
Summary of changes:
.../PythonStreamGroupWindowAggregateOperator.java | 15 +-
...PythonGroupWindowAggregateFunctionOperator.java | 35 +-
...ghPythonStreamGroupWindowAggregateOperator.java | 9 +-
.../flink/table/catalog/DefaultSchemaResolver.java | 51 +-
.../flink/table/catalog/SchemaResolutionTest.java | 113 ++++
.../java/org/apache/flink/table/api/Schema.java | 4 +-
.../org/apache/flink/table/api/TableSchema.java | 11 +-
.../types/logical/utils/LogicalTypeChecks.java | 22 +-
.../apache/flink/table/api/TableSchemaTest.java | 28 +-
.../table/planner/catalog/CatalogSchemaTable.java | 4 +-
.../expressions/PlannerRowtimeAttribute.java | 7 +-
.../functions/sql/FlinkSqlOperatorTable.java | 16 +-
.../exec/serde/RelDataTypeJsonDeserializer.java | 5 +-
.../exec/serde/RelDataTypeJsonSerializer.java | 2 +
.../nodes/exec/stream/StreamExecLegacySink.java | 14 +-
.../stream/StreamExecLocalWindowAggregate.java | 3 +-
.../plan/nodes/exec/stream/StreamExecMatch.java | 4 +-
...WatermarkIntoTableSourceScanAcrossCalcRule.java | 7 +-
.../table/planner/calcite/FlinkTypeFactory.scala | 21 +-
.../calcite/RelTimeIndicatorConverter.scala | 117 +++-
.../table/planner/codegen/ExprCodeGenerator.scala | 2 +-
.../table/planner/codegen/GenerateUtils.scala | 9 +-
.../table/planner/codegen/MatchCodeGenerator.scala | 5 +-
.../codegen/WatermarkGeneratorCodeGenerator.scala | 5 +-
.../plan/nodes/calcite/WatermarkAssigner.scala | 6 +-
...gicalCorrelateToJoinFromTemporalTableRule.scala | 8 +
.../StreamPhysicalGroupWindowAggregateRule.scala | 1 -
.../stream/StreamPhysicalIntervalJoinRule.scala | 13 +
.../plan/schema/LegacyCatalogSourceTable.scala | 2 +-
.../plan/schema/TimeIndicatorRelDataType.scala | 8 +-
.../table/planner/plan/utils/WindowUtil.scala | 4 +-
.../nodes/exec/serde/RelDataTypeSerdeTest.java | 3 +-
.../jsonplan/GroupWindowAggregateJsonITCase.java | 2 +-
.../stream/jsonplan/TemporalSortJsonITCase.java | 2 +-
.../stream/jsonplan/WindowAggregateJsonITCase.java | 2 +-
.../testDeduplication.out | 1 +
.../testProcTimeHopWindow.out | 40 +-
.../testProcTimeSessionWindow.out | 40 +-
.../testProcTimeTumbleWindow.out | 46 +-
.../testProcessingTimeInnerJoinWithOnClause.out | 78 +--
.../testJoinTemporalTable.out | 3 +
...testJoinTemporalTableWithProjectionPushDown.out | 3 +
.../testMatch.out | 27 +-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 46 +-
.../testProcTimeBoundedPartitionedRangeOver.out | 46 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 39 +-
.../testProcTimeUnboundedPartitionedRangeOver.out | 46 +-
...stProctimeBoundedDistinctPartitionedRowOver.out | 46 +-
...edDistinctWithNonDistinctPartitionedRowOver.out | 46 +-
.../testSortProcessingTime.out | 39 +-
.../testEventTimeCumulateWindow.out | 52 +-
.../testEventTimeHopWindow.out | 52 +-
.../testEventTimeTumbleWindow.out | 52 +-
.../testProcTimeCumulateWindow.out | 46 +-
.../testProcTimeHopWindow.out | 46 +-
.../testProcTimeTumbleWindow.out | 46 +-
.../ExpandWindowTableFunctionTransposeRuleTest.xml | 6 +-
.../planner/plan/stream/sql/MatchRecognizeTest.xml | 66 ++
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 2 +-
.../stream/sql/RelTimeIndicatorConverterTest.xml | 2 +-
.../plan/stream/sql/SourceWatermarkTest.xml | 97 +--
.../table/planner/plan/stream/sql/UnionTest.xml | 35 ++
.../planner/plan/stream/sql/WindowRankTest.xml | 26 +-
.../plan/stream/sql/WindowTableFunctionTest.xml | 8 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 162 ++---
.../plan/stream/sql/join/IntervalJoinTest.xml | 140 +++--
.../stream/sql/join/TemporalFunctionJoinTest.xml | 8 +-
.../plan/stream/sql/join/TemporalJoinTest.xml | 33 +
.../plan/stream/sql/join/WindowJoinTest.xml | 64 +-
.../stream/table/TemporalTableFunctionJoinTest.xml | 10 +-
.../plan/schema/TimeIndicatorRelDataTypeTest.scala | 9 +-
.../plan/stream/sql/MatchRecognizeTest.scala | 71 +++
.../plan/stream/sql/SourceWatermarkTest.scala | 132 ++--
.../table/planner/plan/stream/sql/UnionTest.scala | 78 ++-
.../plan/stream/sql/join/IntervalJoinTest.scala | 56 ++
.../plan/stream/sql/join/TemporalJoinTest.scala | 49 ++
.../TemporalTableJoinValidationTest.scala | 2 +-
.../harness/WindowAggregateHarnessTest.scala | 14 +-
...WindowAggregateUseDaylightTimeHarnessTest.scala | 4 +-
.../runtime/stream/sql/GroupWindowITCase.scala | 343 +++++-----
.../runtime/stream/sql/MatchRecognizeITCase.scala | 69 +-
.../runtime/stream/sql/SourceWatermarkITCase.scala | 56 +-
.../runtime/stream/sql/TimeAttributeITCase.scala | 51 +-
.../runtime/stream/sql/WindowAggregateITCase.scala | 58 +-
.../stream/sql/WindowDistinctAggregateITCase.scala | 2 +-
.../runtime/stream/sql/WindowRankITCase.scala | 2 +-
.../table/planner/runtime/utils/TestData.scala | 59 +-
.../table/planner/utils/DateTimeTestUtil.scala | 7 +-
.../window/LocalSlicingWindowAggOperator.java | 59 +-
.../window/SlicingWindowAggOperatorBuilder.java | 2 +-
.../window/buffers/RecordsWindowBuffer.java | 27 +-
.../aggregate/window/buffers/WindowBuffer.java | 5 +-
.../window/combines/AggRecordsCombiner.java | 10 +-
.../window/combines/GlobalAggAccCombiner.java | 10 +-
.../processors/AbstractWindowAggProcessor.java | 28 +-
.../processors/SliceSharedWindowAggProcessor.java | 7 +-
.../rank/window/WindowRankOperatorBuilder.java | 5 +-
.../rank/window/combines/TopNRecordsCombiner.java | 10 +-
.../window/processors/WindowRankProcessor.java | 21 +-
.../runtime/operators/window/WindowOperator.java | 28 +-
.../operators/window/WindowOperatorBuilder.java | 2 +-
.../window/combines/WindowCombineFunction.java | 4 +-
.../internal/InternalWindowProcessFunction.java | 12 +-
.../internal/MergingWindowProcessFunction.java | 8 +-
.../operators/window/slicing/SliceAssigners.java | 10 +-
.../window/slicing/SlicingWindowOperator.java | 20 +-
.../window/slicing/WindowTimerService.java | 57 ++
.../window/slicing/WindowTimerServiceImpl.java | 44 +-
.../window/triggers/EventTimeTriggers.java | 42 +-
.../window/triggers/ProcessingTimeTriggers.java | 27 +-
.../runtime/operators/window/triggers/Trigger.java | 4 +
.../operators/window/triggers/WindowTrigger.java} | 34 +-
.../table/runtime/types/PlannerTypeUtils.java | 1 +
.../table/runtime/typeutils/TypeCheckUtils.java | 5 +-
.../flink/table/runtime/util/TimeWindowUtil.java | 73 ++-
.../window/SlicingWindowAggOperatorTest.java | 111 ++--
.../operators/window/WindowOperatorTest.java | 693 ++++++++++++++-------
.../table/runtime/util/TimeWindowUtilTest.java | 119 ++++
118 files changed, 3100 insertions(+), 1499 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/MatchRecognizeTest.xml
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/MatchRecognizeTest.scala
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/WindowTimerService.java
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/SimpleTimerService.java
=>
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/WindowTimerServiceImpl.java
(54%)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{filesystem/PartitionComputer.java
=> runtime/operators/window/triggers/WindowTrigger.java} (52%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/TimeWindowUtilTest.java
