This closes #2852: Tighten up access and use internal annotations a bit in the Java SDK
Annotate internal methods on Pipeline Tighten access in sdk.options Annotate internal-only bits of Java sdk.runners The transforms.reflect package is not for users Tighten access control and internal annotations for triggers Annotate internal pieces of sdks.transforms Annotate internal methods of PCollection Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f43b61af Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f43b61af Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f43b61af Branch: refs/heads/master Commit: f43b61af4d5a3ee77a610d8b11ef80d421c34501 Parents: ff6bb35 362d0be Author: Kenneth Knowles <[email protected]> Authored: Thu May 4 06:10:45 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu May 4 06:10:45 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/sdk/Pipeline.java | 29 ++++++-- .../beam/sdk/options/ValueProviderUtils.java | 60 --------------- .../apache/beam/sdk/options/ValueProviders.java | 60 +++++++++++++++ .../beam/sdk/runners/PTransformMatcher.java | 6 +- .../beam/sdk/runners/PTransformOverride.java | 6 +- .../sdk/runners/PTransformOverrideFactory.java | 6 +- .../sdk/runners/PipelineRunnerRegistrar.java | 4 + .../beam/sdk/runners/TransformHierarchy.java | 6 +- .../beam/sdk/transforms/AppliedPTransform.java | 7 +- .../beam/sdk/transforms/CombineFnBase.java | 22 ++++-- .../beam/sdk/transforms/Materialization.java | 6 +- .../beam/sdk/transforms/Materializations.java | 11 ++- .../org/apache/beam/sdk/transforms/View.java | 36 ++++++--- .../org/apache/beam/sdk/transforms/ViewFn.java | 6 +- .../sdk/transforms/reflect/package-info.java | 5 +- .../beam/sdk/transforms/windowing/AfterAll.java | 4 +- .../sdk/transforms/windowing/AfterEach.java | 2 +- .../sdk/transforms/windowing/AfterFirst.java | 2 +- .../sdk/transforms/windowing/AfterPane.java | 2 +- .../windowing/AfterProcessingTime.java | 2 +- .../transforms/windowing/AfterWatermark.java | 4 +- .../transforms/windowing/DefaultTrigger.java | 2 +- .../beam/sdk/transforms/windowing/Never.java | 2 +- .../transforms/windowing/OrFinallyTrigger.java | 2 +- .../sdk/transforms/windowing/Repeatedly.java | 2 +- .../windowing/TimestampTransform.java | 41 ++++++++-- .../beam/sdk/transforms/windowing/Trigger.java | 18 ++++- .../org/apache/beam/sdk/values/PCollection.java | 16 ++-- .../beam/sdk/options/ValueProviderTest.java | 4 +- .../sdk/options/ValueProviderUtilsTest.java | 78 -------------------- .../beam/sdk/options/ValueProvidersTest.java | 78 ++++++++++++++++++++ 31 files changed, 321 insertions(+), 208 deletions(-) ----------------------------------------------------------------------
