diff options
| author |  Michael Case <mikecase@google.com> | 2018-05-31 18:29:32 -0700 |
|---|---|---|
| committer | Michael Case <mikecase@google.com> | 2018-05-31 18:29:32 -0700 |
| commit | 7a9f1e6ec8ae53cd4321e819bd2343429a5ea9eb (patch) | |
| tree | 430e7ffc7d8157f2e0b4bb6d814e2eb0d375d31b /tensorflow/contrib/kafka | |
| parent | e365deab1333005c8aa186632f160c1bfd4485f8 (diff) | |
| parent | 2e272dbca6600991599e55a7ff7cfa668b8403aa (diff) | |
Merge commit for internal changes
Diffstat (limited to 'tensorflow/contrib/kafka')
| -rw-r--r-- | tensorflow/contrib/kafka/kernels/kafka_dataset_ops.cc | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tensorflow/contrib/kafka/kernels/kafka_dataset_ops.cc b/tensorflow/contrib/kafka/kernels/kafka_dataset_ops.cc index a4cd4a2cc4..2638b25ec4 100644 --- a/tensorflow/contrib/kafka/kernels/kafka_dataset_ops.cc +++ b/tensorflow/contrib/kafka/kernels/kafka_dataset_ops.cc @@ -64,7 +64,7 @@ class KafkaDatasetOp : public DatasetOpKernel { eof_(eof), timeout_(timeout) {} - std::unique_ptr<IteratorBase> MakeIterator( + std::unique_ptr<IteratorBase> MakeIteratorInternal( const string& prefix) const override { return std::unique_ptr<IteratorBase>( new Iterator({this, strings::StrCat(prefix, "::Kafka")})); @@ -81,7 +81,7 @@ class KafkaDatasetOp : public DatasetOpKernel { return *shapes; } - string DebugString() override { return "KafkaDatasetOp::Dataset"; } + string DebugString() const override { return "KafkaDatasetOp::Dataset"; } protected: Status AsGraphDefInternal(DatasetGraphDefBuilder* b, |