You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/03/01 04:10:56 UTC
[9/9] beam git commit: This closes #1943
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 <dh...@google.com>
Authored: Tue Feb 28 20:10:39 2017 -0800
Committer: Dan Halperin <dh...@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(-)
----------------------------------------------------------------------