Repository: incubator-beam Updated Branches: refs/heads/master e953cb022 -> d5814a38d
Thank goodness for checkstyle! I almost committed a change which almost cirtainly would have resulting in global meltdown. Here's to you maven-checkstyle-plugin. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a441a262 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a441a262 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a441a262 Branch: refs/heads/master Commit: a441a26246de81656561b1647fdb7d8b1d508dff Parents: 62b6119 Author: Mark Shields <markshie...@google.com> Authored: Fri Apr 22 17:59:37 2016 -0700 Committer: Mark Shields <markshie...@google.com> Committed: Mon Apr 25 14:10:50 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/runners/dataflow/TestCountingSource.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a441a262/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSource.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSource.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSource.java index 010a19b..cc7b6e8 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSource.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSource.java @@ -155,6 +155,10 @@ public class TestCountingSource return dedup; } + /** + * Public only so that the checkpoint can be conveyed from {@link #getCheckpointMark()} to + * {@link TestCountingSource#createReader(PipelineOptions, CounterMark)} without cast. + */ public class CountingSourceReader extends UnboundedReader<KV<Integer, Integer>> { private int current;
