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 2016/10/07 16:53:39 UTC
[2/2] incubator-beam git commit: Closes #1028
Closes #1028
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2492604e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2492604e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2492604e
Branch: refs/heads/master
Commit: 2492604e4becac4dde67b84083be68d2d509da2e
Parents: 03b89c0 e3e6fe3
Author: Dan Halperin <dh...@google.com>
Authored: Fri Oct 7 09:50:20 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Fri Oct 7 09:50:20 2016 -0700
----------------------------------------------------------------------
.../beam/runners/direct/DirectRunner.java | 1 +
.../direct/ImmutableListBundleFactory.java | 2 +-
.../beam/runners/direct/ParDoEvaluator.java | 7 +-
.../beam/runners/direct/StructuralKey.java | 2 +-
.../direct/TestStreamEvaluatorFactory.java | 4 +-
.../beam/runners/direct/WatermarkManager.java | 2 +-
.../beam/runners/dataflow/DataflowRunner.java | 26 ++-----
.../runners/dataflow/internal/IsmFormat.java | 5 +-
.../beam/sdk/io/PubsubUnboundedSource.java | 2 +-
.../beam/sdk/options/PipelineOptions.java | 9 ++-
.../org/apache/beam/sdk/testing/TestStream.java | 2 +-
.../beam/sdk/transforms/DoFnAdapters.java | 3 +-
.../sdk/transforms/reflect/DoFnInvokers.java | 8 +-
.../sdk/transforms/reflect/DoFnSignature.java | 4 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 11 ++-
.../beam/sdk/coders/CoderRegistryTest.java | 1 +
.../sdk/options/PipelineOptionsFactoryTest.java | 6 +-
.../beam/sdk/testing/TestPipelineTest.java | 4 +-
.../apache/beam/sdk/transforms/CombineTest.java | 77 ++++++++------------
.../apache/beam/sdk/transforms/ParDoTest.java | 4 +-
.../display/DisplayDataEvaluator.java | 6 +-
.../transforms/reflect/DoFnInvokersTest.java | 2 +-
.../beam/sdk/io/hdfs/AvroHDFSFileSource.java | 2 +-
.../beam/sdk/io/hdfs/AvroWrapperCoder.java | 2 +-
.../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 7 +-
.../simpleauth/SimpleAuthHDFSFileSource.java | 5 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 3 +-
.../beam/sdk/io/kinesis/CustomOptional.java | 5 +-
28 files changed, 93 insertions(+), 119 deletions(-)
----------------------------------------------------------------------