Versions in this module Expand all Collapse all v1 v1.0.0 Jun 9, 2020 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) error + func (bm *BatchMgr) Done() + func (bm *BatchMgr) GeneratePropsString(props []*config.Prop) string + func (bm *BatchMgr) InitSchema(header base.Record) + func (m *BatchMgr) MakeEdgeStmt(batch []base.Data) string + func (m *BatchMgr) MakeVertexStmt(batch []base.Data) string + type DataFileReader interface + InitReader func(*os.File) + ReadLine func() (base.Data, 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() error + func (r *FileReader) Stop() v1.0.0-beta Dec 4, 2019 Other modules containing this package github.com/vesoft-inc/nebula-importer/v3 github.com/vesoft-inc/nebula-importer/v4