This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 49d9172b1 [Feature][Connector-V2][Github] Adding Github Source
Connector (#4155)
add 9681173b1 [Feature][Connector-V2] StarRocks source connector (#3679)
No new revisions were added by this update.
Summary of changes:
.../connector-v2/Error-Quick-Reference-Manual.md | 5 +
docs/en/connector-v2/source/StarRocks.md | 176 ++++++++++
plugin-mapping.properties | 1 +
.../connector-starrocks/pom.xml | 60 ++++
.../seatunnel/starrocks/client/HttpHelper.java | 19 ++
.../client/source/StarRocksBeReadClient.java | 200 ++++++++++++
.../source/StarRocksQueryPlanReadClient.java | 212 ++++++++++++
.../client/source/StarRocksRowBatchReader.java | 357 +++++++++++++++++++++
.../model/Column.java} | 18 +-
.../model/QueryBeXTablets.java} | 15 +-
.../model/QueryInfo.java} | 15 +-
.../client/source/model/QueryPartition.java | 122 +++++++
.../model/QueryPlan.java} | 23 +-
.../model/Tablet.java} | 18 +-
.../seatunnel/starrocks/config/CommonConfig.java} | 60 ++--
.../seatunnel/starrocks/config/SourceConfig.java | 166 ++++++++++
.../exception/StarRocksConnectorErrorCode.java | 8 +-
.../starrocks/source/StarRocksSource.java} | 81 +++--
.../starrocks/source/StarRocksSourceFactory.java} | 35 +-
.../starrocks/source/StarRocksSourceReader.java | 116 +++++++
.../starrocks/source/StarRocksSourceSplit.java} | 16 +-
.../starrocks/source/StarRocksSourceState.java} | 10 +-
.../source/StartRocksSourceSplitEnumerator.java | 196 +++++++++++
.../connector-starrocks-e2e/pom.xml | 6 -
.../e2e/connector/starrocks/StarRocksIT.java | 3 +-
... starrocks-thrift-to-starrocks-streamload.conf} | 29 +-
26 files changed, 1823 insertions(+), 144 deletions(-)
create mode 100644 docs/en/connector-v2/source/StarRocks.md
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksBeReadClient.java
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksQueryPlanReadClient.java
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksRowBatchReader.java
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/{StarRocksFlushTuple.java
=> source/model/Column.java} (85%)
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/{StarRocksFlushTuple.java
=> source/model/QueryBeXTablets.java} (81%)
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/{StarRocksFlushTuple.java
=> source/model/QueryInfo.java} (80%)
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/model/QueryPartition.java
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/{StarRocksFlushTuple.java
=> source/model/QueryPlan.java} (67%)
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/{StarRocksFlushTuple.java
=> source/model/Tablet.java} (76%)
copy
seatunnel-connectors-v2/{connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/config/HudiSourceConfig.java
=>
connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/CommonConfig.java}
(50%)
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SourceConfig.java
copy
seatunnel-connectors-v2/{connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSource.java
=>
connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSource.java}
(53%)
copy
seatunnel-connectors-v2/{connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/source/RedisSourceFactory.java
=>
connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceFactory.java}
(57%)
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceReader.java
copy
seatunnel-connectors-v2/{connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/split/RabbitmqSplit.java
=>
connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceSplit.java}
(75%)
copy
seatunnel-connectors-v2/{connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceState.java
=>
connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceState.java}
(81%)
create mode 100644
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StartRocksSourceSplitEnumerator.java
rename
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/{starrocks-jdbc-to-starrocks.conf
=> starrocks-thrift-to-starrocks-streamload.conf} (65%)
