diff options
author | Jiri Simsa <jsimsa@google.com> | 2018-10-01 17:26:37 -0700 |
---|---|---|
committer | TensorFlower Gardener <gardener@tensorflow.org> | 2018-10-01 17:31:54 -0700 |
commit | 9a23e9251ecba026471ff77a5bbbc802a2889a10 (patch) | |
tree | b3cdc0a120ac823a91fbb8a8b68e0846f239885e /tensorflow/core | |
parent | ea5c529ed7b7e17d1e66bc7cf4479d232ed0a896 (diff) |
[tf.data] Adding `tf.data.Options()`, `tf.data.Dataset.options()`, and `tf.data.Dataset.with_options()` to make it possible to respectively represent, get, and set options, such as optimization configuration, of a tf.data input pipeline.
PiperOrigin-RevId: 215310764
Diffstat (limited to 'tensorflow/core')
-rw-r--r-- | tensorflow/core/kernels/data/optimize_dataset_op.cc | 16 |
1 files changed, 4 insertions, 12 deletions
diff --git a/tensorflow/core/kernels/data/optimize_dataset_op.cc b/tensorflow/core/kernels/data/optimize_dataset_op.cc index d5b725eac9..1cb7caa738 100644 --- a/tensorflow/core/kernels/data/optimize_dataset_op.cc +++ b/tensorflow/core/kernels/data/optimize_dataset_op.cc @@ -154,12 +154,8 @@ class OptimizeDatasetOp : public UnaryDatasetOpKernel { : DatasetIterator<Dataset>(params) {} Status Initialize(IteratorContext* ctx) override { - IteratorContext::Params params; - params.env = ctx->env(); - params.runner = *(ctx->runner()); - params.stats_aggregator_getter = ctx->stats_aggregator_getter(); + IteratorContext::Params params = ctx->params(); params.lib = dataset()->lib_; - params.allocator_getter = ctx->allocator_getter(); return dataset()->optimized_input_->MakeIterator( IteratorContext(params), prefix(), &input_impl_); } @@ -167,14 +163,10 @@ class OptimizeDatasetOp : public UnaryDatasetOpKernel { Status GetNextInternal(IteratorContext* ctx, std::vector<Tensor>* out_tensors, bool* end_of_sequence) override { - IteratorContext::Params params; - params.env = ctx->env(); - params.runner = *(ctx->runner()); - params.stats_aggregator_getter = ctx->stats_aggregator_getter(); + IteratorContext::Params params = ctx->params(); params.lib = dataset()->lib_; - params.allocator_getter = ctx->allocator_getter(); - IteratorContext iter_ctx(params); - return input_impl_->GetNext(&iter_ctx, out_tensors, end_of_sequence); + return input_impl_->GetNext(IteratorContext(params), out_tensors, + end_of_sequence); } protected: |