You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2022/10/11 13:37:13 UTC
[bahir-flink] branch BAHIR-308 updated (29a9d1d -> cc0f7b8)

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

eskabetxe pushed a change to branch BAHIR-308
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git


    from 29a9d1d  fix: fixed flink upgrade 1.15 causing the projectFields method to be incompatible
     add 7af5111  [BAHIR-308] InfluxDB changes
     add cc0f7b8  influxdb testing

No new revisions were added by this update.

Summary of changes:
 .../influxdb/sink/writer/InfluxDBWriter.java       |  13 +-
 .../connectors/influxdb/sink2/InfluxDBSink.java    |  45 +++++++
 .../{sink => sink2}/InfluxDBSinkBuilder.java       |  27 ++---
 .../{sink => sink2}/InfluxDBSinkOptions.java       |   2 +-
 .../writer/InfluxDBSchemaSerializer.java           |   5 +-
 .../influxdb/sink2/writer/InfluxDBWriter.java      | 133 +++++++++++++++++++++
 ....java => InfluxDBSink2IntegrationTestCase.java} |  32 ++---
 .../influxdb/InfluxDBSinkIntegrationTestCase.java  |   3 +
 ...erializer.java => InfluxDBTestSerializer2.java} |   6 +-
 pom.xml                                            |   2 +-
 10 files changed, 223 insertions(+), 45 deletions(-)
 create mode 100644 flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSink.java
 copy flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/{sink => sink2}/InfluxDBSinkBuilder.java (87%)
 copy flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/{sink => sink2}/InfluxDBSinkOptions.java (98%)
 copy flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/{sink => sink2}/writer/InfluxDBSchemaSerializer.java (90%)
 create mode 100644 flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer/InfluxDBWriter.java
 copy flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{InfluxDBSinkIntegrationTestCase.java => InfluxDBSink2IntegrationTestCase.java} (91%)
 copy flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/util/{InfluxDBTestSerializer.java => InfluxDBTestSerializer2.java} (83%)