concatenate_dataset_op.cc
imports tsl/platform/mutex.himports tsl/platform/thread_annotations.h
SHA-256c7b4495dd05be16ef5e0ea9978a09e6da0c86f52bd5b002ac7999f759d370fee
MaleculeH(Db)Md(In₄)
Evidence
1/* Copyright 2017 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#include "tensorflow/core/kernels/data/concatenate_dataset_op.h"
16
17#include <cstddef>
18#include <cstdint>
19#include <memory>
20#include <utility>
21#include <vector>
22
23#include "absl/status/status.h"
24#include "absl/status/statusor.h"
25#include "absl/strings/str_format.h"
26#include "xla/tsl/platform/errors.h"
27#include "xla/tsl/platform/statusor.h"
28#include "tensorflow/core/data/name_utils.h"
29#include "tensorflow/core/data/split_utils.h"
30#include "tensorflow/core/framework/dataset.h"
31#include "tensorflow/core/framework/tensor.h"
32#include "tsl/platform/mutex.h"
33#include "tsl/platform/thread_annotations.h"
34
35namespace tensorflow {
⋯4 lines
45:26… nst char* const ConcatenateDatasetOp::kOutputShapes;
46
47constexpr char kIndex[] = "i";
48constexpr char kInputImplUninitialized[] = "input_impl_uninitialized";
49constexpr char kElementCount[] = "element_count";
50
51namespace {
52
53// Gets the next shuffled index by iterating through the `index_mapper` until
54// 1. It is not …
241 // This has to return a status so that upstream global shuffle
242 // iterator will not treat it as an end of sequence.
243 …
481:34… and dataset to concatenate"
482 " have different output_types %s and %s",
483 (DataTypeVectorString(input->output_dtypes …