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%)
