Versions in this module Expand all Collapse all v3 v3.4.0 Feb 6, 2023 Changes in this version + type Batch struct + func NewBatch(mgr *BatchMgr, bufferSize int, clientReq chan base.ClientRequest, ...) *Batch + func (b *Batch) Add(data base.Data) + func (b *Batch) Done() + func (b *Batch) IsFull() bool + func (b *Batch) SendErrorData(d base.Data, err error) + type BatchMgr struct + Batches []*Batch + InsertStmtPrefix string + Schema *config.Schema + func NewBatchMgr(schema *config.Schema, batchSize int, ...) *BatchMgr + func (bm *BatchMgr) Add(data base.Data, runnerLogger *logger.RunnerLogger) error + func (bm *BatchMgr) Done() + func (bm *BatchMgr) GeneratePropsString(props []*config.Prop) string + func (bm *BatchMgr) InitSchema(header base.Record, runnerLogger *logger.RunnerLogger) (err error) + func (m *BatchMgr) MakeEdgeStmt(batch []base.Data) (string, error) + func (m *BatchMgr) MakeVertexStmt(batch []base.Data) (string, error) + type DataFileReader interface + InitReader func(*os.File, *logger.RunnerLogger) + ReadLine func() (base.Data, error) + TotalBytes func() (int64, error) + type FileReader struct + BatchMgr *BatchMgr + Concurrency int + DataReader DataFileReader + File *config.File + FileIdx int + StopFlag bool + WithHeader bool + func New(fileIdx int, file *config.File, cleanup bool, ...) (*FileReader, error) + func (r *FileReader) Read() (numErrorLines int64, err error) + func (r *FileReader) Stop() Other modules containing this package github.com/vesoft-inc/nebula-importer github.com/vesoft-inc/nebula-importer/v4