提交 0c20b514 编写于 作者: J Jiri Simsa 提交者: TensorFlower Gardener

[tf.data] Enforcing usage of the tensorflow::data namespace for tf.data C++ classes.

PiperOrigin-RevId: 328141067
Change-Id: I154c55c9b1cc47ec069bfc663a1d3fb0f135e67d
上级 d88e5532
......@@ -1188,20 +1188,6 @@ class DatasetOpRegistrar {
registrar__body__##ctr##__object(op_name)
} // namespace data
// TODO(b/114112161): Remove these aliases when all users have moved over to the
// `tensorflow::data` namespace.
using data::DatasetBase;
using data::DatasetContext;
using data::DatasetIterator;
using data::DatasetOpKernel;
using data::IteratorBase;
using data::IteratorContext;
using data::IteratorStateReader;
using data::IteratorStateWriter;
using data::SerializationContext;
using data::UnaryDatasetOpKernel;
} // namespace tensorflow
#endif // TENSORFLOW_CORE_FRAMEWORK_DATASET_H_
......@@ -264,11 +264,6 @@ class InstantiatedCapturedFunction {
};
} // namespace data
// TODO(b/114112161): Remove these aliases when all users have moved over to the
// `tensorflow::data` namespace.
using data::CapturedFunction;
} // namespace tensorflow
#endif // TENSORFLOW_CORE_KERNELS_DATA_CAPTURED_FUNCTION_H_
......@@ -175,7 +175,7 @@ class InitializeTableFromDatasetOp : public AsyncOpKernel {
OP_REQUIRES_OK_ASYNC(
ctx, GetInitializableLookupTable("table_handle", ctx, &table), done);
core::ScopedUnref unref_me(table);
DatasetBase* dataset;
data::DatasetBase* dataset;
OP_REQUIRES_OK_ASYNC(
ctx, GetDatasetFromVariantTensor(ctx->input(1), &dataset), done);
background_worker_.Schedule([ctx, dataset, table, done]() {
......
......@@ -396,12 +396,12 @@ Status InitializeTableFromTextFile(const string& filename, int64 vocab_size,
class DatasetIterator : public InitializableLookupTable::InitTableIterator {
public:
explicit DatasetIterator(DatasetBase* dataset) : dataset_(dataset) {}
explicit DatasetIterator(data::DatasetBase* dataset) : dataset_(dataset) {}
~DatasetIterator() override {}
Status Init(OpKernelContext* ctx) {
IteratorContext::Params params(ctx);
data::IteratorContext::Params params(ctx);
function_handle_cache_ =
absl::make_unique<data::FunctionHandleCache>(params.flr);
params.function_handle_cache = function_handle_cache_.get();
......@@ -409,7 +409,7 @@ class DatasetIterator : public InitializableLookupTable::InitTableIterator {
cancellation_manager_ =
absl::make_unique<CancellationManager>(ctx->cancellation_manager());
params.cancellation_manager = cancellation_manager_.get();
iterator_ctx_ = absl::make_unique<IteratorContext>(std::move(params));
iterator_ctx_ = absl::make_unique<data::IteratorContext>(std::move(params));
TF_RETURN_IF_ERROR(dataset_->MakeIterator(iterator_ctx_.get(), nullptr,
"LookupTable", &iterator_));
Next();
......@@ -442,12 +442,12 @@ class DatasetIterator : public InitializableLookupTable::InitTableIterator {
}
private:
DatasetBase* dataset_; // not owned.
std::unique_ptr<IteratorContext> iterator_ctx_;
data::DatasetBase* dataset_; // not owned.
std::unique_ptr<data::IteratorContext> iterator_ctx_;
std::unique_ptr<data::FunctionHandleCache> function_handle_cache_;
ResourceMgr resource_mgr_;
std::unique_ptr<CancellationManager> cancellation_manager_;
std::unique_ptr<IteratorBase> iterator_;
std::unique_ptr<data::IteratorBase> iterator_;
std::vector<Tensor> tensors_;
Status status_;
};
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册