This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from bee011fd9 [INLONG-6282][Manager] Fix the delete API not working
problem in the manager client (#6287)
add 29dfc6a77 [INLONG-6045][Sort] Support all migrate for Oracle connector
(#6175)
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/sort/protocol/Metadata.java | 8 +
.../protocol/node/extract/OracleExtractNode.java | 3 +-
.../node/extract/OracleExtractNodeTest.java | 4 +
.../org/apache/inlong/sort/base/Constants.java | 6 +
inlong-sort/sort-connectors/oracle-cdc/pom.xml | 39 ++-
.../inlong/sort/cdc/oracle/OracleSource.java | 5 +-
.../debezium/DebeziumDeserializationSchema.java | 5 +-
.../{ => debezium}/DebeziumSourceFunction.java | 101 ++++----
.../history/FlinkJsonTableChangeSerializer.java | 3 +-
.../debezium/internal/DebeziumChangeConsumer.java | 7 +-
.../debezium/internal/DebeziumChangeFetcher.java | 21 +-
.../oracle}/debezium/internal/DebeziumOffset.java | 5 +-
.../internal/DebeziumOffsetSerializer.java | 5 +-
.../debezium/internal/FlinkDatabaseHistory.java | 11 +-
.../internal/FlinkDatabaseSchemaHistory.java | 21 +-
.../debezium/internal/FlinkOffsetBackingStore.java | 25 +-
.../cdc/oracle}/debezium/internal/Handover.java | 17 +-
.../oracle}/debezium/internal/SchemaRecord.java | 5 +-
.../debezium/table/AppendMetadataCollector.java | 14 +-
.../oracle}/debezium/table/DebeziumOptions.java | 2 +-
.../table/DeserializationRuntimeConverter.java | 9 +-
.../DeserializationRuntimeConverterFactory.java | 5 +-
.../oracle}/debezium/table/MetadataConverter.java | 9 +-
.../table/RowDataDebeziumDeserializeSchema.java | 252 +++++++++++++++----
.../debezium/utils/DatabaseHistoryUtil.java | 5 +-
.../cdc/oracle/debezium/utils/RecordUtils.java | 134 ++++++++++
.../debezium/utils/TemporalConversions.java | 2 +-
.../OracleDeserializationConverterFactory.java | 280 +++++++++++++++++++++
.../cdc/oracle/table/OracleReadableMetaData.java} | 194 ++++++--------
.../sort/cdc/oracle/table/OracleTableSource.java | 36 +--
.../cdc/oracle/table/OracleTableSourceFactory.java | 6 +-
...lMigrateTest.java => AllMigrateOracleTest.java} | 103 ++++----
.../inlong/sort/formats/json/canal/CanalJson.java | 19 ++
licenses/inlong-sort-connectors/LICENSE | 22 ++
34 files changed, 1001 insertions(+), 382 deletions(-)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/DebeziumDeserializationSchema.java
(97%)
rename
inlong-sort/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/{
=> debezium}/DebeziumSourceFunction.java (91%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/history/FlinkJsonTableChangeSerializer.java
(99%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/DebeziumChangeConsumer.java
(98%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/DebeziumChangeFetcher.java
(96%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/DebeziumOffset.java
(97%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/DebeziumOffsetSerializer.java
(96%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/FlinkDatabaseHistory.java
(91%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/FlinkDatabaseSchemaHistory.java
(91%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/FlinkOffsetBackingStore.java
(98%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/Handover.java
(99%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/internal/SchemaRecord.java
(97%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/table/AppendMetadataCollector.java
(91%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/table/DebeziumOptions.java
(97%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/table/DeserializationRuntimeConverter.java
(84%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/table/DeserializationRuntimeConverterFactory.java
(97%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/table/MetadataConverter.java
(94%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/table/RowDataDebeziumDeserializeSchema.java
(78%)
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/utils/DatabaseHistoryUtil.java
(96%)
create mode 100644
inlong-sort/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/utils/RecordUtils.java
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle}/debezium/utils/TemporalConversions.java
(99%)
create mode 100644
inlong-sort/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/table/OracleDeserializationConverterFactory.java
copy
inlong-sort/sort-connectors/{mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/table/MySqlReadableMetadata.java
=>
oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/table/OracleReadableMetaData.java}
(75%)
copy
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/{AllMigrateTest.java
=> AllMigrateOracleTest.java} (71%)
