Constructor

ChunkTransformer

new ChunkTransformer()

Methods

_flush

public

_flush(cb)

called at end of the stream.

Parameter

cb

callback

callback will be called with error if there is any uncommitted row

_transform

public

_transform(data, enc, next)

transform the readrowsresponse chunks into friendly format. Chunks contain 3 properties:

rowContents The row contents, this essentially is all data pertaining to a single family.

commitRow This is a boolean telling us the all previous chunks for this row are ok to consume.

resetRow This is a boolean telling us that all the previous chunks are to be discarded.

Parameter

data

object

readrows response containing array of chunks.

enc

Optional

object

encoding options.

next

callback

callback will be called once data is processed, with error if any error in processing

destroy

public

destroy(err)

called when stream is destroyed.

Parameter

err

error

error if any