You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by di...@apache.org on 2022/06/29 07:18:40 UTC

[flink] branch master updated (e7e120acf92 -> 78c30cad695)

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

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


    from e7e120acf92 [FLINK-28092][table] Support ASCII and CHR built-in function in the Table API
     add 78c30cad695 [FLINK-27964][python] Support Cassandra connector in Python DataStream API

No new revisions were added by this update.

Summary of changes:
 .../connectors/cassandra/SimpleMapperOptions.java  | 121 +++++++
 .../pyflink/datastream/connectors/__init__.py      |   4 +-
 .../pyflink/datastream/connectors/cassandra.py     | 366 +++++++++++++++++++++
 .../pyflink/datastream/tests/test_connectors.py    |  33 ++
 4 files changed, 523 insertions(+), 1 deletion(-)
 create mode 100644 flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/SimpleMapperOptions.java
 create mode 100644 flink-python/pyflink/datastream/connectors/cassandra.py