blob: 08a4da5b41bb37430888c70b193c6c8a66beab63 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
// See docs in ../ops/io_ops.cc.
#include <string>
#include <vector>
#include "tensorflow/core/framework/op_kernel.h"
#include "tensorflow/core/lib/core/errors.h"
#include "tensorflow/core/lib/io/match.h"
#include "tensorflow/core/public/env.h"
#include "tensorflow/core/public/tensor_shape.h"
namespace tensorflow {
class MatchingFilesOp : public OpKernel {
public:
using OpKernel::OpKernel;
void Compute(OpKernelContext* context) override {
const Tensor* pattern;
OP_REQUIRES_OK(context, context->input("pattern", &pattern));
OP_REQUIRES(context, TensorShapeUtils::IsScalar(pattern->shape()),
errors::InvalidArgument(
"Input pattern tensor must be scalar, but had shape: ",
pattern->shape().DebugString()));
std::vector<string> fnames;
OP_REQUIRES_OK(context,
io::GetMatchingFiles(context->env(),
pattern->scalar<string>()(), &fnames));
const int num_out = fnames.size();
Tensor* output = nullptr;
OP_REQUIRES_OK(context, context->allocate_output(
"filenames", TensorShape({num_out}), &output));
auto output_vec = output->vec<string>();
for (int i = 0; i < num_out; ++i) {
output_vec(i) = fnames[i];
}
}
};
REGISTER_KERNEL_BUILDER(Name("MatchingFiles").Device(DEVICE_CPU),
MatchingFilesOp);
} // namespace tensorflow
|
