kafka_dataset_ops.cc | 46 bool eof = false; variable 47 OP_REQUIRES_OK(ctx, ParseScalarArgument<bool>(ctx, "eof", &eof)); 53 *output = new Dataset(ctx, std::move(topics), servers, group, eof, timeout); 60 const string& servers, const string& group, const bool eof, 66 eof_(eof), 97 Node* eof = nullptr; variable 98 TF_RETURN_IF_ERROR(b->AddScalar(eof_, &eof)); 102 b->AddDataset(this, {topics, servers, group, eof, timeout}, output)); 122 // EOF current topi [all...] |