This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b7cd6a9 [FLINK-14493][core] Introduce data types to ConfigOptions.
add 44c85e3 [FLINK-14490] Use ObjectIdentifier in TableOperations
add 54e69c3 [FLINK-14490][table-planner] Extract CalciteParser from
FlinkPlannerImpl
add 0fe3fe1 [FLINK-14490][table-api] Introduce UnresolvedIdentifier
add 96a62d9 [FLINK-14490][table-planner] Extract parsing logic from
Planner interface
add c0f4b7fa [FLINK-14490][table] Introduced temporary tables to
CatalogManager
add 0c24cec [FLINK-14490][table-api] Add createTemporaryView
add 8d40df4 [FLINK-14490][table-api] Add drop temporary tables
add b286330 [FLINK-14490][table-api] Add from method
add fe966d4 [FLINK-14490][table-api] Rework insertInto method
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableSinkTest.java | 6 +-
.../flink/table/catalog/hive/HiveTestUtils.java | 4 +-
.../flink/addons/hbase/HBaseConnectorITCase.java | 4 +-
flink-python/pyflink/table/table.py | 13 +-
.../table/tests/test_environment_completeness.py | 8 +-
.../table/client/gateway/local/LocalExecutor.java | 3 -
.../client/gateway/local/LocalExecutorITCase.java | 8 +-
flink-table/flink-table-api-java-bridge/pom.xml | 8 +
.../table/api/java/BatchTableEnvironment.java | 80 ++++-
.../table/api/java/StreamTableEnvironment.java | 102 ++++--
.../java/internal/StreamTableEnvironmentImpl.java | 14 +-
.../internal/StreamTableEnvironmentImplTest.java | 37 +--
.../java/org/apache/flink/table/api/Table.java | 12 +-
.../apache/flink/table/api/TableEnvironment.java | 148 ++++++++-
.../flink/table/api/internal/Registration.java | 60 ++++
.../table/api/internal/TableEnvironmentImpl.java | 232 +++++++++-----
.../apache/flink/table/api/internal/TableImpl.java | 4 +-
.../apache/flink/table/catalog/CatalogManager.java | 345 +++++++++++++++++----
.../flink/table/catalog/UnresolvedIdentifier.java | 127 ++++++++
.../org/apache/flink/table/delegation/Parser.java | 57 ++++
.../org/apache/flink/table/delegation/Planner.java | 19 +-
.../table/descriptors/BatchTableDescriptor.java | 6 +-
.../table/descriptors/ConnectTableDescriptor.java | 76 ++++-
.../table/descriptors/StreamTableDescriptor.java | 6 +-
.../table/operations/CatalogQueryOperation.java | 12 +-
.../operations/CatalogSinkModifyOperation.java | 19 +-
.../table/operations/ddl/CreateTableOperation.java | 14 +-
.../table/operations/ddl/DropTableOperation.java | 13 +-
.../flink/table/api/TableEnvironmentTest.java | 13 +-
.../utils/{ExecutorMock.java => ParserMock.java} | 17 +-
.../org/apache/flink/table/utils/PlannerMock.java | 5 +-
flink-table/flink-table-api-scala-bridge/pom.xml | 8 +
.../table/api/scala/BatchTableEnvironment.scala | 70 ++++-
.../table/api/scala/StreamTableEnvironment.scala | 85 ++++-
.../internal/StreamTableEnvironmentImpl.scala | 13 +
.../internal/StreamTableEnvironmentImplTest.scala | 26 +-
.../flink/table/planner/calcite/CalciteParser.java | 71 +++++
.../planner/catalog/CatalogCalciteSchema.java | 14 +-
.../catalog/CatalogManagerCalciteSchema.java | 10 +-
.../planner/catalog/DatabaseCalciteSchema.java | 201 +++++++-----
.../flink/table/planner/delegation/ParserImpl.java | 77 +++++
.../table/planner/delegation/PlannerContext.java | 10 +
.../operations/SqlToOperationConverter.java | 64 +++-
.../planner/plan/QueryOperationConverter.java | 2 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 39 +--
.../table/planner/delegation/PlannerBase.scala | 58 ++--
.../planner/catalog/CatalogStatisticsTest.java | 11 +-
.../table/sqlexec/SqlToOperationConverterTest.java | 31 +-
.../apache/flink/table/api/batch/ExplainTest.xml | 24 +-
.../apache/flink/table/api/stream/ExplainTest.xml | 40 +--
.../planner/plan/batch/sql/DagOptimizationTest.xml | 132 ++++----
.../table/planner/plan/batch/sql/SinkTest.xml | 12 +-
.../plan/stream/sql/DagOptimizationTest.xml | 160 +++++-----
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 12 +-
.../table/planner/plan/stream/sql/SinkTest.xml | 48 +--
.../flink/table/api/TableEnvironmentTest.scala | 6 +-
.../expressions/utils/ExpressionTestBase.scala | 3 +-
.../planner/match/PatternTranslatorTestBase.scala | 3 +-
.../table/validation/TableSinkValidationTest.scala | 2 +-
.../runtime/batch/sql/join/JoinITCase.scala | 5 +-
.../planner/runtime/stream/sql/CalcITCase.scala | 2 +-
.../runtime/stream/sql/CorrelateITCase.scala | 14 +-
.../runtime/stream/sql/Limit0RemoveITCase.scala | 16 +-
.../planner/runtime/stream/sql/RankITCase.scala | 38 +--
.../planner/runtime/stream/sql/UnnestITCase.scala | 2 +-
.../runtime/stream/sql/WindowAggregateITCase.scala | 2 +-
.../runtime/stream/table/AggregateITCase.scala | 2 +-
.../planner/runtime/stream/table/JoinITCase.scala | 12 +-
.../planner/runtime/utils/BatchTableEnvUtil.scala | 7 +-
.../table/planner/runtime/utils/TableUtil.scala | 8 +-
.../flink/table/planner/utils/TableTestBase.scala | 17 +-
.../apache/flink/table/calcite/CalciteParser.java | 71 +++++
.../flink/table/catalog/CatalogCalciteSchema.java | 13 +-
.../table/catalog/CatalogManagerCalciteSchema.java | 10 +-
.../flink/table/catalog/DatabaseCalciteSchema.java | 88 +++---
.../flink/table/plan/QueryOperationConverter.java | 2 +-
.../org/apache/flink/table/planner/ParserImpl.java | 81 +++++
.../planner/PlanningConfigurationBuilder.java | 10 +
.../table/sqlexec/SqlToOperationConverter.java | 62 +++-
.../table/api/internal/BatchTableEnvImpl.scala | 30 +-
.../flink/table/api/internal/TableEnvImpl.scala | 308 +++++++++++-------
.../java/internal/BatchTableEnvironmentImpl.scala | 13 +
.../scala/internal/BatchTableEnvironmentImpl.scala | 13 +
.../flink/table/calcite/FlinkPlannerImpl.scala | 51 +--
.../apache/flink/table/planner/StreamPlanner.scala | 55 ++--
.../flink/table/catalog/CatalogManagerTest.java | 191 +++++++++++-
.../table/catalog/CatalogStructureBuilder.java | 137 ++++++--
.../table/catalog/DatabaseCalciteSchemaTest.java | 3 +-
.../flink/table/catalog/PathResolutionTest.java | 51 ++-
.../table/sqlexec/SqlToOperationConverterTest.java | 30 +-
.../apache/flink/table/api/TableSourceTest.scala | 35 ++-
.../expressions/utils/ExpressionTestBase.scala | 7 +-
.../table/match/PatternTranslatorTestBase.scala | 3 +-
.../flink/table/utils/MockTableEnvironment.scala | 17 +
94 files changed, 2979 insertions(+), 1131 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/Registration.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/Parser.java
copy
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/utils/{ExecutorMock.java
=> ParserMock.java} (70%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/CalciteParser.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/ParserImpl.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/calcite/CalciteParser.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/ParserImpl.java
