You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/12/19 15:43:13 UTC
[beam] branch master updated (cd186a5 -> 6709419)
This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from cd186a5 Fix global match test in localfilesystem
add f7af9ae [BEAM-2865] Introduces FileIO.write() and adds support for it in AvroIO and TextIO
add 173208c Addresses comments
new 6709419 Merge pull request #3817 from jkff/fileio-write
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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
['"commits@beam.apache.org" <co...@beam.apache.org>'].
[beam] 01/01: Merge pull request #3817 from jkff/fileio-write
Posted by jk...@apache.org.
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 <ek...@gmail.com>
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
"commits@beam.apache.org" <co...@beam.apache.org>.