This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch eventmesh-function
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 866b4d6cc fix ci check error
add a1d834d31 fix ci check error
add 35f1659e9 fix ci check error
No new revisions were added by this update.
Summary of changes:
.../HttpRecordOffset.java} | 12 +-
.../HttpRecordPartition.java} | 17 ++-
.../prometheus/PrometheusRecordPartition.java | 23 +---
.../offset/spring/SpringRecordPartition.java | 23 +---
.../connector/canal/ByteArrayConverter.java | 7 +-
.../connector/canal/CanalConnectRecord.java | 72 +++++-----
.../connector/canal/DatabaseConnection.java | 4 +-
.../connector/canal/SqlTimestampConverter.java | 18 ++-
.../apache/eventmesh/connector/canal/SqlUtils.java | 72 ++++------
.../connector/canal/dialect/AbstractDbDialect.java | 82 +----------
.../connector/canal/dialect/DbDialect.java | 2 +-
.../connector/canal/dialect/MysqlDialect.java | 6 +-
.../interceptor/SqlBuilderLoadInterceptor.java | 20 +--
.../connector/canal/model/EventColumn.java | 76 +++-------
.../canal/model/EventColumnIndexComparable.java | 4 -
.../eventmesh/connector/canal/model/EventType.java | 3 +-
.../connector/canal/sink/DbLoadContext.java | 9 +-
.../eventmesh/connector/canal/sink/DbLoadData.java | 12 +-
.../canal/sink/connector/CanalSinkConnector.java | 153 ++++++---------------
.../connector/canal/source/EntryParser.java | 107 ++------------
.../source/connector/CanalSourceConnector.java | 73 +---------
.../canal/template/AbstractSqlTemplate.java | 19 +--
.../connector/canal/template/MysqlSqlTemplate.java | 7 +-
.../connector/canal/template/SqlTemplate.java | 5 +-
.../chatgpt/config/ChatGPTServerConfig.java | 2 +-
.../chatgpt/source/config/ChatGPTSourceConfig.java | 2 +-
.../source/connector/ChatGPTSourceConnector.java | 2 +-
.../file/source/connector/FileSourceConnector.java | 3 +-
.../connector/http/sink/HttpSinkConnector.java | 2 +-
.../connector/http/sink/config/HttpSinkConfig.java | 2 +-
.../http/sink/data/HttpConnectRecord.java | 3 +-
.../http/sink/handle/CommonHttpSinkHandler.java | 3 +-
.../http/source/connector/HttpSourceConnector.java | 1 -
.../jdbc/source/AbstractJdbcTaskManager.java | 2 +-
.../dialect/antlr4/mysql/MysqlAntlr4DdlParser.java | 3 +-
.../listener/CreateDatabaseParserListener.java | 2 +-
.../mysql/listener/DropDatabaseParserListener.java | 2 +-
.../jdbc/source/dialect/cdc/AbstractCdcEngine.java | 4 +-
.../source/dialect/cdc/mysql/MysqlCdcEngine.java | 5 +-
.../source/dialect/mysql/MysqlJdbcContext.java | 4 +-
.../snapshot/mysql/MysqlSnapshotEngineFactory.java | 2 +-
.../java/org/apache/eventmesh/runtime/Runtime.java | 3 +
.../apache/eventmesh/runtime/RuntimeFactory.java | 3 +
.../eventmesh/runtime/RuntimeInstanceConfig.java | 24 ++--
.../eventmesh/runtime/boot/RuntimeInstance.java | 8 +-
.../runtime/connector/ConnectorRuntime.java | 123 ++++++++---------
46 files changed, 298 insertions(+), 733 deletions(-)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/{canal/CanalRecordOffset.java
=> http/HttpRecordOffset.java} (81%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/{S3/S3RecordOffset.java
=> http/HttpRecordPartition.java} (73%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
