aboutsummaryrefslogtreecommitdiffhomepage
path: root/tensorflow/core
diff options
context:
space:
mode:
authorGravatar Jiri Simsa <jsimsa@google.com>2018-10-01 17:26:37 -0700
committerGravatar TensorFlower Gardener <gardener@tensorflow.org>2018-10-01 17:31:54 -0700
commit9a23e9251ecba026471ff77a5bbbc802a2889a10 (patch)
treeb3cdc0a120ac823a91fbb8a8b68e0846f239885e /tensorflow/core
parentea5c529ed7b7e17d1e66bc7cf4479d232ed0a896 (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.cc16
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: