0.0.3 • Published 3 years ago
@modelize/transfer v0.0.3
Modelize Transfer
npm i --save @modelize/transferExecution Flow
Start a new transfer with basic options: new Transfer().start()
onBefore(): returnsresumeInfo- do process:
onLoad(): consumesresumeInfoand reduces raw-rows- for each loaded
raw-row:onFilter(): consumesraw-row, returnfalseto exclude rowtransform(): consumesraw-rowmust producewrite-row- filtered/transformed
raw-rowis cleaned directly from internal memory
- filtered/transformed
beforeWrite(): consumeswrite-rows, may change theresumeInfo- must be run before
writing, as the already written rows are cleaned directly from internal memory
- must be run before
- for each
batch-to-writeonWrite(): consumes batch ofwrite-row
- repeat process if
resumeInfonotundefinednow