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/05/02 19:23:25 UTC
[7/7] beam git commit: This closes #2774
This closes #2774
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3161904d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3161904d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3161904d
Branch: refs/heads/master
Commit: 3161904d97e9eb4ec6eb354fb54d8d0e4e5733eb
Parents: c2c89ed 7b725c2
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue May 2 12:20:24 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue May 2 12:20:24 2017 -0700
----------------------------------------------------------------------
.../beam/examples/DebuggingWordCount.java | 2 +-
.../apache/beam/examples/MinimalWordCount.java | 4 +-
.../apache/beam/examples/WindowedWordCount.java | 2 +-
.../org/apache/beam/examples/WordCount.java | 4 +-
.../examples/common/WriteOneFilePerWindow.java | 2 +-
.../beam/examples/complete/AutoComplete.java | 2 +-
.../examples/complete/StreamingWordExtract.java | 2 +-
.../apache/beam/examples/complete/TfIdf.java | 4 +-
.../examples/complete/TopWikipediaSessions.java | 4 +-
.../examples/complete/TrafficMaxLaneFlow.java | 2 +-
.../beam/examples/complete/TrafficRoutes.java | 2 +-
.../beam/examples/cookbook/DistinctExample.java | 4 +-
.../beam/examples/cookbook/JoinExamples.java | 2 +-
.../beam/examples/cookbook/TriggerExample.java | 2 +-
.../beam/examples/MinimalWordCountJava8.java | 4 +-
.../examples/complete/game/HourlyTeamScore.java | 2 +-
.../beam/examples/complete/game/UserScore.java | 2 +-
.../examples/MinimalWordCountJava8Test.java | 4 +-
.../runners/apex/examples/WordCountTest.java | 4 +-
.../direct/WriteWithShardingFactoryTest.java | 2 +-
.../beam/runners/flink/ReadSourceITCase.java | 2 +-
.../flink/ReadSourceStreamingITCase.java | 2 +-
.../flink/streaming/GroupByNullKeyTest.java | 2 +-
.../streaming/TopWikipediaSessionsITCase.java | 2 +-
.../DataflowPipelineTranslatorTest.java | 16 +-
.../runners/dataflow/DataflowRunnerTest.java | 23 +-
.../beam/runners/spark/examples/WordCount.java | 4 +-
.../runners/spark/SparkRunnerDebuggerTest.java | 4 +-
.../beam/runners/spark/io/NumShardsTest.java | 3 +-
.../main/java/org/apache/beam/sdk/Pipeline.java | 6 +-
.../apache/beam/sdk/io/ShardNameTemplate.java | 2 +-
.../java/org/apache/beam/sdk/io/TextIO.java | 1159 +++++-------------
.../java/org/apache/beam/sdk/io/TextSink.java | 139 +++
.../java/org/apache/beam/sdk/io/TextSource.java | 236 ++++
.../org/apache/beam/sdk/io/package-info.java | 2 +-
.../java/org/apache/beam/sdk/io/TextIOTest.java | 61 +-
.../beam/sdk/runners/TransformTreeTest.java | 6 +-
.../display/DisplayDataEvaluatorTest.java | 5 +-
.../sdk/transforms/windowing/WindowingTest.java | 2 +-
.../org/apache/beam/sdk/util/NameUtilsTest.java | 2 +-
.../org/apache/beam/sdk/values/PDoneTest.java | 2 +-
.../beam/sdk/io/hdfs/HadoopFileSystemTest.java | 3 +-
42 files changed, 753 insertions(+), 986 deletions(-)
----------------------------------------------------------------------