beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [1/2] incubator-beam git commit: Add experimental warning to datastoreio
Date Mon, 05 Dec 2016 19:39:22 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/python-sdk 0d99856f3 -> f7118c8a5


Add experimental warning to datastoreio


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

Branch: refs/heads/python-sdk
Commit: f3dcf6c2dd32e17998d9e185a326fb725abccf31
Parents: 0d99856
Author: Vikas Kedigehalli <vikasrk@google.com>
Authored: Mon Dec 5 11:23:53 2016 -0800
Committer: Vikas Kedigehalli <vikasrk@google.com>
Committed: Mon Dec 5 11:28:52 2016 -0800

----------------------------------------------------------------------
 sdks/python/apache_beam/io/datastore/v1/datastoreio.py | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f3dcf6c2/sdks/python/apache_beam/io/datastore/v1/datastoreio.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/datastore/v1/datastoreio.py b/sdks/python/apache_beam/io/datastore/v1/datastoreio.py
index 20466b9..fc3e813 100644
--- a/sdks/python/apache_beam/io/datastore/v1/datastoreio.py
+++ b/sdks/python/apache_beam/io/datastore/v1/datastoreio.py
@@ -86,6 +86,7 @@ class ReadFromDatastore(PTransform):
       namespace: An optional namespace.
       num_splits: Number of splits for the query.
     """
+    logging.warning('datastoreio read transform is experimental.')
     super(ReadFromDatastore, self).__init__()
 
     if not project:
@@ -309,6 +310,7 @@ class _Mutate(PTransform):
      """
     self._project = project
     self._mutation_fn = mutation_fn
+    logging.warning('datastoreio write transform is experimental.')
 
   def apply(self, pcoll):
     return (pcoll


Mime
View raw message