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 11ff93d [INLONG-2381] DataProxy support Tube sink of PB compression
cache message protocol. (#2447)
add 0ac5ac5 [INLONG-2377] DataProxy support PB compression protocol
format source. (#2395)
No new revisions were added by this update.
Summary of changes:
.../inlong/dataproxy/source/SourceContext.java | 304 +++++++++++++++++++++
.../source/tcp/InlongTcpChannelHandler.java | 263 ++++++++++++++++++
.../tcp/InlongTcpChannelPipelineFactory.java | 88 +++---
.../dataproxy/source/tcp/InlongTcpSource.java | 240 ++++++++++++++++
inlong-sdk/sdk-common/pom.xml | 1 -
5 files changed, 853 insertions(+), 43 deletions(-)
create mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/SourceContext.java
create mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/tcp/InlongTcpChannelHandler.java
copy
inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageFactory.java
=>
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/tcp/InlongTcpChannelPipelineFactory.java
(51%)
create mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/tcp/InlongTcpSource.java
