Repository: beam Updated Branches: refs/heads/release-2.0.0 7b598f878 -> 6083b47d0
[BEAM-1345] internal comments Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7573ec10 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7573ec10 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7573ec10 Branch: refs/heads/release-2.0.0 Commit: 7573ec10c31742519e98ccbc2d4d4de1f05013bb Parents: 7b598f8 Author: Ahmet Altay <[email protected]> Authored: Fri May 12 14:54:33 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Fri May 12 15:24:35 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/internal/pickler.py | 2 ++ sdks/python/apache_beam/internal/util.py | 5 ++++- sdks/python/apache_beam/transforms/trigger.py | 6 +++++- 3 files changed, 11 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/7573ec10/sdks/python/apache_beam/internal/pickler.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/internal/pickler.py b/sdks/python/apache_beam/internal/pickler.py index 4305379..e049a71 100644 --- a/sdks/python/apache_beam/internal/pickler.py +++ b/sdks/python/apache_beam/internal/pickler.py @@ -17,6 +17,8 @@ """Pickler for values, functions, and classes. +For internal use only. No backwards compatibility guarantees. + Pickles created by the pickling library contain non-ASCII characters, so we base64-encode the results so that we can put them in a JSON objects. The pickler is used to embed FlatMap callable objects into the workflow JSON http://git-wip-us.apache.org/repos/asf/beam/blob/7573ec10/sdks/python/apache_beam/internal/util.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/internal/util.py b/sdks/python/apache_beam/internal/util.py index df4878c..dbbeafc 100644 --- a/sdks/python/apache_beam/internal/util.py +++ b/sdks/python/apache_beam/internal/util.py @@ -15,7 +15,10 @@ # limitations under the License. # -"""Utility functions used throughout the package.""" +"""Utility functions used throughout the package. + +For internal use only. No backwards compatibility guarantees. +""" import logging from multiprocessing.pool import ThreadPool http://git-wip-us.apache.org/repos/asf/beam/blob/7573ec10/sdks/python/apache_beam/transforms/trigger.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/transforms/trigger.py b/sdks/python/apache_beam/transforms/trigger.py index 7de2f85..4200995 100644 --- a/sdks/python/apache_beam/transforms/trigger.py +++ b/sdks/python/apache_beam/transforms/trigger.py @@ -37,6 +37,7 @@ from apache_beam.runners.api import beam_runner_api_pb2 from apache_beam.utils.timestamp import MAX_TIMESTAMP from apache_beam.utils.timestamp import MIN_TIMESTAMP +# AfterCount is experimental. No backwards compatibility guarantees. __all__ = [ 'AccumulationMode', @@ -367,7 +368,10 @@ class AfterWatermark(TriggerFn): class AfterCount(TriggerFn): - """Fire when there are at least count elements in this window pane.""" + """Fire when there are at least count elements in this window pane. + + AfterCount is experimental. No backwards compatibility guarantees. + """ COUNT_TAG = _CombiningValueStateTag('count', combiners.CountCombineFn())
