This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 3e8afd7ce1 [INLONG-10907][Manager] Support reinstalling the installer
(#10909)
add 8be8834a78 [INLONG-10831][Sort] SortStandalone support HTTP sink
(#10837)
No new revisions were added by this update.
Summary of changes:
.../sink/http/DefaultEvent2HttpRequestHandler.java | 140 +++++++
.../sort/standalone/sink/http/HttpCallback.java | 80 ++++
.../HttpChannelWorker.java} | 72 +---
.../ClsIdConfig.java => http/HttpIdConfig.java} | 62 ++--
.../standalone/sink/http/HttpOutputChannel.java | 146 ++++++++
.../EsIndexRequest.java => http/HttpRequest.java} | 44 +--
.../EsSink.java => http/HttpSink.java} | 49 +--
.../sort/standalone/sink/http/HttpSinkContext.java | 404 +++++++++++++++++++++
.../sort/standalone/sink/http/HttpSinkFactory.java | 23 +-
.../IEvent2HttpRequestHandler.java} | 21 +-
10 files changed, 877 insertions(+), 164 deletions(-)
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/http/DefaultEvent2HttpRequestHandler.java
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/http/HttpCallback.java
copy
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{elasticsearch/EsChannelWorker.java
=> http/HttpChannelWorker.java} (56%)
copy
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{cls/ClsIdConfig.java
=> http/HttpIdConfig.java} (50%)
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/http/HttpOutputChannel.java
copy
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{elasticsearch/EsIndexRequest.java
=> http/HttpRequest.java} (63%)
copy
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{elasticsearch/EsSink.java
=> http/HttpSink.java} (66%)
create mode 100644
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/http/HttpSinkContext.java
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/IntListValuable.java
=>
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/http/HttpSinkFactory.java
(64%)
copy
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/{hive/IEventFormatHandler.java
=> http/IEvent2HttpRequestHandler.java} (73%)
