Searched refs:topics_ (Results 1 – 1 of 1) sorted by relevance
61 topics_(std::move(topics)), in Dataset()91 TF_RETURN_IF_ERROR(b->AddVector(topics_, &topics)); in AsGraphDefInternal()159 if (current_topic_index_ == dataset()->topics_.size()) { in GetNextInternal()214 if (current_topic_index_ >= dataset()->topics_.size()) { in SetupStreamsLocked()217 " >= topics_.size():", dataset()->topics_.size()); in SetupStreamsLocked()221 string entry = dataset()->topics_[current_topic_index_]; in SetupStreamsLocked()309 const std::vector<string> topics_; member in tensorflow::KafkaDatasetOp::Dataset