This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c775463 [FLINK-21177][runtime] Support limiting max total resources
for fine-grained resource management.
add edcaa30 [FLINK-21646][table-planner-blink] Port the classes in
windowingSpecs.scala to Java
add 7fc7fc6 [FLINK-21646][table-planner-blink] Port the classes in
plannerWindowProperties.scala to Java
add 0355039 [FLINK-21646][table-planner-blink] Port
FlinkRelBuilder.PlannerNamedWindowProperty to Java
add cc79fb3 [FLINK-21646][table-planner-blink] Support Duration json
serialization/deserialization
add 4c4ba6c [FLINK-21646][table-planner-blink] Support
StreamExecWindowAggregate json serialization/deserialization
No new revisions were added by this update.
Summary of changes:
.../PythonStreamGroupWindowAggregateOperator.java | 9 +-
...PythonGroupWindowAggregateFunctionOperator.java | 8 +-
...ghPythonStreamGroupWindowAggregateOperator.java | 8 +-
...thonStreamGroupWindowAggregateOperatorTest.java | 15 +-
...onGroupWindowAggregateFunctionOperatorTest.java | 12 +-
.../expressions/AbstractPlannerWindowProperty.java | 39 ++
.../expressions/PlannerNamedWindowProperty.java | 56 +++
.../expressions/PlannerProctimeAttribute.java | 48 +++
.../expressions/PlannerRowtimeAttribute.java | 62 +++
.../planner/expressions/PlannerWindowEnd.java | 46 ++
.../planner/expressions/PlannerWindowProperty.java | 39 ++
.../expressions/PlannerWindowReference.java | 64 +++
.../planner/expressions/PlannerWindowStart.java | 47 +++
.../planner/plan/QueryOperationConverter.java | 18 +-
.../planner/plan/logical/CumulativeWindowSpec.java | 82 ++++
.../planner/plan/logical/HoppingWindowSpec.java | 82 ++++
.../logical/TimeAttributeWindowingStrategy.java | 56 +++
.../planner/plan/logical/TumblingWindowSpec.java | 69 +++
.../logical/WindowAttachedWindowingStrategy.java | 72 ++++
.../table/planner/plan/logical/WindowSpec.java | 34 ++
.../planner/plan/logical/WindowingStrategy.java | 80 ++++
.../exec/batch/BatchExecHashWindowAggregate.java | 2 +-
.../batch/BatchExecPythonGroupWindowAggregate.java | 8 +-
.../exec/batch/BatchExecSortWindowAggregate.java | 2 +-
.../nodes/exec/serde/DurationJsonDeserializer.java | 46 ++
.../nodes/exec/serde/DurationJsonSerializer.java | 44 ++
.../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 3 +
.../stream/StreamExecGroupWindowAggregate.java | 6 +-
.../StreamExecPythonGroupWindowAggregate.java | 10 +-
.../exec/stream/StreamExecWindowAggregate.java | 73 +++-
.../table/planner/calcite/FlinkRelBuilder.scala | 12 +-
.../codegen/agg/AggsHandlerCodeGenerator.scala | 16 +-
.../agg/batch/HashWindowCodeGenerator.scala | 4 +-
.../agg/batch/SortWindowCodeGenerator.scala | 2 +-
.../codegen/agg/batch/WindowCodeGenerator.scala | 2 +-
.../expressions/plannerWindowProperties.scala | 86 ----
.../planner/plan/logical/windowingSpecs.scala | 125 ------
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 2 +-
.../plan/metadata/FlinkRelMdUniqueGroups.scala | 2 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 2 +-
.../plan/metadata/FlinkRelMdWindowProperties.scala | 37 +-
.../nodes/calcite/LogicalWindowAggregate.scala | 2 +-
.../calcite/LogicalWindowTableAggregate.scala | 12 +-
.../plan/nodes/calcite/WindowAggregate.scala | 8 +-
.../plan/nodes/calcite/WindowTableAggregate.scala | 15 +-
.../logical/FlinkLogicalWindowAggregate.scala | 2 +-
.../logical/FlinkLogicalWindowTableAggregate.scala | 11 +-
.../batch/BatchPhysicalHashWindowAggregate.scala | 4 +-
.../BatchPhysicalHashWindowAggregateBase.scala | 2 +-
.../BatchPhysicalLocalHashWindowAggregate.scala | 4 +-
.../BatchPhysicalLocalSortWindowAggregate.scala | 4 +-
.../BatchPhysicalPythonGroupWindowAggregate.scala | 4 +-
.../batch/BatchPhysicalSortWindowAggregate.scala | 4 +-
.../BatchPhysicalSortWindowAggregateBase.scala | 2 +-
.../batch/BatchPhysicalWindowAggregateBase.scala | 4 +-
.../StreamPhysicalGroupWindowAggregate.scala | 4 +-
.../StreamPhysicalGroupWindowAggregateBase.scala | 4 +-
.../StreamPhysicalGroupWindowTableAggregate.scala | 4 +-
.../StreamPhysicalPythonGroupWindowAggregate.scala | 4 +-
.../stream/StreamPhysicalWindowAggregate.scala | 19 +-
.../logical/LogicalWindowAggregateRuleBase.scala | 7 +-
.../plan/rules/logical/WindowPropertiesRule.scala | 29 +-
.../ExpandWindowTableFunctionTransposeRule.scala | 12 +-
...indowTableFunctionIntoWindowAggregateRule.scala | 10 +-
.../stream/StreamPhysicalWindowAggregateRule.scala | 40 +-
.../stream/StreamPhysicalWindowRankRule.scala | 8 +-
.../table/planner/plan/utils/AggregateUtil.scala | 21 +-
.../table/planner/plan/utils/FlinkRelMdUtil.scala | 2 +-
.../table/planner/plan/utils/RelExplainUtil.scala | 6 +-
.../table/planner/plan/utils/WindowUtil.scala | 11 +-
.../nodes/exec/serde/DurationJsonSerdeTest.java | 69 +++
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 1 -
.../exec/stream/WindowAggregateJsonPlanTest.java | 188 +++++++++
.../stream/jsonplan/WindowAggregateJsonITCase.java | 153 +++++++
.../testEventTimeCumulateWindow.out | 404 ++++++++++++++++++
.../testEventTimeHopWindow.out | 394 +++++++++++++++++
.../testEventTimeTumbleWindow.out | 468 +++++++++++++++++++++
.../testProcTimeCumulateWindow.out | 362 ++++++++++++++++
.../testProcTimeHopWindow.out | 361 ++++++++++++++++
.../testProcTimeTumbleWindow.out | 363 ++++++++++++++++
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 15 +-
81 files changed, 4005 insertions(+), 462 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/AbstractPlannerWindowProperty.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerNamedWindowProperty.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerProctimeAttribute.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerRowtimeAttribute.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerWindowEnd.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerWindowProperty.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerWindowReference.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerWindowStart.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/CumulativeWindowSpec.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/HoppingWindowSpec.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/TimeAttributeWindowingStrategy.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/TumblingWindowSpec.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/WindowAttachedWindowingStrategy.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/WindowSpec.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/WindowingStrategy.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DurationJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DurationJsonSerializer.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/plannerWindowProperties.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/logical/windowingSpecs.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DurationJsonSerdeTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WindowAggregateJsonITCase.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindow.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindow.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
