beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [beam] 13/13: This closes #4145: Many simplifications to WriteFiles
Date Wed, 06 Dec 2017 00:30:00 GMT
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 761ec1af410f0ee153893f6e7082db85d0fdc3e7
Merge: b059664 d314339
Author: Eugene Kirpichov <kirpichov@google.com>
AuthorDate: Tue Dec 5 16:27:17 2017 -0800

    This closes #4145: Many simplifications to WriteFiles

 .../apache/beam/examples/WindowedWordCount.java    |    5 +-
 .../examples/common/WriteOneFilePerWindow.java     |   12 +-
 .../apache/beam/examples/WindowedWordCountIT.java  |    8 +
 .../beam/runners/apex/examples/WordCountTest.java  |    2 +-
 .../core/construction/WriteFilesTranslation.java   |    7 +-
 .../construction/WriteFilesTranslationTest.java    |   13 +-
 .../beam/runners/dataflow/DataflowRunnerTest.java  |    2 +-
 .../beam/runners/spark/io/AvroPipelineTest.java    |    5 +-
 .../java/org/apache/beam/sdk/io/FileBasedSink.java |  281 +++---
 .../java/org/apache/beam/sdk/io/WriteFiles.java    | 1061 ++++++++------------
 .../java/org/apache/beam/sdk/transforms/Reify.java |   73 +-
 .../apache/beam/sdk/values/TypeDescriptors.java    |    4 +
 .../org/apache/beam/sdk/io/FileBasedSinkTest.java  |   66 +-
 .../org/apache/beam/sdk/io/WriteFilesTest.java     |   27 +-
 14 files changed, 745 insertions(+), 821 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <commits@beam.apache.org>.

Mime
View raw message