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%)
