You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 02:04:18 UTC
[rocketmq-connect] branch master updated (18c29ea -> a1e5f60)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git.
omit 18c29ea Add 'connector/rocketmq-connect-cassandra/' from commit 'e2cc843ef4926a98797ca76880579941d5363fc6'
omit 32a23ce Add 'connector/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
omit e2cc843 [ISSUE #570] ASoC runtime optimization: Cassandra connectors (#587)
omit e8aedf3 Change README.md (#301)
omit 3da8a3f format pom.xml
omit db391c5 change exception
omit 23a5b24 add licenses
omit 508eea1 add unit test
omit d50ffb8 message type
omit 6663768 change
omit da0b21f change
omit 30b02f4 change package name
omit c7c0c04 init complete
omit f4221ce (1)Rename rocketmq-connector to replicator (2) Initialize RocketMQ activemq connect and runtime
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/master (a1e5f60)
\
O -- O -- O (18c29ea)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
connector/rocketmq-connect-activemq/README-CN.md | 16 --
connector/rocketmq-connect-activemq/README.md | 16 --
connector/rocketmq-connect-activemq/pom.xml | 201 ---------------
.../apache/rocketmq/connect/activemq/Config.java | 163 ------------
.../rocketmq/connect/activemq/ErrorCode.java | 8 -
.../rocketmq/connect/activemq/Replicator.java | 63 -----
.../connector/ActivemqSourceConnector.java | 72 ------
.../activemq/connector/ActivemqSourceTask.java | 141 -----------
.../connect/activemq/pattern/PatternProcessor.java | 89 -------
.../rocketmq/connect/activemq/ReplicatorTest.java | 74 ------
.../activemq/connector/ActivemqConnectorTest.java | 58 -----
.../activemq/connector/ActivemqSourceTaskTest.java | 165 ------------
connector/rocketmq-connect-cassandra/README.md | 97 -------
connector/rocketmq-connect-cassandra/pom.xml | 276 --------------------
.../rocketmq-connect-cassandra/scripts/gen_data.py | 155 -----------
.../scripts/requirements.txt | 2 -
.../connect/cassandra/common/CloneUtils.java | 44 ----
.../connect/cassandra/common/ConstDefine.java | 23 --
.../rocketmq/connect/cassandra/common/DBUtils.java | 91 -------
.../connect/cassandra/common/DataType.java | 26 --
.../rocketmq/connect/cassandra/common/Utils.java | 76 ------
.../rocketmq/connect/cassandra/config/Config.java | 282 ---------------------
.../connect/cassandra/config/ConfigUtil.java | 70 -----
.../cassandra/config/DbConnectorConfig.java | 110 --------
.../cassandra/config/SinkDbConnectorConfig.java | 112 --------
.../cassandra/config/SourceDbConnectorConfig.java | 87 -------
.../connect/cassandra/config/TaskDivideConfig.java | 123 ---------
.../connect/cassandra/config/TaskTopicInfo.java | 40 ---
.../connector/CassandraSinkConnector.java | 240 ------------------
.../cassandra/connector/CassandraSinkTask.java | 161 ------------
.../connector/CassandraSourceConnector.java | 108 --------
.../cassandra/connector/CassandraSourceTask.java | 168 ------------
.../connect/cassandra/schema/Database.java | 140 ----------
.../rocketmq/connect/cassandra/schema/Schema.java | 146 -----------
.../rocketmq/connect/cassandra/schema/Table.java | 103 --------
.../schema/column/BigIntColumnParser.java | 50 ----
.../schema/column/BooleanColumnParser.java | 34 ---
.../cassandra/schema/column/ColumnParser.java | 118 ---------
.../schema/column/DateTimeColumnParser.java | 53 ----
.../schema/column/DefaultColumnParser.java | 37 ---
.../cassandra/schema/column/EnumColumnParser.java | 46 ----
.../cassandra/schema/column/IntColumnParser.java | 66 -----
.../cassandra/schema/column/SetColumnParser.java | 54 ----
.../schema/column/StringColumnParser.java | 57 -----
.../cassandra/schema/column/TimeColumnParser.java | 39 ---
.../cassandra/schema/column/YearColumnParser.java | 40 ---
.../rocketmq/connect/cassandra/sink/Updater.java | 216 ----------------
.../rocketmq/connect/cassandra/source/Querier.java | 164 ------------
.../cassandra/strategy/DivideStrategyEnum.java | 23 --
.../cassandra/strategy/DivideTaskByTopic.java | 110 --------
.../cassandra/strategy/TaskDivideStrategy.java | 32 ---
51 files changed, 4885 deletions(-)
delete mode 100644 connector/rocketmq-connect-activemq/README-CN.md
delete mode 100644 connector/rocketmq-connect-activemq/README.md
delete mode 100644 connector/rocketmq-connect-activemq/pom.xml
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
delete mode 100644 connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
delete mode 100644 connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
delete mode 100644 connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
delete mode 100644 connector/rocketmq-connect-cassandra/README.md
delete mode 100644 connector/rocketmq-connect-cassandra/pom.xml
delete mode 100644 connector/rocketmq-connect-cassandra/scripts/gen_data.py
delete mode 100644 connector/rocketmq-connect-cassandra/scripts/requirements.txt
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java