This is an automated email from the ASF dual-hosted git repository. jkff pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 670941961845593d9a7e09b17c1bd117f27bf579 Merge: cd186a5 173208c Author: Eugene Kirpichov <[email protected]> AuthorDate: Tue Dec 19 07:43:10 2017 -0800 Merge pull request #3817 from jkff/fileio-write [BEAM-2865] Introduces FileIO.write() and uses it in AvroIO. .../main/java/org/apache/beam/sdk/io/AvroIO.java | 137 ++- .../apache/beam/sdk/io/DefaultFilenamePolicy.java | 2 +- .../java/org/apache/beam/sdk/io/FileBasedSink.java | 52 +- .../main/java/org/apache/beam/sdk/io/FileIO.java | 997 ++++++++++++++++++++- .../main/java/org/apache/beam/sdk/io/TextIO.java | 135 ++- .../java/org/apache/beam/sdk/io/WriteFiles.java | 11 +- .../apache/beam/sdk/transforms/Requirements.java | 10 + .../beam/sdk/transforms/SerializableFunctions.java | 20 +- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 275 ++++-- .../org/apache/beam/sdk/io/TextIOWriteTest.java | 67 +- .../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 2 +- .../org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 2 +- 12 files changed, 1556 insertions(+), 154 deletions(-) -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
