You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by zo...@apache.org on 2022/09/23 02:25:59 UTC
[incubator-seatunnel] branch dev updated (4aacbcdd1 -> 5b3957bc5)

This is an automated email from the ASF dual-hosted git repository.

zongwen pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from 4aacbcdd1 [Imporve][Connector-V2] Refactor ftp sink & Add ftp file source (#2774)
     add 5b3957bc5 [Improve][Connector-V2] Improve http connector (#2833)

No new revisions were added by this update.

Summary of changes:
 docs/en/connector-v2/sink/Http.md                  |  31 ++-
 docs/en/connector-v2/source/Http.md                |  46 +++--
 .../connector-http/connector-http-base/pom.xml     |  32 +---
 .../seatunnel/http/client/HttpClientProvider.java  |  53 ++++--
 .../seatunnel/http/config/HttpConfig.java          |   4 +
 .../seatunnel/http/config/HttpParameter.java       |  18 ++
 .../seatunnel/http/sink/HttpSinkWriter.java        |   3 +-
 .../http/source/DeserializationCollector.java      |  60 ++++++
 .../seatunnel/http/source/HttpSource.java          |  24 ++-
 .../seatunnel/http/source/HttpSourceReader.java    |  18 +-
 .../source/SimpleTextDeserializationSchema.java}   |  22 ++-
 .../seatunnel-flink-connector-v2-example/pom.xml   |  11 ++
 .../example/flink/v2/HttpConnectorExample.java     | 210 +++++++++++++++++++++
 .../resources/examples/http_source_to_sink.conf    |  24 +--
 .../format/json/JsonDeserializationSchema.java     |  21 ++-
 .../format/json/JsonSerializationSchema.java       |   4 +-
 .../seatunnel/format/json/JsonToRowConverters.java |  40 +++-
 17 files changed, 522 insertions(+), 99 deletions(-)
 create mode 100644 seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/DeserializationCollector.java
 copy seatunnel-connectors-v2/{connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbJdbcRowConverter.java => connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/SimpleTextDeserializationSchema.java} (62%)
 create mode 100644 seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/HttpConnectorExample.java
 copy seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-mongodb-flink-e2e/src/test/resources/mongodb/mongodb_source_and_sink.conf => seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/resources/examples/http_source_to_sink.conf (75%)