You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by do...@apache.org on 2022/02/14 09:33:56 UTC

[incubator-inlong] branch master updated (11ff93d -> 0ac5ac5)

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