You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2020/04/05 19:32:54 UTC
[pulsar] branch master updated (1aad3b7 -> 2166003)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 1aad3b7 ISSUE-6612 FIX: parse long field in GenricJsonRecord (#6612) (#6622)
add 2166003 ISSUE-6514 Add support for influxdb2 in pulsar-influxdb-sink(#6514) (#6601)
No new revisions were added by this update.
Summary of changes:
pulsar-io/influxdb/pom.xml | 14 ++
.../org/apache/pulsar/io/influxdb/BatchSink.java | 129 ++++++++++++++
.../pulsar/io/influxdb/InfluxDBAbstractSink.java | 156 -----------------
.../io/influxdb/InfluxDBGenericRecordSink.java | 105 ++++-------
.../io/influxdb/v1/InfluxDBAbstractSink.java | 89 ++++++++++
.../io/influxdb/{ => v1}/InfluxDBBuilder.java | 2 +-
.../io/influxdb/{ => v1}/InfluxDBBuilderImpl.java | 2 +-
.../{ => v1}/InfluxDBGenericRecordSink.java | 49 ++----
.../io/influxdb/{ => v1}/InfluxDBSinkConfig.java | 2 +-
.../io/influxdb/v2/InfluxDBClientBuilder.java | 14 +-
.../io/influxdb/v2/InfluxDBClientBuilderImpl.java | 47 +++++
.../apache/pulsar/io/influxdb/v2/InfluxDBSink.java | 153 ++++++++++++++++
.../io/influxdb/{ => v2}/InfluxDBSinkConfig.java | 84 +++++----
.../io/influxdb/InfluxDBGenericRecordSinkTest.java | 166 +++++-------------
.../{ => v1}/InfluxDBGenericRecordSinkTest.java | 7 +-
.../influxdb/{ => v1}/InfluxDBSinkConfigTest.java | 4 +-
.../io/influxdb/v2/InfluxDBSinkConfigTest.java | 103 +++++++++++
.../pulsar/io/influxdb/v2/InfluxDBSinkTest.java | 193 +++++++++++++++++++++
.../{sinkConfig.yaml => sinkConfig-v1.yaml} | 0
.../{sinkConfig.yaml => sinkConfig-v2.yaml} | 17 +-
site2/docs/io-influxdb-sink.md | 50 +++++-
21 files changed, 926 insertions(+), 460 deletions(-)
create mode 100644 pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/BatchSink.java
delete mode 100644 pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBAbstractSink.java
create mode 100644 pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBAbstractSink.java
rename pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/{ => v1}/InfluxDBBuilder.java (95%)
rename pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/{ => v1}/InfluxDBBuilderImpl.java (98%)
copy pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/{ => v1}/InfluxDBGenericRecordSink.java (65%)
copy pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/{ => v1}/InfluxDBSinkConfig.java (98%)
copy pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/AvroTestObject.java => pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBClientBuilder.java (81%)
create mode 100644 pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBClientBuilderImpl.java
create mode 100644 pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSink.java
rename pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/{ => v2}/InfluxDBSinkConfig.java (58%)
copy pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/{ => v1}/InfluxDBGenericRecordSinkTest.java (95%)
rename pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/{ => v1}/InfluxDBSinkConfigTest.java (98%)
create mode 100644 pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfigTest.java
create mode 100644 pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkTest.java
copy pulsar-io/influxdb/src/test/resources/{sinkConfig.yaml => sinkConfig-v1.yaml} (100%)
rename pulsar-io/influxdb/src/test/resources/{sinkConfig.yaml => sinkConfig-v2.yaml} (77%)