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 <dhalp...@google.com> Authored: Fri Oct 7 09:50:20 2016 -0700 Committer: Dan Halperin <dhalp...@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(-) ----------------------------------------------------------------------