You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/04/13 02:36:04 UTC

[2/2] incubator-beam git commit: This closes #163

This closes #163


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b640ba88
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b640ba88
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b640ba88

Branch: refs/heads/master
Commit: b640ba88c65fb9aa011c64759653edef7351662c
Parents: 46c82ac 61f8dfd
Author: Davor Bonaci <da...@google.com>
Authored: Tue Apr 12 17:23:36 2016 -0700
Committer: Davor Bonaci <da...@google.com>
Committed: Tue Apr 12 17:23:36 2016 -0700

----------------------------------------------------------------------
 .../sdk/options/CloudDebuggerOptions.java       |  3 +-
 .../options/DataflowPipelineDebugOptions.java   |  3 +-
 .../DataflowPipelineWorkerPoolOptions.java      |  2 +-
 .../sdk/options/DataflowProfilingOptions.java   |  2 +-
 .../runners/BlockingDataflowPipelineRunner.java |  3 +-
 .../sdk/runners/DataflowPipelineRunner.java     |  3 +-
 .../runners/DataflowPipelineRunnerHooks.java    |  3 +-
 sdks/java/checkstyle.xml                        |  2 +-
 .../dataflow/sdk/annotations/Experimental.java  | 81 --------------------
 .../dataflow/sdk/annotations/package-info.java  | 21 -----
 .../google/cloud/dataflow/sdk/coders/Coder.java |  4 +-
 .../cloud/dataflow/sdk/io/AvroSource.java       |  2 +-
 .../cloud/dataflow/sdk/io/BlockBasedSource.java |  2 +-
 .../cloud/dataflow/sdk/io/BoundedSource.java    |  2 +-
 .../cloud/dataflow/sdk/io/CompressedSource.java |  2 +-
 .../cloud/dataflow/sdk/io/DatastoreIO.java      |  3 +-
 .../com/google/cloud/dataflow/sdk/io/Sink.java  |  2 +-
 .../google/cloud/dataflow/sdk/io/Source.java    |  2 +-
 .../cloud/dataflow/sdk/io/UnboundedSource.java  |  2 +-
 .../com/google/cloud/dataflow/sdk/io/Write.java |  3 +-
 .../dataflow/sdk/io/bigtable/BigtableIO.java    |  3 +-
 .../inprocess/InProcessPipelineRunner.java      |  3 +-
 .../cloud/dataflow/sdk/transforms/DoFn.java     |  4 +-
 .../dataflow/sdk/transforms/DoFnTester.java     |  2 +-
 .../sdk/transforms/DoFnWithContext.java         |  2 +-
 .../cloud/dataflow/sdk/transforms/ParDo.java    |  3 +-
 .../sdk/transforms/windowing/AfterAll.java      |  2 +-
 .../windowing/AfterDelayFromFirstElement.java   |  2 +-
 .../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    |  2 +-
 .../transforms/windowing/DefaultTrigger.java    |  2 +-
 .../sdk/transforms/windowing/OutputTimeFn.java  |  2 +-
 .../sdk/transforms/windowing/OutputTimeFns.java |  2 +-
 .../sdk/transforms/windowing/Sessions.java      |  4 +-
 .../transforms/windowing/SlidingWindows.java    |  4 +-
 .../sdk/transforms/windowing/Trigger.java       |  2 +-
 .../sdk/transforms/windowing/Window.java        |  4 +-
 .../sdk/transforms/windowing/WindowFn.java      |  4 +-
 .../google/cloud/dataflow/sdk/util/Timers.java  |  2 +-
 .../dataflow/sdk/util/WindowingStrategy.java    |  2 +-
 .../sdk/util/state/InMemoryStateInternals.java  |  4 +-
 .../sdk/util/state/MergingStateAccessor.java    |  4 +-
 .../dataflow/sdk/util/state/ReadableState.java  |  4 +-
 .../dataflow/sdk/util/state/StateAccessor.java  |  4 +-
 .../dataflow/sdk/util/state/StateInternals.java |  4 +-
 .../cloud/dataflow/sdk/util/state/StateTag.java |  4 +-
 .../dataflow/sdk/util/state/StateTags.java      |  4 +-
 .../dataflow/sdk/util/state/ValueState.java     |  4 +-
 .../sdk/util/state/WatermarkHoldState.java      |  4 +-
 .../beam/sdk/annotations/Experimental.java      | 81 ++++++++++++++++++++
 .../beam/sdk/annotations/package-info.java      | 21 +++++
 .../java/javadoc/dataflow-sdk-docs/package-list |  2 +-
 sdks/java/javadoc/overview.html                 |  2 +-
 56 files changed, 179 insertions(+), 169 deletions(-)
----------------------------------------------------------------------