This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a change to branch api-draft
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 369bb0e89 [api-draft][flink] The FinkCommitter's commit info class
could not be inferred. (#2086)
add fc640b52b add assert sink to Api draft (#2071)
No new revisions were added by this update.
Summary of changes:
docs/en/connector/sink/Assert.md | 105 ++++++++++++++++++++
plugin-mapping.properties | 1 +
pom.xml | 6 ++
seatunnel-common/pom.xml | 4 +
seatunnel-connectors-v2-dist/pom.xml | 5 +
.../connector-assert}/pom.xml | 25 ++---
.../assertion/excecutor/AssertExecutor.java | 108 ++++++++++++++++++++
.../seatunnel/assertion/rule/AssertFieldRule.java | 65 ++++++++++++
.../seatunnel/assertion/rule/AssertRuleParser.java | 83 ++++++++++++++++
.../seatunnel/assertion/sink/AssertSink.java} | 42 ++++++--
.../assertion/sink/AssertSinkWriter.java} | 28 +++---
.../flink/assertion/AssertExecutorTest.java | 110 +++++++++++++++++++++
.../flink/assertion/rule/AssertRuleParserTest.java | 85 ++++++++++++++++
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/release-docs/LICENSE | 1 -
.../e2e/flink/assertion/FakeSourceToAssertIT.java} | 8 +-
.../resources/assertion/fakesource_to_assert.conf} | 42 +++++++-
tools/dependencies/known-dependencies.txt | 1 -
18 files changed, 669 insertions(+), 51 deletions(-)
create mode 100644 docs/en/connector/sink/Assert.md
copy
{seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-webhook
=> seatunnel-connectors-v2/connector-assert}/pom.xml (69%)
create mode 100644
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/excecutor/AssertExecutor.java
create mode 100644
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/rule/AssertFieldRule.java
create mode 100644
seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/rule/AssertRuleParser.java
copy
seatunnel-connectors-v2/{connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSink.java
=>
connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSink.java}
(56%)
copy
seatunnel-connectors-v2/{connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java
=>
connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSinkWriter.java}
(57%)
create mode 100644
seatunnel-connectors-v2/connector-assert/src/test/java/org/apache/seatunnel/flink/assertion/AssertExecutorTest.java
create mode 100644
seatunnel-connectors-v2/connector-assert/src/test/java/org/apache/seatunnel/flink/assertion/rule/AssertRuleParserTest.java
copy
seatunnel-e2e/{seatunnel-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/fake/FakeSourceToConsoleIT.java
=>
seatunnel-flink-new-connector-e2e/src/test/java/org/apache/seatunnel/e2e/flink/assertion/FakeSourceToAssertIT.java}
(82%)
copy
seatunnel-e2e/{seatunnel-flink-e2e/src/test/resources/file/fakesource_to_file.conf
=>
seatunnel-flink-new-connector-e2e/src/test/resources/assertion/fakesource_to_assert.conf}
(66%)
