[incubator-inlong] branch master updated (6bc4b37 -> c183c78)

[do...@apache.org]

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 6bc4b37   [INLONG-2317] Support Plugin in Inlong Manager (#2319)
     add c183c78  [INLONG-2326] Inlong-Sort-Standalone support to sort the events to ElasticSearch cluster. (#2327)

No new revisions were added by this update.

Summary of changes:
 .../conf/es/GetClusterConfig.json                  |  90 ++++
 .../conf/es/GetSortSourceConfig.json               |  68 +++
 .../conf/{hive => es}/common.properties            |   6 +-
 inlong-sort-standalone/pom.xml                     |  26 +
 .../DefaultEvent2IndexRequestHandler.java          | 200 +++++++
 .../sink/elasticsearch/EsCallbackListener.java     | 119 ++++
 .../sink/elasticsearch/EsChannelWorker.java        | 118 ++++
 .../standalone/sink/elasticsearch/EsIdConfig.java  | 240 +++++++++
 .../sink/elasticsearch/EsIndexRequest.java         |  58 +-
 .../sink/elasticsearch/EsOutputChannel.java        | 226 ++++++++
 .../EsSink.java}                                   |  70 +--
 .../sink/elasticsearch/EsSinkContext.java          | 599 +++++++++++++++++++++
 .../sink/elasticsearch/EsSinkFactory.java          |  32 +-
 .../IEvent2IndexRequestHandler.java}               |  12 +-
 .../src/test/java/SortClusterConfig.conf           |  85 +++
 .../src/test/java}/common.properties               |  10 +-
 .../TestDefaultEvent2IndexRequestHandler.java      |  53 ++
 .../sink/elasticsearch/TestEsCallbackListener.java | 137 +++++
 .../sink/elasticsearch/TestEsChannelWorker.java    |  73 +++
 .../sink/elasticsearch/TestEsOutputChannel.java    | 124 +++++
 .../sink/elasticsearch/TestEsSinkContext.java      | 103 ++++
 .../source/sortsdk/TestSortSdkSource.java}         |   6 +-
 .../src/test/resources/SortClusterConfig.conf      |  85 +++
 .../src/test/resources}/common.properties          |  10 +-
 24 files changed, 2445 insertions(+), 105 deletions(-)
 create mode 100644 inlong-sort-standalone/conf/es/GetClusterConfig.json
 create mode 100644 inlong-sort-standalone/conf/es/GetSortSourceConfig.json
 copy inlong-sort-standalone/conf/{hive => es}/common.properties (88%)
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/DefaultEvent2IndexRequestHandler.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsCallbackListener.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsChannelWorker.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsIdConfig.java
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/pojo/CacheType.java => inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsIndexRequest.java (53%)
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsOutputChannel.java
 copy inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{pulsar/PulsarFederationSink.java => elasticsearch/EsSink.java} (51%)
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsSinkContext.java
 copy inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/DataProxyMetricItemSet.java => inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsSinkFactory.java (59%)
 copy inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{hive/IEventFormatHandler.java => elasticsearch/IEvent2IndexRequestHandler.java} (79%)
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/java/SortClusterConfig.conf
 copy inlong-sort-standalone/{conf/hive => sort-standalone-source/src/test/java}/common.properties (73%)
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/java/org/apache/inlong/sort/standalone/sink/elasticsearch/TestDefaultEvent2IndexRequestHandler.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/java/org/apache/inlong/sort/standalone/sink/elasticsearch/TestEsCallbackListener.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/java/org/apache/inlong/sort/standalone/sink/elasticsearch/TestEsChannelWorker.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/java/org/apache/inlong/sort/standalone/sink/elasticsearch/TestEsOutputChannel.java
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/java/org/apache/inlong/sort/standalone/sink/elasticsearch/TestEsSinkContext.java
 rename inlong-sort-standalone/sort-standalone-source/src/{main/test/org/apache/inlong/sort/standalone/source/sortsdk/SortSdkSourceTest.java => test/java/org/apache/inlong/sort/standalone/source/sortsdk/TestSortSdkSource.java} (96%)
 create mode 100644 inlong-sort-standalone/sort-standalone-source/src/test/resources/SortClusterConfig.conf
 copy inlong-sort-standalone/{conf/hive => sort-standalone-source/src/test/resources}/common.properties (73%)