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/28 11:01:02 UTC

[incubator-inlong] branch master updated (59afacf -> d5e67a4)

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 59afacf  [INLONG-2771][Manager] Add stream source API in manager client module (#2780)
     add d5e67a4  [INGLONG-2754][Agent] Add stream metric data to Prometheus and JMX #2755

No new revisions were added by this update.

Summary of changes:
 .../inlong/agent/constant/CommonConstants.java     |   1 -
 .../inlong/agent/plugin/sinks/AbstractSink.java    |  41 +++
 .../inlong/agent/plugin/sinks/ConsoleSink.java     |  24 +-
 .../inlong/agent/plugin/sinks/ProxySink.java       |  34 +--
 .../inlong/agent/plugin/sinks/PulsarSink.java      | 287 ---------------------
 .../plugin/sources/reader/AbstractReader.java      |  67 +++++
 .../agent/plugin/sources/reader/SqlReader.java     |  32 +--
 .../plugin/sources/reader/TextFileReader.java      |  44 ++--
 .../apache/inlong/dataproxy/base/ProxyMessage.java |   2 +-
 .../dataproxy/consts/AttributeConstants.java       |   2 +-
 .../inlong/dataproxy/http/MessageFilter.java       |   4 +-
 .../dataproxy/http/MessageProcessServlet.java      |   4 +-
 .../dataproxy/http/SimpleMessageHandler.java       |   4 +-
 .../dataproxy/metrics/DataProxyMetricItem.java     |   2 +-
 .../org/apache/inlong/dataproxy/sink/MetaSink.java |   8 +-
 .../apache/inlong/dataproxy/sink/PulsarSink.java   |   4 +-
 .../dataproxy/sink/SimpleMessageTubeSink.java      |   4 +-
 .../dataproxy/sink/pulsar/PulsarClientService.java |   4 +-
 .../dataproxy/source/DefaultServiceDecoder.java    |   6 +-
 .../dataproxy/source/ServerMessageHandler.java     |   4 +-
 .../dataproxy/source/SimpleMessageHandler.java     |   4 +-
 21 files changed, 172 insertions(+), 410 deletions(-)
 delete mode 100755 inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java
 create mode 100644 inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/AbstractReader.java