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

Posted to commits@beam.apache.org by ch...@apache.org on 2019/01/07 16:08:53 UTC

[beam] 01/01: Merge pull request #7006: [BEAM-5964] Add ClickHouseIO.Write

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

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

commit 054b88c36461485141ac8fa3737d6eb0c4351145
Merge: ac18fac 3bdd48a
Author: Chamikara Jayalath <ch...@google.com>
AuthorDate: Mon Jan 7 08:08:43 2019 -0800

    Merge pull request #7006: [BEAM-5964] Add ClickHouseIO.Write

 .../src/main/resources/beam/findbugs-filter.xml    |   7 +
 sdks/java/io/clickhouse/OWNERS                     |   4 +
 sdks/java/io/clickhouse/build.gradle               |  49 ++
 .../beam/sdk/io/clickhouse/ClickHouseIO.java       | 516 +++++++++++++++++++++
 .../beam/sdk/io/clickhouse/ClickHouseWriter.java   | 134 ++++++
 .../apache/beam/sdk/io/clickhouse/TableSchema.java | 297 ++++++++++++
 .../beam/sdk/io/clickhouse/package-info.java       |  23 +
 .../clickhouse/src/main/javacc/ColumnTypeParser.jj | 190 ++++++++
 .../beam/sdk/io/clickhouse/AtomicInsertTest.java   | 165 +++++++
 .../beam/sdk/io/clickhouse/BaseClickHouseTest.java | 100 ++++
 .../beam/sdk/io/clickhouse/ClickHouseIOTest.java   | 361 ++++++++++++++
 .../beam/sdk/io/clickhouse/TableSchemaTest.java    | 144 ++++++
 .../test/resources/config.d/zookeeper_default.xml  |  23 +
 settings.gradle                                    |   2 +
 14 files changed, 2015 insertions(+)