datapipe-util
v1.0.0
Published
Streaming data transformation pipeline with batching and serialization
Readme
datapipe-util
Streaming data transformation with batching, serialization, and normalization.
Install
npm install datapipe-utilQuick Start
const dp = require('datapipe-util');
const batcher = dp.createBatcher({ batchSize: 100 });
batcher.add({ event: 'login', user: 'alice' });
const packed = await batcher.flushAndPack();API
- createBatcher
- batcher.add
- batcher.addMany
- batcher.forceFlush
- batcher.flushAndPack
- batcher.restore
- batcher.isStale
- batcher.getPendingCount
- batcher.getStats
- serializeRow
- serializeBatch
- serializeToBuffer
- serializeStream
- deserializeRow
- deserializeBatch
- normalize
- denormalize
- hashRecord
- quickPack
- pipeThrough
License
MIT
