beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [9/9] beam git commit: This closes #1943
Date Wed, 01 Mar 2017 04:10:56 GMT
This closes #1943


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

Branch: refs/heads/master
Commit: d66029cafde152c0a46ebd276ddfa4c3e7fd3433
Parents: 63b63f0 9957c89
Author: Dan Halperin <dhalperi@google.com>
Authored: Tue Feb 28 20:10:39 2017 -0800
Committer: Dan Halperin <dhalperi@google.com>
Committed: Tue Feb 28 20:10:39 2017 -0800

----------------------------------------------------------------------
 .../beam/examples/complete/AutoComplete.java    |   2 +-
 .../translation/ApexPipelineTranslator.java     |   2 +-
 .../FlattenPCollectionTranslator.java           |   6 +-
 .../operators/ApexFlattenOperator.java          |   4 +-
 .../EmptyFlattenAsCreateFactory.java            |   7 +-
 .../core/construction/PTransformMatchers.java   |   8 +-
 .../construction/PTransformMatchersTest.java    |  16 +-
 .../beam/runners/direct/EmptyInputProvider.java |   4 +-
 .../runners/direct/FlattenEvaluatorFactory.java |   4 +-
 .../runners/direct/RootProviderRegistry.java    |   4 +-
 .../direct/TransformEvaluatorRegistry.java      |   4 +-
 .../direct/WriteWithShardingFactory.java        |   9 +-
 .../runners/direct/DirectGraphVisitorTest.java  |   4 +-
 .../direct/WriteWithShardingFactoryTest.java    |   2 +-
 .../flink/examples/streaming/AutoComplete.java  |   2 +-
 .../flink/FlinkBatchTransformTranslators.java   |   6 +-
 .../FlinkStreamingTransformTranslators.java     |  12 +-
 .../beam/runners/flink/WriteSinkITCase.java     |   2 +-
 .../dataflow/DataflowPipelineTranslator.java    |   8 +-
 .../beam/runners/dataflow/DataflowRunner.java   |  13 +-
 .../spark/translation/TransformTranslator.java  |   8 +-
 .../streaming/StreamingTransformTranslator.java |   8 +-
 .../translation/streaming/CreateStreamTest.java |   4 +-
 .../java/org/apache/beam/sdk/io/AvroIO.java     |   2 +-
 .../java/org/apache/beam/sdk/io/TextIO.java     |   2 +-
 .../main/java/org/apache/beam/sdk/io/Write.java | 727 +++++++++----------
 .../org/apache/beam/sdk/transforms/Combine.java |   9 +-
 .../org/apache/beam/sdk/transforms/Count.java   |  24 +-
 .../org/apache/beam/sdk/transforms/Flatten.java |  15 +-
 .../apache/beam/sdk/transforms/GroupByKey.java  |   8 +-
 .../org/apache/beam/sdk/transforms/Latest.java  |  80 +-
 .../org/apache/beam/sdk/transforms/Sample.java  | 121 ++-
 .../apache/beam/sdk/transforms/ToString.java    | 109 ++-
 .../java/org/apache/beam/sdk/io/WriteTest.java  |  16 +-
 .../beam/sdk/runners/TransformTreeTest.java     |  23 +-
 .../apache/beam/sdk/testing/TestStreamTest.java |   4 +-
 .../apache/beam/sdk/transforms/FlattenTest.java |  12 +-
 .../beam/sdk/transforms/GroupByKeyTest.java     |   2 +-
 .../apache/beam/sdk/transforms/SampleTest.java  |   2 +-
 .../beam/sdk/transforms/ToStringTest.java       |   8 +-
 .../sorter/BufferedExternalSorter.java          |  23 +-
 .../sorter/BufferedExternalSorterTest.java      |  46 +-
 .../sdk/extensions/sorter/SortValuesTest.java   |   2 +-
 43 files changed, 716 insertions(+), 658 deletions(-)
----------------------------------------------------------------------



Mime
View raw message