aboutsummaryrefslogtreecommitdiffhomepage
path: root/tensorflow/contrib/kinesis
diff options
context:
space:
mode:
authorGravatar Jiri Simsa <jsimsa@google.com>2018-09-25 13:42:46 -0700
committerGravatar TensorFlower Gardener <gardener@tensorflow.org>2018-09-25 13:46:54 -0700
commit348478f642216cf3cbe1eb67b875252d8e6a6418 (patch)
treec4c7afd4283506b2c413e429cab02fc547e13481 /tensorflow/contrib/kinesis
parent976fb3105312bb17accebcbca2ebae906bcf99fb (diff)
[tf.data] Adding a private method for (recursively) tracking dataset inputs.
PiperOrigin-RevId: 214495925
Diffstat (limited to 'tensorflow/contrib/kinesis')
-rw-r--r--tensorflow/contrib/kinesis/python/ops/kinesis_dataset_ops.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/tensorflow/contrib/kinesis/python/ops/kinesis_dataset_ops.py b/tensorflow/contrib/kinesis/python/ops/kinesis_dataset_ops.py
index ca2df95ba4..75806dbbeb 100644
--- a/tensorflow/contrib/kinesis/python/ops/kinesis_dataset_ops.py
+++ b/tensorflow/contrib/kinesis/python/ops/kinesis_dataset_ops.py
@@ -17,15 +17,15 @@ from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
-from tensorflow.contrib.kinesis.python.ops import kinesis_op_loader # pylint: disable=unused-import
from tensorflow.contrib.kinesis.python.ops import gen_dataset_ops
-from tensorflow.python.data.ops.dataset_ops import Dataset
+from tensorflow.contrib.kinesis.python.ops import kinesis_op_loader # pylint: disable=unused-import
+from tensorflow.python.data.ops import dataset_ops
from tensorflow.python.framework import dtypes
from tensorflow.python.framework import ops
from tensorflow.python.framework import tensor_shape
-class KinesisDataset(Dataset):
+class KinesisDataset(dataset_ops.DatasetSource):
"""A Kinesis Dataset that consumes the message.
Kinesis is a managed service provided by AWS for data streaming.