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 ad0bcd7 [FLINK-9683][history] HistoryServer uses configured default
fs scheme
add e16e45f [FLINK-21092][table-planner-blink] Introduce getJsonPlan,
explainJsonPlan and executeJsonPlan in TableEnvironmentInternal
add c37905e [FLINK-21093][table-planner-blink] Support
StreamExecTableSource json serialization/deserialization
add cae2388 [FLINK-21094][table-planner-blink] Support StreamExecSink
json serialization/deserialization
add 0150ae4 [FLINK-21096][table-planner-blink] Introduce
ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and
deserialize json plan to ExecNodeGraph
add 99c1b2f [FLINK-21092][table-planner-blink] Move the spec classes in
`exec.utils` to `exec.spec` package
No new revisions were added by this update.
Summary of changes:
.../flink/table/api/internal/StatementSetImpl.java | 24 +-
.../table/api/internal/TableEnvironmentImpl.java | 47 ++-
.../api/internal/TableEnvironmentInternal.java | 65 ++++
.../org/apache/flink/table/delegation/Planner.java | 51 +++
.../org/apache/flink/table/utils/PlannerMock.java | 15 +
.../apache/flink/table/factories/FactoryUtil.java | 2 +-
flink-table/flink-table-planner-blink/pom.xml | 6 +
.../table/planner/plan/nodes/exec/ExecEdge.java | 20 +-
.../table/planner/plan/nodes/exec/ExecNode.java | 25 ++
.../planner/plan/nodes/exec/ExecNodeBase.java | 48 ++-
.../planner/plan/nodes/exec/ExecNodeGraph.java | 38 ++-
.../planner/plan/nodes/exec/InputProperty.java | 147 +++++++--
.../plan/nodes/exec/batch/BatchExecHashJoin.java | 2 +-
.../nodes/exec/batch/BatchExecOverAggregate.java | 6 +-
.../exec/batch/BatchExecOverAggregateBase.java | 4 +-
.../exec/batch/BatchExecPythonOverAggregate.java | 6 +-
.../plan/nodes/exec/batch/BatchExecSink.java | 17 +-
.../plan/nodes/exec/batch/BatchExecSort.java | 2 +-
.../plan/nodes/exec/batch/BatchExecSortLimit.java | 2 +-
.../nodes/exec/batch/BatchExecSortMergeJoin.java | 2 +-
.../nodes/exec/batch/BatchExecTableSourceScan.java | 5 +-
.../plan/nodes/exec/common/CommonExecSink.java | 45 +--
.../exec/common/CommonExecTableSourceScan.java | 24 +-
.../exec/serde/CatalogTableJsonDeserializer.java | 48 +++
.../exec/serde/CatalogTableJsonSerializer.java | 55 ++++
.../exec/serde/ChangelogModeJsonDeserializer.java | 55 ++++
.../exec/serde/ChangelogModeJsonSerializer.java | 53 ++++
.../DynamicTableSinkSpecJsonDeserializer.java | 53 ++++
.../DynamicTableSourceSpecJsonDeserializer.java | 55 ++++
.../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 350 +++++++++++++++++++++
.../exec/serde/FlinkDeserializationContext.java | 67 ++++
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 60 ++++
.../exec/serde/LogicalTypeJsonDeserializer.java | 209 ++++++++++++
.../exec/serde/LogicalTypeJsonSerializer.java | 172 ++++++++++
.../serde/ObjectIdentifierJsonDeserializer.java | 56 ++++
.../exec/serde/ObjectIdentifierJsonSerializer.java | 54 ++++
.../RequiredDistributionJsonDeserializer.java | 71 +++++
.../serde/RequiredDistributionJsonSerializer.java | 69 ++++
.../SerdeContext.java} | 26 +-
.../nodes/exec/serde/ShuffleJsonDeserializer.java | 69 ++++
.../nodes/exec/serde/ShuffleJsonSerializer.java | 66 ++++
.../plan/nodes/exec/spec/CatalogTableSpecBase.java | 106 +++++++
.../plan/nodes/exec/spec/DynamicTableSinkSpec.java | 65 ++++
.../nodes/exec/spec/DynamicTableSourceSpec.java | 98 ++++++
.../exec/{utils => spec}/IntervalJoinSpec.java | 2 +-
.../plan/nodes/exec/{utils => spec}/JoinSpec.java | 2 +-
.../plan/nodes/exec/{utils => spec}/MatchSpec.java | 2 +-
.../plan/nodes/exec/{utils => spec}/OverSpec.java | 2 +-
.../nodes/exec/{utils => spec}/PartitionSpec.java | 2 +-
.../plan/nodes/exec/{utils => spec}/SortSpec.java | 2 +-
.../nodes/exec/stream/StreamExecIntervalJoin.java | 4 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 2 +-
.../plan/nodes/exec/stream/StreamExecLimit.java | 4 +-
.../plan/nodes/exec/stream/StreamExecMatch.java | 4 +-
.../nodes/exec/stream/StreamExecOverAggregate.java | 2 +-
.../exec/stream/StreamExecPythonOverAggregate.java | 2 +-
.../plan/nodes/exec/stream/StreamExecRank.java | 4 +-
.../plan/nodes/exec/stream/StreamExecSink.java | 54 +++-
.../plan/nodes/exec/stream/StreamExecSort.java | 2 +-
.../nodes/exec/stream/StreamExecSortLimit.java | 4 +-
.../exec/stream/StreamExecTableSourceScan.java | 19 +-
.../nodes/exec/stream/StreamExecTemporalJoin.java | 2 +-
.../nodes/exec/stream/StreamExecTemporalSort.java | 2 +-
.../table/planner/plan/utils/ReflectionsUtil.java | 56 ++++
.../table/planner/codegen/GenerateUtils.scala | 2 +-
...ltiFieldRangeBoundComparatorCodeGenerator.scala | 2 +-
.../over/RangeBoundComparatorCodeGenerator.scala | 2 +-
.../codegen/sort/ComparatorCodeGenerator.scala | 2 +-
.../planner/codegen/sort/SortCodeGenerator.scala | 2 +-
.../table/planner/delegation/BatchPlanner.scala | 3 +
.../table/planner/delegation/PlannerBase.scala | 34 +-
.../table/planner/delegation/StreamPlanner.scala | 20 ++
.../batch/BatchPhysicalOverAggregate.scala | 4 +-
.../batch/BatchPhysicalPythonOverAggregate.scala | 4 +-
.../nodes/physical/batch/BatchPhysicalSink.scala | 13 +-
.../batch/BatchPhysicalTableSourceScan.scala | 11 +-
.../nodes/physical/common/CommonPhysicalJoin.scala | 2 +-
.../stream/StreamPhysicalIntervalJoin.scala | 6 +-
.../nodes/physical/stream/StreamPhysicalRank.scala | 7 +-
.../nodes/physical/stream/StreamPhysicalSink.scala | 14 +-
.../stream/StreamPhysicalTableSourceScan.scala | 12 +-
.../stream/StreamPhysicalTemporalJoin.scala | 4 +-
.../stream/StreamPhysicalJoinRuleBase.scala | 2 +-
.../planner/plan/utils/IntervalJoinUtil.scala | 2 +-
.../flink/table/planner/plan/utils/JoinUtil.scala | 2 +-
.../flink/table/planner/plan/utils/MatchUtil.scala | 2 +-
.../planner/plan/utils/OverAggregateUtil.scala | 4 +-
.../flink/table/planner/plan/utils/SortUtil.scala | 2 +-
.../planner/plan/utils/TemporalJoinUtil.scala | 2 +-
.../table/api/internal/StatementSetImplTest.java | 76 +++++
.../api/internal/TableEnvironmentInternalTest.java | 291 +++++++++++++++++
.../planner/codegen/SortCodeGeneratorTest.java | 2 +-
.../plan/nodes/exec/TestingBatchExecNode.java | 5 +
.../exec/serde/ChangelogModeJsonSerdeTest.java | 62 ++++
.../exec/serde/DynamicTableSinkSpecSerdeTest.java | 88 ++++++
.../serde/DynamicTableSourceSpecSerdeTest.java | 87 +++++
.../nodes/exec/serde/InputPropertySerdeTest.java | 84 +++++
.../exec/serde/LogicalTypeSerdeCoverageTest.java | 60 ++++
.../nodes/exec/serde/LogicalTypeSerdeTest.java | 218 +++++++++++++
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 124 ++++++++
.../planner/plan/utils/ReflectionsUtilTest.java | 87 +++++
.../test/resources/explain/testExplainJsonPlan.out | 25 ++
.../test/resources/jsonplan/testGetJsonPlan.out | 74 +++++
.../metadata/MetadataHandlerConsistencyTest.scala | 10 +-
.../flink/table/planner/utils/TableTestBase.scala | 31 +-
.../flink/table/api/internal/TableEnvImpl.scala | 21 +-
.../apache/flink/table/planner/StreamPlanner.scala | 15 +
pom.xml | 1 +
108 files changed, 3968 insertions(+), 186 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/CatalogTableJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/CatalogTableJsonSerializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ChangelogModeJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ChangelogModeJsonSerializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DynamicTableSinkSpecJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DynamicTableSourceSpecJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ExecNodeGraphJsonPlanGenerator.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/FlinkDeserializationContext.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonSerdeUtil.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeJsonSerializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ObjectIdentifierJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ObjectIdentifierJsonSerializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RequiredDistributionJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RequiredDistributionJsonSerializer.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{ExecNodeGraph.java
=> serde/SerdeContext.java} (55%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ShuffleJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ShuffleJsonSerializer.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/CatalogTableSpecBase.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/DynamicTableSinkSpec.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/DynamicTableSourceSpec.java
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{utils
=> spec}/IntervalJoinSpec.java (97%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{utils
=> spec}/JoinSpec.java (97%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{utils
=> spec}/MatchSpec.java (98%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{utils
=> spec}/OverSpec.java (99%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{utils
=> spec}/PartitionSpec.java (96%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{utils
=> spec}/SortSpec.java (99%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/ReflectionsUtil.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/internal/StatementSetImplTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/api/internal/TableEnvironmentInternalTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ChangelogModeJsonSerdeTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DynamicTableSinkSpecSerdeTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DynamicTableSourceSpecSerdeTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/InputPropertySerdeTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeSerdeCoverageTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeSerdeTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/JsonSerdeCoverageTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/utils/ReflectionsUtilTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/explain/testExplainJsonPlan.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/jsonplan/testGetJsonPlan.out
