You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/06/08 08:12:39 UTC
[flink] branch master updated (98d4cd659bc -> 5b6394b8071)

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

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 98d4cd659bc [FLINK-27902][network] remove useless isPipelined, isBlocking and isReconnectable in ResultPartitionType.
     add 5b6394b8071 [FLINK-27457][cassandra] Implement flush() logic in output formats

No new revisions were added by this update.

Summary of changes:
 .../CassandraColumnarOutputFormatBase.java         |  66 +++++
 .../cassandra/CassandraOutputFormatBase.java       | 115 ++------
 .../cassandra/CassandraPojoOutputFormat.java       | 102 ++-----
 .../cassandra/CassandraRowOutputFormat.java        |  14 +-
 .../cassandra/CassandraTupleOutputFormat.java      |  15 +-
 .../connectors/cassandra/OutputFormatBase.java     | 140 +++++++++
 .../connectors/cassandra/utils/SinkUtils.java      |  55 ++++
 .../connectors/cassandra/CassandraSinkBase.java    |  16 +-
 .../connectors/cassandra/OutputFormatBaseTest.java | 319 +++++++++++++++++++++
 .../cassandra/utils}/ResultSetFutures.java         |  21 +-
 .../cassandra/CassandraSinkBaseTest.java           |   1 +
 .../apache/flink/api/common/io/OutputFormat.java   |   2 +-
 tools/maven/suppressions.xml                       |   2 +-
 13 files changed, 677 insertions(+), 191 deletions(-)
 create mode 100644 flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraColumnarOutputFormatBase.java
 create mode 100644 flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/OutputFormatBase.java
 create mode 100644 flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/connectors/cassandra/utils/SinkUtils.java
 create mode 100644 flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/OutputFormatBaseTest.java
 rename flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/{streaming/connectors/cassandra => connectors/cassandra/utils}/ResultSetFutures.java (81%)