This is an automated email from the ASF dual-hosted git repository.
lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 9d21878befa [FLINK-36287] Disallow UC for inner sink channels
add 363d8bdfa99 [FLINK-36369][table] Move deprecated user-visible classes
in table-common to the legacy package
add 2836d250262 [FLINK-36369][table] Move deprecated user-visible classes
in table-api-java to the legacy package
add 10037e39b5c [FLINK-36369][table] Move deprecated user-visible classes
in table-api-java-bridge to the legacy package
add 84eab0405a0 [FLINK-36166][table-planner] Temporarily ignore
testJoinDisorderChangeLog
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/dev/table/functions/udfs.md | 6 ++--
docs/content.zh/docs/dev/table/sourcesSinks.md | 2 +-
docs/content.zh/docs/dev/table/tableApi.md | 2 +-
docs/content/docs/dev/table/sourcesSinks.md | 2 +-
docs/content/docs/dev/table/tableApi.md | 2 +-
.../file/table/FileSystemTableFactory.java | 2 +-
flink-connectors/flink-connector-hive/pom.xml | 4 +--
.../connectors/hive/HiveLookupTableSource.java | 2 +-
.../flink/connectors/hive/HiveTableFactory.java | 8 ++---
.../flink/table/catalog/hive/HiveCatalog.java | 4 +--
.../hive/client/HiveMetastoreClientWrapper.java | 2 +-
.../flink/table/catalog/hive/client/HiveShim.java | 2 +-
.../table/catalog/hive/client/HiveShimV100.java | 2 +-
.../table/catalog/hive/client/HiveShimV210.java | 2 +-
.../table/catalog/hive/client/HiveShimV310.java | 2 +-
.../table/catalog/hive/util/HiveTableUtil.java | 2 +-
.../hive/parse/HiveParserDDLSemanticAnalyzer.java | 2 +-
.../connectors/hive/HiveTableFactoryTest.java | 10 +++---
.../TestScanTableSourceWithWatermarkPushDown.java | 2 +-
.../flink/sql/tests/StreamSQLTestProgram.java | 12 +++----
.../avro/typeutils/AvroSchemaConverter.java | 2 +-
.../avro/typeutils/AvroSchemaConverterTest.java | 2 +-
.../protobuf/table/TestProtobufTableSource.java | 2 +-
flink-python/pyflink/java_gateway.py | 6 ++++
flink-python/pyflink/table/descriptors.py | 2 +-
flink-python/pyflink/table/table_result.py | 2 +-
.../pyflink/table/tests/test_descriptor.py | 8 ++---
.../runtime/arrow/sources/ArrowTableSource.java | 4 +--
.../chain/PythonOperatorChainingOptimizerTest.java | 2 +-
.../table/utils/TestCollectionTableFactory.java | 2 +-
.../flink/table/utils/TestingDescriptors.java | 2 +-
.../AbstractStreamTableEnvironmentImpl.java | 2 +-
.../table/operations/DataStreamQueryOperation.java | 2 +-
.../datagen/table/DataGenTableSource.java | 4 +--
.../connector/source/SourceFunctionProvider.java | 3 +-
.../table/descriptors/RowtimeValidator.java | 41 ++++++++++++----------
.../table/descriptors/SchemaValidator.java | 33 +++++++++--------
.../table/factories/StreamTableSinkFactory.java | 8 +++--
.../table/factories/StreamTableSourceFactory.java | 8 +++--
.../table/sinks/AppendStreamTableSink.java | 3 +-
.../table/sinks/OutputFormatTableSink.java | 3 +-
.../table/sinks/RetractStreamTableSink.java | 3 +-
.../{ => legacy}/table/sinks/StreamTableSink.java | 3 +-
.../table/sinks/UpsertStreamTableSink.java | 3 +-
.../table/sources/InputFormatTableSource.java | 3 +-
.../table/sources/StreamTableSource.java | 3 +-
.../java/internal/StreamTableEnvironmentImpl.java | 2 +-
.../connector/sink/DataStreamSinkProvider.java | 1 +
.../connector/source/DataStreamScanProvider.java | 1 +
.../table/sinks/CsvAppendTableSinkFactory.java | 3 +-
.../table/sinks/CsvBatchTableSinkFactory.java | 3 +-
.../org/apache/flink/table/sinks/CsvTableSink.java | 4 ++-
.../flink/table/sinks/CsvTableSinkFactoryBase.java | 8 ++---
.../table/sources/CsvAppendTableSourceFactory.java | 3 +-
.../table/sources/CsvBatchTableSourceFactory.java | 3 +-
.../apache/flink/table/sources/CsvTableSource.java | 6 +++-
.../table/sources/CsvTableSourceFactoryBase.java | 8 ++---
.../sources/wmstrategies/AscendingTimestamps.java | 2 +-
.../wmstrategies/BoundedOutOfOrderTimestamps.java | 2 +-
...ache.flink.table.legacy.factories.TableFactory} | 0
.../table/factories/CsvTableSinkFactoryTest.java | 10 +++---
.../factories/DataGenTableSourceFactoryTest.java | 2 +-
.../flink/table/sources/CsvTableSourceTest.java | 3 +-
.../java/org/apache/flink/table/api/Table.java | 1 +
.../org/apache/flink/table/api/TableResult.java | 1 +
.../table/api/internal/TableEnvironmentImpl.java | 4 +--
.../api/internal/TableEnvironmentInternal.java | 4 +--
.../flink/table/catalog/AbstractCatalogTable.java | 2 +-
.../flink/table/catalog/AbstractCatalogView.java | 2 +-
.../flink/table/catalog/CatalogTableImpl.java | 4 +--
.../flink/table/catalog/CatalogViewImpl.java | 2 +-
.../flink/table/catalog/ConnectorCatalogTable.java | 12 +++----
.../flink/table/factories/TableFactoryUtil.java | 7 ++--
.../table/functions/TemporalTableFunctionImpl.java | 2 +-
.../operations/ddl/AlterTableOptionsOperation.java | 4 ++-
.../sources/tsextractors/ExistingField.java | 4 +--
.../tsextractors/StreamRecordTimestamp.java | 4 +--
.../operations/TableSourceQueryOperation.java | 4 +--
.../UnregisteredSinkModifyOperation.java | 2 +-
.../flink/table/typeutils/FieldInfoUtils.java | 4 +--
.../catalog/CatalogBaseTableResolutionTest.java | 4 +--
.../flink/table/catalog/CatalogTableImpTest.java | 4 +--
.../resolver/ExpressionResolverTest.java | 2 +-
.../apache/flink/table/utils/TableSourceMock.java | 4 +--
.../flink/table/utils/UserDefinedFunctions.java | 2 +-
.../internal/StreamTableEnvironmentImpl.scala | 3 +-
.../table/api/AmbiguousTableFactoryException.java | 2 +-
.../table/api/NoMatchingTableFactoryException.java | 2 +-
.../org/apache/flink/table/catalog/Catalog.java | 2 +-
.../flink/table/catalog/CatalogBaseTable.java | 2 +-
.../table/catalog/ResolvedCatalogBaseTable.java | 2 +-
.../table/connector/sink/DynamicTableSink.java | 1 +
.../abilities/SupportsAggregatePushDown.java | 2 +-
.../table/descriptors/DescriptorProperties.java | 12 +++----
.../table/descriptors/DescriptorValidator.java | 1 +
.../table/expressions/ResolvedFieldReference.java | 2 +-
.../factories/AmbiguousTableFactoryException.java | 1 +
.../flink/table/factories/CatalogFactory.java | 1 +
.../apache/flink/table/factories/FactoryUtil.java | 1 +
.../flink/table/factories/ModuleFactory.java | 1 +
.../factories/NoMatchingTableFactoryException.java | 1 +
.../flink/table/factories/TableFactoryService.java | 3 +-
.../factories/TableSinkFactoryContextImpl.java | 1 +
.../factories/TableSourceFactoryContextImpl.java | 1 +
.../flink/table/{ => legacy}/api/TableColumn.java | 4 +--
.../flink/table/{ => legacy}/api/TableSchema.java | 13 ++++---
.../apache/flink/table/{ => legacy}/api/Types.java | 4 ++-
.../table/{ => legacy}/api/WatermarkSpec.java | 2 +-
.../api/constraints/AbstractConstraint.java | 2 +-
.../{ => legacy}/api/constraints/Constraint.java | 2 +-
.../api/constraints/UniqueConstraint.java | 2 +-
.../{ => legacy}/connector/sink/SinkProvider.java | 4 ++-
.../source/AsyncTableFunctionProvider.java | 3 +-
.../connector/source/TableFunctionProvider.java | 3 +-
.../table/{ => legacy}/descriptors/Descriptor.java | 2 +-
.../table/{ => legacy}/descriptors/Rowtime.java | 5 +--
.../table/{ => legacy}/descriptors/Schema.java | 7 ++--
.../table/{ => legacy}/factories/TableFactory.java | 7 ++--
.../{ => legacy}/factories/TableSinkFactory.java | 5 +--
.../{ => legacy}/factories/TableSourceFactory.java | 5 +--
.../{ => legacy}/sinks/OverwritableTableSink.java | 2 +-
.../{ => legacy}/sinks/PartitionableTableSink.java | 2 +-
.../flink/table/{ => legacy}/sinks/TableSink.java | 4 +--
.../{ => legacy}/sources/DefinedFieldMapping.java | 4 +--
.../sources/DefinedProctimeAttribute.java | 4 +--
.../sources/DefinedRowtimeAttributes.java | 4 +--
.../table/{ => legacy}/sources/FieldComputer.java | 2 +-
.../sources/FilterableTableSource.java | 2 +-
.../{ => legacy}/sources/LimitableTableSource.java | 2 +-
.../sources/LookupableTableSource.java | 2 +-
.../NestedFieldsProjectableTableSource.java | 2 +-
.../sources/PartitionableTableSource.java | 2 +-
.../sources/ProjectableTableSource.java | 2 +-
.../sources/RowtimeAttributeDescriptor.java | 4 +--
.../table/{ => legacy}/sources/TableSource.java | 4 +--
.../sources/tsextractors/TimestampExtractor.java | 8 ++---
.../types/logical/TypeInformationRawType.java | 6 +++-
.../table/{ => legacy}/utils/TypeStringUtils.java | 3 +-
.../apache/flink/table/sinks/TableSinkBase.java | 1 +
.../flink/table/sources/TableSourceValidation.java | 9 +++--
.../tsextractors/TimestampExtractorUtils.java | 1 +
.../sources/wmstrategies/PreserveWatermarks.java | 2 +-
.../sources/wmstrategies/WatermarkStrategy.java | 4 +--
.../transforms/LegacyRawTypeTransformation.java | 2 +-
.../types/logical/LegacyTypeInformationType.java | 3 +-
.../table/types/logical/LogicalTypeVisitor.java | 1 +
.../types/logical/utils/LogicalTypeChecks.java | 2 +-
.../types/logical/utils/LogicalTypeParser.java | 2 +-
.../utils/LegacyTypeInfoDataTypeConverter.java | 2 +-
.../apache/flink/table/utils/TableSchemaUtils.java | 12 +++----
.../apache/flink/table/utils/TypeMappingUtils.java | 21 +++++------
.../apache/flink/table/api/TableSchemaTest.java | 4 ++-
.../api/constraints/UniqueConstraintTest.java | 3 ++
.../apache/flink/table/catalog/CatalogTest.java | 2 +-
.../table/connector/sink/TestManagedTableSink.java | 1 +
.../descriptors/DescriptorPropertiesTest.java | 4 +--
.../factories/TableSinkFactoryServiceTest.java | 2 ++
.../table/factories/TestTableSinkFactory.java | 4 ++-
.../flink/table/sources/TableSourceTestBase.java | 4 ++-
.../table/types/LogicalTypeCastAvoidanceTest.java | 2 +-
.../flink/table/types/LogicalTypeCastsTest.java | 2 +-
.../apache/flink/table/types/LogicalTypesTest.java | 2 +-
.../types/inference/TypeTransformationsTest.java | 2 +-
.../flink/table/utils/TableSchemaUtilsTest.java | 2 +-
.../flink/table/utils/TypeMappingUtilsTest.java | 12 +++----
.../flink/table/utils/TypeStringUtilsTest.java | 1 +
...ache.flink.table.legacy.factories.TableFactory} | 0
.../table/planner/catalog/CatalogSchemaTable.java | 8 ++---
.../connectors/TransformationScanProvider.java | 2 +-
.../connectors/TransformationSinkProvider.java | 2 +-
.../InternalDataStreamQueryOperation.java | 2 +-
.../operations/RichTableSourceQueryOperation.java | 4 +--
.../planner/plan/FlinkCalciteCatalogReader.java | 6 ++--
.../planner/plan/QueryOperationConverter.java | 8 ++---
.../plan/nodes/exec/batch/BatchExecLegacySink.java | 2 +-
.../exec/batch/BatchExecLegacyTableSourceScan.java | 4 +--
.../nodes/exec/common/CommonExecLegacySink.java | 10 +++---
.../common/CommonExecLegacyTableSourceScan.java | 10 +++---
.../nodes/exec/common/CommonExecLookupJoin.java | 4 +--
.../plan/nodes/exec/common/CommonExecSink.java | 2 +-
.../exec/common/CommonExecTableSourceScan.java | 2 +-
.../exec/serde/LogicalTypeJsonSerializer.java | 2 +-
.../nodes/exec/stream/StreamExecLegacySink.java | 2 +-
.../stream/StreamExecLegacyTableSourceScan.java | 6 ++--
.../StreamNonDeterministicUpdatePlanVisitor.java | 4 +--
.../PushFilterIntoLegacyTableSourceScanRule.java | 4 +--
.../plan/schema/FlinkPreparingTableBase.java | 2 +-
.../table/planner/plan/utils/LookupJoinUtil.java | 8 ++---
.../utils/DummyStreamExecutionEnvironment.java | 4 +--
.../table/planner/calcite/FlinkTypeFactory.scala | 6 ++--
.../flink/table/planner/codegen/CodeGenUtils.scala | 4 +--
.../table/planner/codegen/ExprCodeGenerator.scala | 1 +
.../table/planner/codegen/GenerateUtils.scala | 1 +
.../table/planner/codegen/SinkCodeGenerator.scala | 2 +-
.../agg/batch/HashWindowCodeGenerator.scala | 2 +-
.../table/planner/delegation/PlannerBase.scala | 11 +++---
.../planner/plan/nodes/calcite/LegacySink.scala | 2 +-
.../plan/nodes/calcite/LogicalLegacySink.scala | 2 +-
.../nodes/logical/FlinkLogicalLegacySink.scala | 2 +-
.../FlinkLogicalLegacyTableSourceScan.scala | 2 +-
.../physical/batch/BatchPhysicalLegacySink.scala | 3 +-
.../batch/BatchPhysicalLegacyTableSourceScan.scala | 2 +-
.../CommonPhysicalLegacyTableSourceScan.scala | 2 +-
.../physical/stream/StreamPhysicalLegacySink.scala | 3 +-
.../StreamPhysicalLegacyTableSourceScan.scala | 2 +-
.../FlinkChangelogModeInferenceProgram.scala | 2 +-
.../rules/common/CommonTemporalTableJoinRule.scala | 2 +-
...gicalCorrelateToJoinFromTemporalTableRule.scala | 2 +-
.../PushLimitIntoLegacyTableSourceScanRule.scala | 2 +-
...ushPartitionIntoLegacyTableSourceScanRule.scala | 2 +-
.../PushProjectIntoLegacyTableSourceScanRule.scala | 2 +-
.../batch/BatchPhysicalLegacySinkRule.scala | 2 +-
.../BatchPhysicalLegacyTableSourceScanRule.scala | 2 +-
.../batch/BatchPhysicalLookupJoinRule.scala | 5 +--
.../physical/common/CommonLookupJoinRule.scala | 2 +-
.../stream/StreamPhysicalLegacySinkRule.scala | 2 +-
.../StreamPhysicalLegacyTableSourceScanRule.scala | 2 +-
.../stream/StreamPhysicalLookupJoinRule.scala | 5 +--
.../planner/plan/schema/GenericRelDataType.scala | 2 +-
.../plan/schema/LegacyCatalogSourceTable.scala | 6 ++--
.../plan/schema/LegacyTableSourceTable.scala | 2 +-
.../flink/table/planner/plan/utils/ScanUtil.scala | 2 +-
.../planner/plan/utils/UpdatingPlanChecker.scala | 2 +-
.../table/planner/sinks/CollectTableSink.scala | 4 ++-
.../table/planner/sinks/DataStreamTableSink.scala | 5 +--
.../flink/table/planner/sinks/TableSinkUtils.scala | 4 ++-
.../table/planner/sources/TableSourceUtil.scala | 8 +++--
.../connector/file/table/LegacyTableFactory.java | 14 ++++----
.../planner/calcite/FlinkTypeFactoryTest.java | 2 +-
.../flink/table/planner/catalog/CatalogITCase.java | 2 +-
.../planner/catalog/CatalogStatisticsTest.java | 2 +-
.../planner/catalog/JavaCatalogTableTest.java | 2 +-
.../codegen/EqualiserCodeGeneratorTest.java | 2 +-
.../planner/codegen/SortCodeGeneratorTest.java | 2 +-
.../planner/factories/TableFactoryHarness.java | 4 +--
.../factories/TestUpdateDeleteTableFactory.java | 2 +-
.../table/planner/factories/TestValuesCatalog.java | 2 +-
.../planner/factories/TestValuesTableFactory.java | 10 +++---
.../BuiltInAggregateFunctionTestBase.java | 2 +-
.../functions/HashcodeDeprecatedITCase.java | 2 +-
.../table/planner/functions/HashcodeITCase.java | 2 +-
.../operations/SqlDdlToOperationConverterTest.java | 6 ++--
.../plan/FlinkCalciteCatalogReaderTest.java | 2 +-
.../nodes/exec/common/CommonExecSinkITCase.java | 4 +--
.../nodes/exec/operator/BatchOperatorNameTest.java | 4 +--
.../exec/operator/StreamOperatorNameTest.java | 4 +--
...ache.flink.table.legacy.factories.TableFactory} | 0
.../flink/table/api/TableEnvironmentITCase.scala | 1 +
.../flink/table/api/TableEnvironmentTest.scala | 3 +-
.../planner/expressions/ScalarFunctionsTest.scala | 1 +
.../utils/userDefinedScalarFunctions.scala | 2 +-
.../utils/TestCollectionTableFactory.scala | 11 +++---
.../plan/batch/sql/OperatorFusionCodegenTest.scala | 2 +-
.../plan/batch/sql/RemoveCollationTest.scala | 2 +-
.../planner/plan/batch/sql/RemoveShuffleTest.scala | 2 +-
.../plan/batch/sql/agg/AggregateTestBase.scala | 3 +-
.../plan/batch/sql/join/LookupJoinTest.scala | 3 +-
.../common/AggregateReduceGroupingTestBase.scala | 2 +-
.../plan/common/DistinctAggregateTestBase.scala | 1 +
.../planner/plan/common/JoinReorderTestBase.scala | 2 +-
.../planner/plan/common/TableFactoryTest.scala | 2 +-
.../table/planner/plan/common/UnnestTestBase.scala | 1 +
.../planner/plan/metadata/MetadataTestUtil.scala | 3 +-
.../logical/DecomposeGroupingSetsRuleTest.scala | 1 +
.../FlinkAggregateJoinTransposeRuleTest.scala | 1 +
.../logical/FlinkAggregateRemoveRuleTest.scala | 1 +
.../logical/JoinDeriveNullFilterRuleTest.scala | 2 +-
.../logical/PruneAggregateCallRuleTestBase.scala | 1 +
...shFilterIntoLegacyTableSourceScanRuleTest.scala | 3 +-
.../plan/stream/sql/NonDeterministicDagTest.scala | 3 +-
.../planner/plan/stream/sql/TableSinkTest.scala | 3 +-
.../plan/stream/sql/agg/AggregateTest.scala | 1 +
.../plan/stream/sql/join/LookupJoinTest.scala | 8 +++--
.../table/TemporalTableFunctionJoinTest.scala | 1 +
.../validation/LegacyTableSinkValidationTest.scala | 1 +
.../plan/utils/TestContextTableFactory.scala | 7 ++--
.../planner/runtime/batch/sql/CalcITCase.scala | 3 +-
.../runtime/batch/sql/LegacyLimitITCase.scala | 2 +-
.../batch/sql/PartitionableSinkITCase.scala | 12 ++++---
.../runtime/batch/sql/TimestampITCase.scala | 3 +-
.../planner/runtime/batch/sql/UnnestITCase.scala | 2 +-
.../batch/sql/agg/AggregateITCaseBase.scala | 1 +
.../sql/agg/AggregateJoinTransposeITCase.scala | 3 +-
.../sql/agg/AggregateReduceGroupingITCase.scala | 2 +-
.../batch/sql/agg/AggregateRemoveITCase.scala | 2 +-
.../runtime/batch/sql/agg/GroupingSetsITCase.scala | 2 +-
.../runtime/batch/sql/agg/SortAggITCase.scala | 3 +-
.../runtime/batch/sql/join/LookupJoinITCase.scala | 2 +-
.../runtime/batch/table/AggregationITCase.scala | 1 +
.../runtime/batch/table/LegacyLimitITCase.scala | 2 +-
.../batch/table/LegacyTableSinkITCase.scala | 1 +
.../runtime/stream/sql/AggregateITCase.scala | 3 +-
.../runtime/stream/sql/AsyncLookupJoinITCase.scala | 1 +
.../runtime/stream/sql/CorrelateITCase.scala | 1 +
.../runtime/stream/sql/GroupWindowITCase.scala | 1 +
.../runtime/stream/sql/LookupJoinITCase.scala | 1 +
.../runtime/stream/sql/MatchRecognizeITCase.scala | 1 +
.../runtime/stream/sql/SplitAggregateITCase.scala | 1 +
.../runtime/stream/sql/TableScanITCase.scala | 1 +
.../runtime/stream/sql/TableSinkITCase.scala | 3 +-
.../runtime/stream/sql/TimestampITCase.scala | 1 +
.../planner/runtime/stream/sql/UnnestITCase.scala | 1 +
.../runtime/stream/table/AggregateITCase.scala | 1 +
.../runtime/stream/table/CorrelateITCase.scala | 1 +
.../planner/runtime/stream/table/JoinITCase.scala | 1 +
.../stream/table/LegacyTableSinkITCase.scala | 1 +
.../utils/InMemoryLookupableTableSource.scala | 10 +++---
.../planner/runtime/utils/StreamTestSink.scala | 4 +--
.../table/planner/runtime/utils/TestSinkUtil.scala | 2 +-
.../flink/table/planner/utils/AvgAggFunction.scala | 3 +-
.../planner/utils/MemoryTableSourceSinkUtil.scala | 9 +++--
.../flink/table/planner/utils/TableTestBase.scala | 14 +++++---
.../utils/TestLegacyLimitableTableSource.scala | 11 +++---
.../planner/utils/UserDefinedAggFunctions.scala | 2 +-
.../utils/UserDefinedTableAggFunctions.scala | 2 +-
.../table/planner/utils/testTableSourceSinks.scala | 16 ++++++---
.../data/conversion/RawByteArrayConverter.java | 2 +-
.../table/data/conversion/RawObjectConverter.java | 2 +-
.../table/data/util/DataFormatConverters.java | 2 +-
.../table/runtime/types/PlannerTypeUtils.java | 2 +-
.../runtime/typeutils/InternalSerializers.java | 2 +-
.../runtime/types/LogicalTypeAssignableTest.java | 2 +-
322 files changed, 662 insertions(+), 486 deletions(-)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/connector/source/SourceFunctionProvider.java (95%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/descriptors/RowtimeValidator.java (80%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/descriptors/SchemaValidator.java (90%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/factories/StreamTableSinkFactory.java (89%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/factories/StreamTableSourceFactory.java (89%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sinks/AppendStreamTableSink.java (94%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sinks/OutputFormatTableSink.java (95%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sinks/RetractStreamTableSink.java (95%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sinks/StreamTableSink.java (94%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sinks/UpsertStreamTableSink.java (97%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sources/InputFormatTableSource.java (95%)
rename
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/{ =>
legacy}/table/sources/StreamTableSource.java (94%)
rename
flink-table/flink-table-api-java-bridge/src/main/resources/META-INF/services/{org.apache.flink.table.factories.TableFactory
=> org.apache.flink.table.legacy.factories.TableFactory} (100%)
rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/{
=> legacy}/operations/ddl/AlterTableOptionsOperation.java (93%)
rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/{
=> legacy}/sources/tsextractors/ExistingField.java (97%)
rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/{
=> legacy}/sources/tsextractors/StreamRecordTimestamp.java (95%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/TableColumn.java (99%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/TableSchema.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/Types.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/WatermarkSpec.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/constraints/AbstractConstraint.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/constraints/Constraint.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/api/constraints/UniqueConstraint.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/connector/sink/SinkProvider.java (92%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/connector/source/AsyncTableFunctionProvider.java (95%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/connector/source/TableFunctionProvider.java (95%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/descriptors/Descriptor.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/descriptors/Rowtime.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/descriptors/Schema.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/factories/TableFactory.java (93%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/factories/TableSinkFactory.java (96%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/factories/TableSourceFactory.java (95%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sinks/OverwritableTableSink.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sinks/PartitionableTableSink.java (99%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sinks/TableSink.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/DefinedFieldMapping.java (96%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/DefinedProctimeAttribute.java (94%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/DefinedRowtimeAttributes.java (94%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/FieldComputer.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/FilterableTableSource.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/LimitableTableSource.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/LookupableTableSource.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/NestedFieldsProjectableTableSource.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/PartitionableTableSource.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/ProjectableTableSource.java (98%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/RowtimeAttributeDescriptor.java (95%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/TableSource.java (97%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/sources/tsextractors/TimestampExtractor.java (90%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/types/logical/TypeInformationRawType.java (94%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/{
=> legacy}/utils/TypeStringUtils.java (99%)
rename
flink-table/flink-table-common/src/test/resources/META-INF/services/{org.apache.flink.table.factories.TableFactory
=> org.apache.flink.table.legacy.factories.TableFactory} (100%)
rename
flink-table/flink-table-planner/src/test/resources/META-INF/services/{org.apache.flink.table.factories.TableFactory
=> org.apache.flink.table.legacy.factories.TableFactory} (100%)
