beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [2/2] beam git commit: This closes #3573: [BEAM-2624] Allow access to created filenames from WriteFiles
Date Fri, 01 Sep 2017 20:33:37 GMT
This closes #3573: [BEAM-2624] Allow access to created filenames from WriteFiles


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7d538787
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7d538787
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7d538787

Branch: refs/heads/master
Commit: 7d53878768757ef2115170a5073b99956e924ff2
Parents: b844126 73535da
Author: Eugene Kirpichov <ekirpichov@gmail.com>
Authored: Fri Sep 1 13:18:08 2017 -0700
Committer: Eugene Kirpichov <ekirpichov@gmail.com>
Committed: Fri Sep 1 13:18:08 2017 -0700

----------------------------------------------------------------------
 .../construction/WriteFilesTranslation.java     |  36 +++--
 .../construction/PTransformMatchersTest.java    |  15 +-
 .../construction/WriteFilesTranslationTest.java |   8 +-
 .../direct/WriteWithShardingFactory.java        |  26 ++--
 .../direct/WriteWithShardingFactoryTest.java    |  11 +-
 .../beam/runners/dataflow/DataflowRunner.java   |  17 ++-
 .../runners/dataflow/DataflowRunnerTest.java    |   4 +-
 .../java/org/apache/beam/sdk/io/AvroIO.java     | 145 ++++++++++--------
 .../org/apache/beam/sdk/io/FileBasedSink.java   |   8 +-
 .../java/org/apache/beam/sdk/io/TFRecordIO.java |   3 +-
 .../java/org/apache/beam/sdk/io/TextIO.java     | 148 +++++++++++--------
 .../java/org/apache/beam/sdk/io/WriteFiles.java | 115 ++++++++------
 .../apache/beam/sdk/io/WriteFilesResult.java    |  81 ++++++++++
 .../java/org/apache/beam/sdk/io/AvroIOTest.java |   2 +-
 .../apache/beam/sdk/io/FileBasedSinkTest.java   |   2 +-
 .../org/apache/beam/sdk/io/TextIOWriteTest.java |  40 ++++-
 .../java/org/apache/beam/sdk/io/xml/XmlIO.java  |   3 +-
 17 files changed, 438 insertions(+), 226 deletions(-)
----------------------------------------------------------------------



Mime
View raw message