data_service_ops.cc
imports tensorflow/core/platform/env_time.himports tensorflow/core/platform/errors.h
SHA-256121d1589b81d59b8e9cf69155c850434020702dd4ffae85d404ea6038cbd9ec0
MaleculeH(Db)Md(In₄)
Evidence
1/* Copyright 2020 The TensorFlow Authors. All Rights Reserved.
2
3Licensed under the Apache License, Version 2.0 (the "License");
4you may not use this file except in compliance with the License.
5You may obtain a copy of the License at
6
7 http://www.apache.org/licenses/LICENSE-2.0
8
9Unless required by applicable law or agreed to in writing, software
10distributed under the License is …
11:42… IND, either express or implied.
12See the License for the specific language governing permissions and
13limitations under the License.
14==============================================================================*/
15
16#include "tensorflow/core/kernels/data/experimental/data_service_ops.h"
17
18#include <optional>
19#include <string>
20#include <utility>
21
22#include "absl/strings/numbers.h"
23#include "tensorflow/core/data/serialization_utils.h"
24#include "tensorflow/core/data/service/common.pb.h"
25#include "tensorflow/core/data/service/dispatcher_client.h"
26#include "tensorflow/core/data/service/grpc_util.h"
27#include "tensorflow/core/framework/dataset.h"
28#include "tensorflow/core/framework/graph.pb.h"
29#include "tensorflow/core/framework/op_kernel.h"
30#include "tensorflow/core/framework/tensor.h"
31#include "tensorflow/core/platform/env_time.h"
32#include "tensorflow/core/platform/errors.h"
33#include "tensorflow/core/platform/status.h"
34#include "tensorflow/core/platform/tstring.h"
35#include "tensorflow/core/protobuf/data_service.pb.h"
36
37namespace tensorflow {
⋯4 lines
42const int64_t kRetryTimeoutMicros = 1000LL * 1000 * 60 * 60; // 60 minutes.
43
44constexpr char kRegisterDatasetV1[] = "RegisterDataset";
45constexpr char kRegisterDatasetV2[] = "RegisterDatasetV2";
46
47} // namespace
48
49RegisterDatasetOp::RegisterDatasetOp(OpKernelConstruction* ctx)
50 : OpKernel(ctx) { …