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 d7fc0d0 [FLINK-17622][connectors/jdbc] Remove useless switch for
decimal in PostgresCatalog
new 5f0183f [FLINK-15947] Fix table implicit conversions structure
new 4e56ca1 [FLINK-15947] Update docs with updated package structure.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/dev/table/common.md | 18 +-
docs/dev/table/common.zh.md | 18 +-
docs/dev/table/tableApi.md | 7 +-
docs/dev/table/tableApi.zh.md | 7 +-
docs/getting-started/walkthroughs/table_api.md | 6 +-
docs/getting-started/walkthroughs/table_api.zh.md | 5 +-
.../cassandra/CassandraConnectorITCase.java | 2 +-
.../connector/hbase/HBaseConnectorITCase.java | 4 +-
.../flink/connectors/hive/HiveTableSinkTest.java | 2 +-
.../flink/connectors/hive/HiveTableSourceTest.java | 2 +-
.../catalog/hive/HiveCatalogUseBlinkITCase.java | 2 +-
.../flink/table/catalog/hive/HiveTestUtils.java | 2 +-
.../flink/connector/jdbc/JdbcDataTypeTest.java | 2 +-
.../jdbc/table/JdbcDynamicTableSinkITCase.java | 2 +-
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 2 +-
.../jdbc/table/JdbcLookupTableITCase.java | 2 +-
.../jdbc/table/JdbcTableSourceITCase.java | 2 +-
.../jdbc/table/JdbcUpsertTableSinkITCase.java | 2 +-
.../connectors/kafka/table/KafkaTableTestBase.java | 2 +-
.../python/tests/BlinkStreamPythonUdfSqlJob.java | 2 +-
.../python/tests/FlinkBatchPythonUdfSqlJob.java | 2 +-
.../python/tests/FlinkStreamPythonUdfSqlJob.java | 2 +-
.../flink/sql/tests/StreamSQLTestProgram.java | 2 +-
.../table/examples/java/StreamSQLExample.java | 2 +-
.../examples/java/StreamWindowSQLExample.java | 2 +-
.../flink/table/examples/java/WordCountSQL.java | 2 +-
.../flink/table/examples/java/WordCountTable.java | 2 +-
.../table/examples/scala/StreamSQLExample.scala | 4 +-
.../table/examples/scala/StreamTableExample.scala | 3 +-
.../table/examples/scala/TPCHQuery3Table.scala | 3 +-
.../flink/table/examples/scala/WordCountSQL.scala | 3 +-
.../table/examples/scala/WordCountTable.scala | 3 +-
.../flink/table/runtime/batch/AvroTypesITCase.java | 2 +-
.../org/apache/flink/orc/OrcTableSourceITCase.java | 2 +-
.../formats/parquet/ParquetTableSourceITCase.java | 2 +-
.../org/apache/flink/ml/common/MLEnvironment.java | 4 +-
.../apache/flink/ml/pipeline/EstimatorBase.java | 2 +-
.../apache/flink/ml/pipeline/TransformerBase.java | 2 +-
.../apache/flink/ml/common/MLEnvironmentTest.java | 4 +-
flink-python/pyflink/java_gateway.py | 1 +
.../client/python/PythonFunctionFactoryTest.java | 4 +-
.../scalar/PythonScalarFunctionOperatorTest.java | 2 +-
.../PythonScalarFunctionOperatorTestBase.java | 2 +-
.../RowDataPythonScalarFunctionOperatorTest.java | 2 +-
.../ArrowPythonScalarFunctionOperatorTest.java | 2 +-
...wDataArrowPythonScalarFunctionOperatorTest.java | 2 +-
.../org/apache/flink/api/scala/FlinkILoop.scala | 10 +-
.../apache/flink/api/scala/ScalaShellITCase.scala | 6 +-
.../client/gateway/local/ExecutionContext.java | 8 +-
.../client/gateway/local/ExecutionContextTest.java | 2 +-
.../{ => bridge}/java/BatchTableEnvironment.java | 4 +-
.../{ => bridge}/java/StreamTableEnvironment.java | 4 +-
.../java/internal/StreamTableEnvironmentImpl.java | 4 +-
.../operations/JavaDataStreamQueryOperation.java | 2 +-
.../internal/StreamTableEnvironmentImplTest.java | 2 +-
.../{ => bridge}/scala/BatchTableEnvironment.scala | 5 +-
.../{ => bridge}/scala/DataSetConversions.scala | 2 +-
.../{ => bridge}/scala/DataStreamConversions.scala | 2 +-
.../scala/StreamTableEnvironment.scala | 5 +-
.../api/{ => bridge}/scala/TableConversions.scala | 2 +-
.../internal/StreamTableEnvironmentImpl.scala | 9 +-
.../table/api/{ => bridge}/scala/package.scala | 13 +-
.../internal/StreamTableEnvironmentImplTest.scala | 2 +-
...l.scala => ImplicitExpressionConversions.scala} | 166 +------------------
.../table/api/ImplicitExpressionOperations.scala | 181 +++++++++++++++++++++
.../scala/org/apache/flink/table/api/package.scala | 8 +-
.../api/ExpressionsConsistencyCheckTest.scala | 2 -
.../planner/delegation/BlinkExecutorFactory.java | 2 +-
.../flink/table/planner/expressions/package.scala | 29 ----
.../planner/plan/utils/WindowEmitStrategy.scala | 34 ++--
.../apache/flink/table/api/EnvironmentTest.java | 2 +-
.../flink/table/planner/catalog/CatalogITCase.java | 2 +-
.../flink/table/api/TableEnvironmentITCase.scala | 4 +-
.../flink/table/api/TableEnvironmentTest.scala | 2 +-
.../org/apache/flink/table/api/TableITCase.scala | 2 +-
.../apache/flink/table/api/batch/ExplainTest.scala | 4 +-
.../flink/table/api/stream/ExplainTest.scala | 8 +-
.../validation/MatchRecognizeValidationTest.scala | 6 +-
.../sql/validation/OverWindowValidationTest.scala | 4 +-
.../UserDefinedFunctionValidationTest.scala | 4 +-
.../table/planner/codegen/agg/AggTestBase.scala | 2 +-
.../table/planner/expressions/ArrayTypeTest.scala | 7 +-
.../planner/expressions/CompositeAccessTest.scala | 2 +-
.../planner/expressions/DecimalTypeTest.scala | 3 +-
.../table/planner/expressions/LiteralTest.scala | 2 +-
.../table/planner/expressions/MapTypeTest.scala | 7 +-
.../expressions/NonDeterministicTests.scala | 2 +-
.../table/planner/expressions/RowTypeTest.scala | 4 +-
.../planner/expressions/ScalarFunctionsTest.scala | 4 +-
.../planner/expressions/TemporalTypesTest.scala | 5 +-
.../UserDefinedScalarFunctionTest.scala | 5 +-
.../expressions/utils/ExpressionTestBase.scala | 2 +-
.../validation/ArrayTypeValidationTest.scala | 3 +-
.../validation/CompositeAccessValidationTest.scala | 3 +-
.../validation/MapTypeValidationTest.scala | 3 +-
.../validation/RowTypeValidationTest.scala | 3 +-
.../validation/ScalarFunctionsValidationTest.scala | 3 +-
.../validation/ScalarOperatorsValidationTest.scala | 3 +-
.../planner/match/PatternTranslatorTestBase.scala | 5 +-
.../table/planner/plan/batch/sql/CalcTest.scala | 3 +-
.../plan/batch/sql/DagOptimizationTest.scala | 7 +-
.../plan/batch/sql/DeadlockBreakupTest.scala | 2 +-
.../planner/plan/batch/sql/LegacySinkTest.scala | 3 +-
.../table/planner/plan/batch/sql/LimitTest.scala | 4 +-
.../plan/batch/sql/PartitionableSinkTest.scala | 3 +-
.../table/planner/plan/batch/sql/RankTest.scala | 3 +-
.../planner/plan/batch/sql/SetOperatorsTest.scala | 3 +-
.../planner/plan/batch/sql/SortLimitTest.scala | 2 +-
.../table/planner/plan/batch/sql/SortTest.scala | 2 +-
.../planner/plan/batch/sql/SubplanReuseTest.scala | 2 +-
.../planner/plan/batch/sql/TableScanTest.scala | 4 +-
.../planner/plan/batch/sql/TableSinkTest.scala | 2 +-
.../table/planner/plan/batch/sql/UnionTest.scala | 2 +-
.../plan/batch/sql/agg/AggregateTestBase.scala | 3 +-
.../plan/batch/sql/agg/GroupingSetsTest.scala | 3 +-
.../plan/batch/sql/agg/OverAggregateTest.scala | 3 +-
.../plan/batch/sql/agg/WindowAggregateTest.scala | 3 +-
.../planner/plan/batch/sql/join/JoinTestBase.scala | 3 +-
.../plan/batch/sql/join/LookupJoinTest.scala | 2 +-
.../plan/batch/sql/join/SemiAntiJoinTestBase.scala | 3 +-
.../plan/batch/sql/join/SingleRowJoinTest.scala | 3 +-
.../plan/batch/sql/join/TemporalJoinTest.scala | 3 +-
.../planner/plan/batch/table/AggregateTest.scala | 2 +-
.../table/planner/plan/batch/table/CalcTest.scala | 2 +-
.../plan/batch/table/ColumnFunctionsTest.scala | 2 +-
.../planner/plan/batch/table/CorrelateTest.scala | 3 +-
.../planner/plan/batch/table/GroupWindowTest.scala | 3 +-
.../table/planner/plan/batch/table/JoinTest.scala | 5 +-
.../planner/plan/batch/table/PythonCalcTest.scala | 3 +-
.../plan/batch/table/SetOperatorsTest.scala | 2 +-
.../plan/batch/table/TemporalTableJoinTest.scala | 3 +-
.../stringexpr/AggregateStringExpressionTest.scala | 3 +-
.../stringexpr/CalcStringExpressionTest.scala | 3 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 3 +-
.../stringexpr/JoinStringExpressionTest.scala | 3 +-
.../batch/table/stringexpr/SetOperatorsTest.scala | 3 +-
.../stringexpr/SortStringExpressionTest.scala | 3 +-
.../table/validation/AggregateValidationTest.scala | 3 +-
.../table/validation/CalcValidationTest.scala | 3 +-
.../table/validation/CorrelateValidationTest.scala | 3 +-
.../validation/GroupWindowValidationTest.scala | 3 +-
.../table/validation/JoinValidationTest.scala | 3 +-
.../validation/OverWindowValidationTest.scala | 3 +-
.../validation/SetOperatorsValidationTest.scala | 3 +-
.../table/validation/SortValidationTest.scala | 3 +-
.../plan/common/DistinctAggregateTestBase.scala | 4 +-
.../table/planner/plan/common/UnnestTestBase.scala | 3 +-
.../planner/plan/common/ViewsExpandingTest.scala | 3 +-
.../CalcPythonCorrelateTransposeRuleTest.scala | 5 +-
.../rules/logical/CalcRankTransposeRuleTest.scala | 2 +-
.../rules/logical/ConvertToNotInOrInRuleTest.scala | 2 +-
.../logical/DecomposeGroupingSetsRuleTest.scala | 3 +-
.../logical/ExpressionReductionRulesTest.scala | 3 +-
.../FlinkAggregateJoinTransposeRuleTest.scala | 5 +-
.../logical/FlinkAggregateRemoveRuleTest.scala | 7 +-
.../rules/logical/FlinkCalcMergeRuleTest.scala | 2 +-
.../rules/logical/FlinkFilterJoinRuleTest.scala | 2 +-
.../logical/FlinkJoinPushExpressionsRuleTest.scala | 2 +-
.../logical/FlinkJoinToMultiJoinRuleTest.scala | 2 +-
.../rules/logical/FlinkLimit0RemoveRuleTest.scala | 2 +-
.../FlinkLogicalRankRuleForConstantRangeTest.scala | 2 +-
.../FlinkLogicalRankRuleForRangeEndTest.scala | 3 +-
.../rules/logical/FlinkPruneEmptyRulesTest.scala | 2 +-
.../FlinkSemiAntiJoinFilterTransposeRuleTest.scala | 2 +-
.../FlinkSemiAntiJoinJoinTransposeRuleTest.scala | 2 +-
...FlinkSemiAntiJoinProjectTransposeRuleTest.scala | 2 +-
.../JoinConditionEqualityTransferRuleTest.scala | 3 +-
.../logical/JoinConditionTypeCoerceRuleTest.scala | 2 +-
.../JoinDependentConditionDerivationRuleTest.scala | 2 +-
.../ProjectSemiAntiJoinTransposeRuleTest.scala | 2 +-
.../logical/PruneAggregateCallRuleTestBase.scala | 3 +-
.../rules/logical/PythonCalcSplitRuleTest.scala | 5 +-
.../logical/PythonCorrelateSplitRuleTest.scala | 5 +-
.../logical/RankNumberColumnRemoveRuleTest.scala | 2 +-
.../ReplaceIntersectWithSemiJoinRuleTest.scala | 2 +-
.../logical/ReplaceMinusWithAntiJoinRuleTest.scala | 2 +-
.../rules/logical/RewriteCoalesceRuleTest.scala | 3 +-
.../logical/RewriteIntersectAllRuleTest.scala | 2 +-
.../rules/logical/RewriteMinusAllRuleTest.scala | 2 +-
.../RewriteMultiJoinConditionRuleTest.scala | 4 +-
.../logical/SimplifyFilterConditionRuleTest.scala | 2 +-
.../logical/SimplifyJoinConditionRuleTest.scala | 2 +-
.../rules/logical/SplitAggregateRuleTest.scala | 2 +-
...SplitPythonConditionFromCorrelateRuleTest.scala | 5 +-
.../SplitPythonConditionFromJoinRuleTest.scala | 5 +-
.../rules/logical/WindowGroupReorderRuleTest.scala | 2 +-
.../subquery/FlinkRewriteSubQueryRuleTest.scala | 2 +-
.../logical/subquery/SubQueryAntiJoinTest.scala | 2 +-
.../logical/subquery/SubQuerySemiJoinTest.scala | 3 +-
.../SubqueryCorrelateVariablesValidationTest.scala | 3 +-
.../batch/EnforceLocalAggRuleTestBase.scala | 2 +-
.../RemoveRedundantLocalHashAggRuleTest.scala | 2 +-
.../batch/RemoveRedundantLocalRankRuleTest.scala | 2 +-
.../RemoveRedundantLocalSortAggRuleTest.scala | 2 +-
.../stream/ChangelogModeInferenceTest.scala | 3 +-
.../table/planner/plan/stream/sql/CalcTest.scala | 3 +-
.../plan/stream/sql/DagOptimizationTest.scala | 4 +-
.../planner/plan/stream/sql/DeduplicateTest.scala | 3 +-
.../planner/plan/stream/sql/LegacySinkTest.scala | 4 +-
.../table/planner/plan/stream/sql/LimitTest.scala | 3 +-
.../stream/sql/MiniBatchIntervalInferTest.scala | 6 +-
.../plan/stream/sql/ModifiedMonotonicityTest.scala | 3 +-
.../plan/stream/sql/PartitionableSinkTest.scala | 3 +-
.../table/planner/plan/stream/sql/RankTest.scala | 3 +-
.../stream/sql/RelTimeIndicatorConverterTest.scala | 2 +-
.../planner/plan/stream/sql/SetOperatorsTest.scala | 3 +-
.../planner/plan/stream/sql/SortLimitTest.scala | 3 +-
.../table/planner/plan/stream/sql/SortTest.scala | 2 +-
.../planner/plan/stream/sql/SubplanReuseTest.scala | 2 +-
.../planner/plan/stream/sql/TableScanTest.scala | 3 +-
.../planner/plan/stream/sql/TableSinkTest.scala | 4 +-
.../table/planner/plan/stream/sql/UnionTest.scala | 2 +-
.../plan/stream/sql/agg/AggregateTest.scala | 3 +-
.../stream/sql/agg/DistinctAggregateTest.scala | 3 +-
.../plan/stream/sql/agg/GroupingSetsTest.scala | 4 +-
.../plan/stream/sql/agg/OverAggregateTest.scala | 3 +-
.../stream/sql/agg/TwoStageAggregateTest.scala | 2 +-
.../plan/stream/sql/agg/WindowAggregateTest.scala | 4 +-
.../planner/plan/stream/sql/join/JoinTest.scala | 3 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 2 +-
.../plan/stream/sql/join/SemiAntiJoinTest.scala | 2 +-
.../plan/stream/sql/join/TemporalJoinTest.scala | 3 +-
.../plan/stream/sql/join/WindowJoinTest.scala | 3 +-
.../planner/plan/stream/table/AggregateTest.scala | 3 +-
.../table/planner/plan/stream/table/CalcTest.scala | 3 +-
.../plan/stream/table/ColumnFunctionsTest.scala | 3 +-
.../planner/plan/stream/table/CorrelateTest.scala | 5 +-
.../table/GroupWindowTableAggregateTest.scala | 4 +-
.../plan/stream/table/GroupWindowTest.scala | 8 +-
.../table/planner/plan/stream/table/JoinTest.scala | 2 +-
.../plan/stream/table/LegacyTableSourceTest.scala | 5 +-
.../planner/plan/stream/table/OverWindowTest.scala | 3 +-
.../planner/plan/stream/table/PythonCalcTest.scala | 3 +-
.../plan/stream/table/SetOperatorsTest.scala | 2 +-
.../plan/stream/table/TableAggregateTest.scala | 3 +-
.../plan/stream/table/TableSourceTest.scala | 3 +-
.../plan/stream/table/TemporalTableJoinTest.scala | 3 +-
.../plan/stream/table/TwoStageAggregateTest.scala | 3 +-
.../stringexpr/AggregateStringExpressionTest.scala | 3 +-
.../stringexpr/CalcStringExpressionTest.scala | 2 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 2 +-
.../GroupWindowStringExpressionTest.scala | 3 +-
...pWindowTableAggregateStringExpressionTest.scala | 4 +-
.../OverWindowStringExpressionTest.scala | 3 +-
.../SetOperatorsStringExpressionTest.scala | 3 +-
.../TableAggregateStringExpressionTest.scala | 3 +-
.../table/validation/AggregateValidationTest.scala | 3 +-
.../table/validation/CalcValidationTest.scala | 3 +-
.../table/validation/CorrelateValidationTest.scala | 2 +-
.../GroupWindowTableAggregateValidationTest.scala | 4 +-
.../validation/GroupWindowValidationTest.scala | 3 +-
.../validation/LegacyTableSinkValidationTest.scala | 5 +-
.../validation/OverWindowValidationTest.scala | 3 +-
.../validation/SetOperatorsValidationTest.scala | 5 +-
.../validation/TableAggregateValidationTest.scala | 3 +-
.../TemporalTableJoinValidationTest.scala | 3 +-
.../validation/UnsupportedOpsValidationTest.scala | 5 +-
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 4 +-
.../runtime/batch/table/AggregationITCase.scala | 3 +-
.../planner/runtime/batch/table/CalcITCase.scala | 2 +-
.../runtime/batch/table/CorrelateITCase.scala | 3 +-
.../runtime/batch/table/DecimalITCase.scala | 3 +-
.../runtime/batch/table/GroupWindowITCase.scala | 3 +-
.../planner/runtime/batch/table/JoinITCase.scala | 2 +-
.../batch/table/LegacyTableSinkITCase.scala | 8 +-
.../runtime/batch/table/OverWindowITCase.scala | 3 +-
.../runtime/batch/table/SetOperatorsITCase.scala | 2 +-
.../planner/runtime/batch/table/SortITCase.scala | 3 +-
.../runtime/batch/table/TableSinkITCase.scala | 3 +-
.../harness/GroupAggregateHarnessTest.scala | 5 +-
.../runtime/harness/OverWindowHarnessTest.scala | 7 +-
.../harness/TableAggregateHarnessTest.scala | 5 +-
.../runtime/stream/sql/AggregateITCase.scala | 9 +-
.../runtime/stream/sql/AggregateRemoveITCase.scala | 3 +-
.../runtime/stream/sql/AsyncLookupJoinITCase.scala | 2 +-
.../planner/runtime/stream/sql/CalcITCase.scala | 4 +-
.../runtime/stream/sql/CorrelateITCase.scala | 9 +-
.../runtime/stream/sql/DeduplicateITCase.scala | 3 +-
.../planner/runtime/stream/sql/JoinITCase.scala | 3 +-
.../stream/sql/LegacyTableSourceITCase.scala | 2 +-
.../runtime/stream/sql/Limit0RemoveITCase.scala | 4 +-
.../planner/runtime/stream/sql/LimitITCase.scala | 4 +-
.../runtime/stream/sql/LookupJoinITCase.scala | 5 +-
.../runtime/stream/sql/MatchRecognizeITCase.scala | 5 +-
.../runtime/stream/sql/OverWindowITCase.scala | 3 +-
.../stream/sql/PruneAggregateCallITCase.scala | 2 +-
.../planner/runtime/stream/sql/RankITCase.scala | 8 +-
.../stream/sql/SemiAntiJoinStreamITCase.scala | 3 +-
.../runtime/stream/sql/SetOperatorsITCase.scala | 3 +-
.../planner/runtime/stream/sql/SortITCase.scala | 4 +-
.../runtime/stream/sql/SortLimitITCase.scala | 3 +-
.../runtime/stream/sql/SplitAggregateITCase.scala | 4 +-
.../stream/sql/StreamFileSystemITCaseBase.scala | 2 +-
.../stream/sql/StreamTableEnvironmentITCase.scala | 5 +-
.../runtime/stream/sql/TableScanITCase.scala | 11 +-
.../runtime/stream/sql/TableSourceITCase.scala | 2 +-
.../runtime/stream/sql/TemporalJoinITCase.scala | 4 +-
.../runtime/stream/sql/TemporalSortITCase.scala | 3 +-
.../runtime/stream/sql/TimeAttributeITCase.scala | 5 +-
.../runtime/stream/sql/TimestampITCase.scala | 5 +-
.../planner/runtime/stream/sql/UnnestITCase.scala | 7 +-
.../planner/runtime/stream/sql/ValuesITCase.scala | 3 +-
.../runtime/stream/sql/WindowAggregateITCase.scala | 10 +-
.../runtime/stream/sql/WindowJoinITCase.scala | 3 +-
.../runtime/stream/table/AggregateITCase.scala | 5 +-
.../planner/runtime/stream/table/CalcITCase.scala | 5 +-
.../runtime/stream/table/CorrelateITCase.scala | 6 +-
.../runtime/stream/table/GroupWindowITCase.scala | 4 +-
.../table/GroupWindowTableAggregateITCase.scala | 11 +-
.../planner/runtime/stream/table/JoinITCase.scala | 7 +-
.../stream/table/LegacyTableSinkITCase.scala | 9 +-
.../stream/table/MiniBatchGroupWindowITCase.scala | 4 +-
.../runtime/stream/table/OverWindowITCase.scala | 4 +-
.../runtime/stream/table/RetractionITCase.scala | 3 +-
.../runtime/stream/table/SetOperatorsITCase.scala | 3 +-
.../runtime/stream/table/SubQueryITCase.scala | 3 +-
.../stream/table/TableAggregateITCase.scala | 5 +-
.../runtime/stream/table/TableSinkITCase.scala | 5 +-
.../planner/runtime/utils/StreamTableEnvUtil.scala | 2 +-
.../planner/runtime/utils/StreamingTestBase.scala | 5 +-
.../runtime/utils/StreamingWithStateTestBase.scala | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 8 +-
.../table/api/{ => bridge}/java/package-info.java | 12 +-
.../table/executor/StreamExecutorFactory.java | 2 +-
.../java/internal/BatchTableEnvironmentImpl.scala | 6 +-
.../scala/internal/BatchTableEnvironmentImpl.scala | 6 +-
.../expressions/PlannerExpressionParserImpl.scala | 4 +-
.../apache/flink/table/expressions/package.scala | 4 +-
.../table/util/DummyExecutionEnvironment.java | 2 +-
.../table/api/StreamTableEnvironmentTest.java | 2 +-
.../flink/table/catalog/PathResolutionTest.java | 2 +-
.../flink/table/catalog/ViewExpansionTest.java | 2 +-
.../table/runtime/batch/JavaTableSourceITCase.java | 2 +-
.../runtime/batch/sql/GroupingSetsITCase.java | 2 +-
.../table/runtime/batch/sql/JavaSqlITCase.java | 2 +-
.../batch/table/JavaTableEnvironmentITCase.java | 2 +-
.../table/runtime/stream/sql/FunctionITCase.java | 2 +-
.../table/runtime/stream/sql/JavaSqlITCase.java | 2 +-
.../table/runtime/stream/table/FunctionITCase.java | 2 +-
.../table/runtime/stream/table/ValuesITCase.java | 2 +-
.../flink/table/api/TableEnvironmentITCase.scala | 14 +-
.../flink/table/api/TableEnvironmentTest.scala | 11 +-
.../org/apache/flink/table/api/TableITCase.scala | 7 +-
.../apache/flink/table/api/TableSourceTest.scala | 11 +-
.../api/batch/BatchTableEnvironmentTest.scala | 5 +-
.../apache/flink/table/api/batch/ExplainTest.scala | 7 +-
.../flink/table/api/batch/sql/AggregateTest.scala | 3 +-
.../flink/table/api/batch/sql/CalcTest.scala | 5 +-
.../flink/table/api/batch/sql/CorrelateTest.scala | 5 +-
.../api/batch/sql/DistinctAggregateTest.scala | 3 +-
.../table/api/batch/sql/GroupWindowTest.scala | 7 +-
.../table/api/batch/sql/GroupingSetsTest.scala | 3 +-
.../flink/table/api/batch/sql/JoinTest.scala | 3 +-
.../table/api/batch/sql/SetOperatorsTest.scala | 3 +-
.../table/api/batch/sql/SingleRowJoinTest.scala | 5 +-
.../api/batch/sql/TemporalTableJoinTest.scala | 9 +-
.../batch/sql/validation/CalcValidationTest.scala | 4 +-
.../sql/validation/CorrelateValidationTest.scala | 4 +-
.../sql/validation/GroupWindowValidationTest.scala | 8 +-
.../sql/validation/InsertIntoValidationTest.scala | 4 +-
.../batch/sql/validation/JoinValidationTest.scala | 5 +-
.../sql/validation/OverWindowValidationTest.scala | 8 +-
.../batch/sql/validation/SortValidationTest.scala | 5 +-
.../table/api/batch/table/AggregateTest.scala | 5 +-
.../flink/table/api/batch/table/CalcTest.scala | 3 +-
.../api/batch/table/ColumnFunctionsTest.scala | 4 +-
.../table/api/batch/table/CorrelateTest.scala | 8 +-
.../table/api/batch/table/GroupWindowTest.scala | 8 +-
.../flink/table/api/batch/table/JoinTest.scala | 3 +-
.../table/api/batch/table/SetOperatorsTest.scala | 3 +-
.../api/batch/table/TemporalTableJoinTest.scala | 8 +-
.../stringexpr/AggregateStringExpressionTest.scala | 5 +-
.../stringexpr/CalcStringExpressionTest.scala | 8 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 3 +-
.../stringexpr/JoinStringExpressionTest.scala | 4 +-
.../batch/table/stringexpr/SetOperatorsTest.scala | 7 +-
.../stringexpr/SortStringExpressionTest.scala | 3 +-
.../table/validation/AggregateValidationTest.scala | 4 +-
.../table/validation/CalcValidationTest.scala | 5 +-
.../table/validation/CorrelateValidationTest.scala | 4 +-
.../validation/GroupWindowValidationTest.scala | 4 +-
.../validation/InsertIntoValidationTest.scala | 4 +-
.../table/validation/JoinValidationTest.scala | 5 +-
.../validation/OverWindowValidationTest.scala | 4 +-
.../validation/SetOperatorsValidationTest.scala | 5 +-
.../table/validation/SortValidationTest.scala | 4 +-
.../flink/table/api/stream/ExplainTest.scala | 5 +-
.../api/stream/StreamTableEnvironmentTest.scala | 10 +-
.../StreamTableEnvironmentValidationTest.scala | 7 +-
.../flink/table/api/stream/sql/AggregateTest.scala | 7 +-
.../flink/table/api/stream/sql/CorrelateTest.scala | 6 +-
.../api/stream/sql/DistinctAggregateTest.scala | 3 +-
.../table/api/stream/sql/GroupWindowTest.scala | 3 +-
.../flink/table/api/stream/sql/JoinTest.scala | 8 +-
.../table/api/stream/sql/MatchRecognizeTest.scala | 3 +-
.../table/api/stream/sql/OverWindowTest.scala | 3 +-
.../table/api/stream/sql/SetOperatorsTest.scala | 3 +-
.../flink/table/api/stream/sql/SortTest.scala | 3 +-
.../api/stream/sql/TemporalTableJoinTest.scala | 8 +-
.../flink/table/api/stream/sql/UnionTest.scala | 5 +-
.../sql/validation/CorrelateValidationTest.scala | 4 +-
.../sql/validation/InsertIntoValidationTest.scala | 2 +-
.../stream/sql/validation/JoinValidationTest.scala | 4 +-
.../validation/MatchRecognizeValidationTest.scala | 4 +-
.../sql/validation/OverWindowValidationTest.scala | 5 +-
.../stream/sql/validation/SortValidationTest.scala | 4 +-
.../validation/WindowAggregateValidationTest.scala | 4 +-
.../table/api/stream/table/AggregateTest.scala | 6 +-
.../flink/table/api/stream/table/CalcTest.scala | 3 +-
.../api/stream/table/ColumnFunctionsTest.scala | 3 +-
.../table/api/stream/table/CorrelateTest.scala | 8 +-
.../table/GroupWindowTableAggregateTest.scala | 6 +-
.../table/api/stream/table/GroupWindowTest.scala | 4 +-
.../flink/table/api/stream/table/JoinTest.scala | 3 +-
.../table/api/stream/table/OverWindowTest.scala | 6 +-
.../table/api/stream/table/SetOperatorsTest.scala | 3 +-
.../api/stream/table/TableAggregateTest.scala | 5 +-
.../table/api/stream/table/TableSourceTest.scala | 4 +-
.../api/stream/table/TemporalTableJoinTest.scala | 3 +-
.../stringexpr/AggregateStringExpressionTest.scala | 4 +-
.../stringexpr/CalcStringExpressionTest.scala | 3 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 2 +-
.../GroupWindowStringExpressionTest.scala | 6 +-
...pWindowTableAggregateStringExpressionTest.scala | 4 +-
.../OverWindowStringExpressionTest.scala | 7 +-
.../SetOperatorsStringExpressionTest.scala | 3 +-
.../TableAggregateStringExpressionTest.scala | 3 +-
.../table/validation/AggregateValidationTest.scala | 4 +-
.../table/validation/CalcValidationTest.scala | 8 +-
.../table/validation/CorrelateValidationTest.scala | 2 +-
.../GroupWindowTableAggregateValidationTest.scala | 4 +-
.../validation/GroupWindowValidationTest.scala | 4 +-
.../validation/InsertIntoValidationTest.scala | 5 +-
.../table/validation/JoinValidationTest.scala | 4 +-
.../validation/OverWindowValidationTest.scala | 4 +-
.../validation/SetOperatorsValidationTest.scala | 4 +-
.../validation/TableAggregateValidationTest.scala | 8 +-
.../table/validation/TableSinkValidationTest.scala | 5 +-
.../validation/TableSourceValidationTest.scala | 4 +-
.../TemporalTableJoinValidationTest.scala | 8 +-
.../validation/UnsupportedOpsValidationTest.scala | 4 +-
.../validation/ColumnFunctionsValidationTest.scala | 4 +-
.../api/validation/InlineTableValidationTest.scala | 4 +-
.../TableEnvironmentValidationTest.scala | 4 +-
.../api/validation/TableSinksValidationTest.scala | 4 +-
.../api/validation/TableSourceValidationTest.scala | 7 +-
.../UserDefinedFunctionValidationTest.scala | 4 +-
.../flink/table/catalog/CatalogTableITCase.scala | 2 +-
.../flink/table/expressions/ArrayTypeTest.scala | 8 +-
.../table/expressions/CompositeAccessTest.scala | 3 +-
.../table/expressions/DateTimeFunctionTest.scala | 7 +-
.../flink/table/expressions/DecimalTypeTest.scala | 6 +-
.../flink/table/expressions/LiteralTest.scala | 4 +-
.../flink/table/expressions/MapTypeTest.scala | 8 +-
.../table/expressions/NonDeterministicTests.scala | 5 +-
.../flink/table/expressions/RowTypeTest.scala | 8 +-
.../table/expressions/ScalarFunctionsTest.scala | 4 +-
.../table/expressions/ScalarOperatorsTest.scala | 4 +-
.../table/expressions/TemporalTypesTest.scala | 10 +-
.../UserDefinedScalarFunctionTest.scala | 14 +-
.../expressions/utils/ExpressionTestBase.scala | 4 +-
.../validation/ArrayTypeValidationTest.scala | 4 +-
.../validation/CompositeAccessValidationTest.scala | 4 +-
.../validation/MapTypeValidationTest.scala | 4 +-
.../validation/RowTypeValidationTest.scala | 4 +-
.../validation/ScalarFunctionsValidationTest.scala | 6 +-
.../validation/ScalarOperatorsValidationTest.scala | 4 +-
.../table/match/MatchRecognizeValidationTest.scala | 3 +-
.../table/match/PatternTranslatorTestBase.scala | 6 +-
.../CalcPythonCorrelateTransposeRuleTest.scala | 3 +-
.../table/plan/ExpressionReductionRulesTest.scala | 5 +-
.../flink/table/plan/NormalizationRulesTest.scala | 8 +-
.../flink/table/plan/PythonCalcSplitRuleTest.scala | 5 +-
.../table/plan/PythonCorrelateSplitRuleTest.scala | 3 +-
.../flink/table/plan/QueryDecorrelationTest.scala | 3 +-
.../flink/table/plan/RetractionRulesTest.scala | 6 +-
...SplitPythonConditionFromCorrelateRuleTest.scala | 3 +-
.../SplitPythonConditionFromJoinRuleTest.scala | 3 +-
.../table/plan/TimeIndicatorConversionTest.scala | 8 +-
.../flink/table/plan/UpdatingPlanCheckerTest.scala | 4 +-
.../table/runtime/batch/sql/AggregateITCase.scala | 5 +-
.../flink/table/runtime/batch/sql/CalcITCase.scala | 13 +-
.../flink/table/runtime/batch/sql/JoinITCase.scala | 9 +-
.../batch/sql/PartitionableSinkITCase.scala | 2 +-
.../runtime/batch/sql/SetOperatorsITCase.scala | 4 +-
.../flink/table/runtime/batch/sql/SortITCase.scala | 5 +-
.../runtime/batch/sql/TableEnvironmentITCase.scala | 10 +-
.../runtime/batch/sql/TableSourceITCase.scala | 5 +-
.../runtime/batch/table/AggregateITCase.scala | 11 +-
.../table/runtime/batch/table/CalcITCase.scala | 12 +-
.../runtime/batch/table/CorrelateITCase.scala | 9 +-
.../runtime/batch/table/GroupWindowITCase.scala | 9 +-
.../table/runtime/batch/table/JoinITCase.scala | 13 +-
.../runtime/batch/table/SetOperatorsITCase.scala | 4 +-
.../table/runtime/batch/table/SortITCase.scala | 6 +-
.../batch/table/TableEnvironmentITCase.scala | 8 +-
.../table/runtime/batch/table/TableITCase.scala | 4 +-
.../runtime/batch/table/TableSinkITCase.scala | 11 +-
.../runtime/batch/table/TableSourceITCase.scala | 13 +-
.../runtime/harness/AggFunctionHarnessTest.scala | 9 +-
.../harness/GroupAggregateHarnessTest.scala | 6 +-
.../table/runtime/harness/MatchHarnessTest.scala | 9 +-
.../harness/TableAggregateHarnessTest.scala | 6 +-
.../runtime/stream/TimeAttributesITCase.scala | 9 +-
.../runtime/stream/sql/InsertIntoITCase.scala | 5 +-
.../table/runtime/stream/sql/JoinITCase.scala | 7 +-
.../runtime/stream/sql/MatchRecognizeITCase.scala | 9 +-
.../runtime/stream/sql/OverWindowITCase.scala | 4 +-
.../runtime/stream/sql/SetOperatorsITCase.scala | 4 +-
.../table/runtime/stream/sql/SortITCase.scala | 7 +-
.../flink/table/runtime/stream/sql/SqlITCase.scala | 5 +-
.../runtime/stream/sql/TableSourceITCase.scala | 3 +-
.../runtime/stream/sql/TemporalJoinITCase.scala | 7 +-
.../runtime/stream/table/AggregateITCase.scala | 5 +-
.../table/runtime/stream/table/CalcITCase.scala | 4 +-
.../runtime/stream/table/CorrelateITCase.scala | 7 +-
.../runtime/stream/table/GroupWindowITCase.scala | 4 +-
.../table/GroupWindowTableAggregateITCase.scala | 6 +-
.../table/runtime/stream/table/JoinITCase.scala | 5 +-
.../runtime/stream/table/OverWindowITCase.scala | 8 +-
.../runtime/stream/table/RetractionITCase.scala | 4 +-
.../runtime/stream/table/SetOperatorsITCase.scala | 4 +-
.../stream/table/TableAggregateITCase.scala | 6 +-
.../runtime/stream/table/TableSinkITCase.scala | 9 +-
.../runtime/stream/table/TableSourceITCase.scala | 12 +-
.../apache/flink/table/utils/TableTestBase.scala | 8 +-
.../src/main/java/SpendReport.java | 2 +-
.../src/main/scala/SpendReport.scala | 1 -
528 files changed, 1338 insertions(+), 1280 deletions(-)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/{
=> bridge}/java/BatchTableEnvironment.java (99%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/{
=> bridge}/java/StreamTableEnvironment.java (99%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/{
=> bridge}/java/internal/StreamTableEnvironmentImpl.java (99%)
rename
flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/api/{
=> bridge}/java/internal/StreamTableEnvironmentImplTest.java (98%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/BatchTableEnvironment.scala (98%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/DataSetConversions.scala (97%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/DataStreamConversions.scala (98%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/StreamTableEnvironment.scala (99%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/TableConversions.scala (98%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/internal/StreamTableEnvironmentImpl.scala (97%)
rename
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/{
=> bridge}/scala/package.scala (86%)
rename
flink-table/flink-table-api-scala-bridge/src/test/scala/org/apache/flink/table/api/{
=> bridge}/scala/internal/StreamTableEnvironmentImplTest.scala (98%)
rename
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/{expressionDsl.scala
=> ImplicitExpressionConversions.scala} (84%)
create mode 100644
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionOperations.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/package.scala
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/api/{ =>
bridge}/java/package-info.java (77%)
rename
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/{ =>
bridge}/java/internal/BatchTableEnvironmentImpl.scala (96%)
rename
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/{ =>
bridge}/scala/internal/BatchTableEnvironmentImpl.scala (94%)
