Method Read

oneflow/user/data/data_reader.h:43–47

  }

  void Read(user_op::KernelComputeContext* ctx) {
    CHECK(load_thrd_.joinable()) << "You should call StartLoadThread before read data";
    auto batch = FetchBatchData();
    parser_->Parse(batch, ctx);
  }

  void Close() {
    if (!is_closed_.load()) {