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/incubator-inlong.git.
from 9040c8b [INLONG-2338] add default dataproxy address (#2339)
add f23927e [INLONG-2331] Introduce sort-connectors module (#2332)
No new revisions were added by this update.
Summary of changes:
inlong-sort/pom.xml | 7 +++
.../pom.xml | 66 +++++++++++++++-------
.../clickhouse/ClickHouseConnectionProvider.java | 0
.../flink/clickhouse/ClickHouseRowConverter.java | 0
.../flink/clickhouse/ClickHouseSinkFunction.java | 0
.../clickhouse/ClickHouseStatementFactory.java | 0
.../executor/ClickHouseAppendExecutor.java | 0
.../clickhouse/executor/ClickHouseExecutor.java | 0
.../executor/ClickHouseExecutorFactory.java | 0
.../executor/ClickHouseUpsertExecutor.java | 0
.../output/AbstractClickHouseOutputFormat.java | 0
.../output/ClickHouseBatchOutputFormat.java | 0
.../output/ClickHouseOutputFormatFactory.java | 0
.../output/ClickHouseShardOutputFormat.java | 0
.../clickhouse/partitioner/BalancePartitioner.java | 0
.../partitioner/ClickHousePartitioner.java | 0
.../clickhouse/partitioner/HashPartitioner.java | 0
.../clickhouse/partitioner/RandomPartitioner.java | 0
.../inlong/sort/flink/doris/DorisSinkFunction.java | 0
.../inlong/sort/flink/doris/DorisSinkOptions.java | 0
.../sort/flink/doris/DorisSinkOptionsBuilder.java | 0
.../sort/flink/doris/load/DorisBeInfoResponse.java | 0
.../sort/flink/doris/load/DorisConnectParam.java | 0
.../sort/flink/doris/load/DorisHttpUtils.java | 0
.../inlong/sort/flink/doris/load/DorisRespond.java | 0
.../sort/flink/doris/load/DorisRespondMsg.java | 0
.../sort/flink/doris/load/DorisRowConverter.java | 0
.../sort/flink/doris/load/DorisStreamLoad.java | 0
.../sort/flink/doris/output/DorisOutputFormat.java | 0
.../inlong/sort/flink/filesystem/Bucket.java | 0
.../sort/flink/filesystem/BucketAssigner.java | 0
.../sort/flink/filesystem/BucketFactory.java | 0
.../inlong/sort/flink/filesystem/BucketState.java | 0
.../flink/filesystem/BucketStateSerializer.java | 0
.../inlong/sort/flink/filesystem/Buckets.java | 0
.../sort/flink/filesystem/BulkPartWriter.java | 0
.../flink/filesystem/DefaultBucketFactoryImpl.java | 0
.../flink/filesystem/DefaultRollingPolicy.java | 0
.../inlong/sort/flink/filesystem/PartFileInfo.java | 0
.../sort/flink/filesystem/PartFileWriter.java | 0
.../sort/flink/filesystem/RollingPolicy.java | 0
.../sort/flink/filesystem/StreamingFileSink.java | 0
.../inlong/sort/flink/hive/HiveCommitter.java | 0
.../flink/hive/HivePartitionBucketAssigner.java | 0
.../inlong/sort/flink/hive/HiveSinkHelper.java | 0
.../apache/inlong/sort/flink/hive/HiveWriter.java | 0
.../sort/flink/hive/formats/ParquetRowWriter.java | 0
.../hive/formats/ParquetRowWriterBuilder.java | 0
.../flink/hive/formats/ParquetSchemaConverter.java | 0
.../sort/flink/hive/formats/TextRowWriter.java | 0
.../sort/flink/hive/partition/HivePartition.java | 0
.../partition/JdbcHivePartitionCommitPolicy.java | 0
.../hive/partition/JdbcHivePartitionTool.java | 0
.../flink/hive/partition/PartitionCommitInfo.java | 0
.../hive/partition/PartitionCommitPolicy.java | 0
.../flink/hive/partition/PartitionComputer.java | 0
.../flink/hive/partition/PartitionPathUtils.java | 0
.../flink/hive/partition/RowPartitionComputer.java | 0
.../flink/pulsar/PulsarDeserializationSchema.java | 0
.../inlong/sort/flink/pulsar/PulsarOptions.java | 0
.../sort/flink/pulsar/PulsarSourceFunction.java | 0
.../inlong/sort/flink/pulsar/PulsarUtils.java | 0
.../inlong/sort/flink/doris/TestDorisSink.java | 0
inlong-sort/sort-core/pom.xml | 27 ++-------
.../org/apache/inlong/sort/flink/Entrance.java | 12 ++--
.../clickhouse/ClickHouseMultiSinkFunction.java | 3 +-
.../doris/DorisMultiSinkFunction.java | 3 +-
.../hive/HiveMultiTenantCommitter.java | 3 +-
.../hive/HiveMultiTenantWriter.java | 3 +-
.../pulsar/MultiTenancyPulsarConsumer.java | 5 +-
.../pulsar/MultiTopicPulsarSourceFunction.java | 5 +-
.../SerializedRecordDeserializationSchema.java | 3 +-
.../tubemq/MultiTenancyTubeConsumer.java | 2 +-
.../tubemq/MultiTopicTubeSourceFunction.java | 2 +-
.../tubemq/TubeSubscriptionDescription.java | 2 +-
.../{ => multitenant}/hive/HiveSinkITCase.java | 2 +-
.../pulsar/MultiTopicPulsarSourceFunctionTest.java | 2 +-
.../pulsar/PulsarTestMetaManagerUtil.java | 2 +-
.../pulsar/TestSourceContext.java | 2 +-
.../tubemq/MultiTenancyTubeConsumerTest.java | 4 +-
.../tubemq/MultiTopicTubeSourceFunctionTest.java | 6 +-
.../tubemq/TubeSubscriptionDescriptionTest.java | 2 +-
82 files changed, 94 insertions(+), 69 deletions(-)
copy inlong-sort/{sort-single-tenant => sort-connectors}/pom.xml (65%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/ClickHouseConnectionProvider.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/ClickHouseRowConverter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/ClickHouseSinkFunction.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/ClickHouseStatementFactory.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/executor/ClickHouseAppendExecutor.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/executor/ClickHouseExecutor.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/executor/ClickHouseExecutorFactory.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/executor/ClickHouseUpsertExecutor.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/output/AbstractClickHouseOutputFormat.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/output/ClickHouseBatchOutputFormat.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/output/ClickHouseOutputFormatFactory.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/output/ClickHouseShardOutputFormat.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/partitioner/BalancePartitioner.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/partitioner/ClickHousePartitioner.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/partitioner/HashPartitioner.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/clickhouse/partitioner/RandomPartitioner.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/DorisSinkFunction.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/DorisSinkOptions.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/DorisSinkOptionsBuilder.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisBeInfoResponse.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisConnectParam.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisHttpUtils.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisRespond.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisRespondMsg.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisRowConverter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/load/DorisStreamLoad.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/doris/output/DorisOutputFormat.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/Bucket.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketAssigner.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketFactory.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketState.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/BucketStateSerializer.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/Buckets.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/BulkPartWriter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/DefaultBucketFactoryImpl.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/DefaultRollingPolicy.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/PartFileInfo.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/PartFileWriter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/RollingPolicy.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/filesystem/StreamingFileSink.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/HiveCommitter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/HivePartitionBucketAssigner.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/HiveSinkHelper.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/HiveWriter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/formats/ParquetRowWriter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/formats/ParquetRowWriterBuilder.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/formats/ParquetSchemaConverter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/formats/TextRowWriter.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/HivePartition.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/JdbcHivePartitionCommitPolicy.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/JdbcHivePartitionTool.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/PartitionCommitInfo.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/PartitionCommitPolicy.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/PartitionComputer.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/PartitionPathUtils.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/hive/partition/RowPartitionComputer.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/pulsar/PulsarDeserializationSchema.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/pulsar/PulsarOptions.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/pulsar/PulsarSourceFunction.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/main/java/org/apache/inlong/sort/flink/pulsar/PulsarUtils.java
(100%)
rename inlong-sort/{sort-core =>
sort-connectors}/src/test/java/org/apache/inlong/sort/flink/doris/TestDorisSink.java
(100%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/clickhouse/ClickHouseMultiSinkFunction.java (98%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/doris/DorisMultiSinkFunction.java (98%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/hive/HiveMultiTenantCommitter.java (98%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/hive/HiveMultiTenantWriter.java (98%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/pulsar/MultiTenancyPulsarConsumer.java (96%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/pulsar/MultiTopicPulsarSourceFunction.java (97%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/pulsar/SerializedRecordDeserializationSchema.java (93%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/tubemq/MultiTenancyTubeConsumer.java (99%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/tubemq/MultiTopicTubeSourceFunction.java (99%)
rename inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/flink/{ =>
multitenant}/tubemq/TubeSubscriptionDescription.java (99%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/hive/HiveSinkITCase.java (99%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/pulsar/MultiTopicPulsarSourceFunctionTest.java (99%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/pulsar/PulsarTestMetaManagerUtil.java (98%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/pulsar/TestSourceContext.java (97%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/tubemq/MultiTenancyTubeConsumerTest.java (98%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/tubemq/MultiTopicTubeSourceFunctionTest.java (96%)
rename inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/flink/{ =>
multitenant}/tubemq/TubeSubscriptionDescriptionTest.java (98%)
