[beam] branch master updated (b80117e -> d2e03ed)

[ar...@apache.org]

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

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


    from b80117e  [BEAM-10871] Fix FhirLROIT tests (#12902)
     add d2e03ed  [BEAM-2546] Add InfluxDbIO (#11459)

No new revisions were added by this update.

Summary of changes:
 ...y => job_PerformanceTests_InfluxDBIO_IT.groovy} |  31 +-
 .../influxdb.yml}                                  |  73 ++-
 .../{hadoop/LargeITCluster => influxdb}/setup.sh   |   4 +-
 .../setup-cluster.sh => influxdb/teardown.sh}      |   7 +-
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 +
 sdks/java/io/influxdb/build.gradle                 |  36 ++
 .../beam/sdk/io/influxdb/DBShardInformation.java   |  62 ++
 .../apache/beam/sdk/io/influxdb/InfluxDbIO.java    | 675 +++++++++++++++++++++
 .../beam/sdk/io/influxdb/ShardInformation.java}    |  53 +-
 .../io/influxdb/ShardInformationByStartDate.java}  |  18 +-
 .../apache/beam/sdk/io/influxdb}/package-info.java |   6 +-
 .../apache/beam/sdk/io/influxdb/GenerateData.java  |  81 +++
 .../sdk/io/influxdb/InfluxDBPipelineOptions.java}  |  34 +-
 .../apache/beam/sdk/io/influxdb/InfluxDbIOIT.java  | 376 ++++++++++++
 .../beam/sdk/io/influxdb/InfluxDbIOTest.java       | 211 +++++++
 .../org/apache/beam/sdk/io/influxdb/Model.java     |  99 +++
 settings.gradle                                    |   1 +
 17 files changed, 1682 insertions(+), 87 deletions(-)
 copy .test-infra/jenkins/{job_PostCommit_Python_MongoDBIO_Load_Test.groovy => job_PerformanceTests_InfluxDBIO_IT.groovy} (65%)
 copy .test-infra/kubernetes/{postgres/postgres-service-for-local-dev.yml => influxdb/influxdb.yml} (51%)
 copy .test-infra/kubernetes/{hadoop/LargeITCluster => influxdb}/setup.sh (94%)
 copy .test-infra/kubernetes/{kafka-cluster/setup-cluster.sh => influxdb/teardown.sh} (94%)
 create mode 100644 sdks/java/io/influxdb/build.gradle
 create mode 100644 sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/DBShardInformation.java
 create mode 100644 sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/InfluxDbIO.java
 copy sdks/java/io/{jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/RowWithSchema.java => influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/ShardInformation.java} (50%)
 copy sdks/java/{core/src/main/java/org/apache/beam/sdk/transforms/SerializableComparator.java => io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/ShardInformationByStartDate.java} (65%)
 copy {runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options => sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb}/package-info.java (83%)
 create mode 100644 sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/GenerateData.java
 copy sdks/java/io/{google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/V1TestOptions.java => influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/InfluxDBPipelineOptions.java} (56%)
 create mode 100644 sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/InfluxDbIOIT.java
 create mode 100644 sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/InfluxDbIOTest.java
 create mode 100644 sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/Model.java