ChunkTransformer formats all incoming chunks in to row keeps all intermediate state until end of stream. Should use new instance for each request.
Inheritance
Transform > ChunkTransformerPackage
@google-cloud/bigtableConstructors
(constructor)(options)
constructor
(
options
?:
TransformOptions
);
Constructs a new instance of the ChunkTransformer
class
options
TransformOptions
Properties
_destroyed
_destroyed
:
boolean
;
family
family
?:
Family
;
lastRowKey
lastRowKey
?:
Value
;
options
options
:
TransformOptions
;
qualifier
qualifier
?:
Qualifier
;
qualifiers
qualifiers
?:
Qualifier
[];
row
row
?:
Row
;
state
state
?:
number
;
Methods
_flush(cb)
_flush
(
cb
:
Function
)
:
void
;
called at end of the stream.
cb
Function
callback will be called with error if there is any uncommitted row
void
_transform(data, _encoding, next)
_transform
(
data
:
Data
,
_encoding
:
string
,
next
:
Function
)
:
void
;
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.
data
_encoding
string
encoding options.
next
Function
callback will be called once data is processed, with error if any error in processing
void
commit()
commit
()
:
void
;
sets lastRowkey and calls reset when row is committed.
void
destroy(err)
destroy
(
err
?:
Error
)
:
this
;
called when stream is destroyed.
err
Error
error if any
this
moveToNextState(chunk)
moveToNextState
(
chunk
:
Chunk
)
:
void
;
Moves to next state in processing.
void
processCellInProgress(chunk)
processCellInProgress
(
chunk
:
Chunk
)
:
void
;
Process chunk when in CELl_IN_PROGRESS state.
void
processNewRow(chunk)
processNewRow
(
chunk
:
Chunk
)
:
void
;
Process chunk when in NEW_ROW state.
void
processRowInProgress(chunk)
processRowInProgress
(
chunk
:
Chunk
)
:
void
;
Process chunk when in ROW_IN_PROGRESS state.
void
reset()
reset
()
:
void
;
Resets state of formatter
void
validateCellInProgress(chunk)
validateCellInProgress
(
chunk
:
Chunk
)
:
void
;
Validates chunk for cellInProgress state.
void
validateNewRow(chunk, newRowKey)
validateNewRow
(
chunk
:
Chunk
,
newRowKey
:
string
|
Buffer
)
:
void
;
Validates state for new row.
chunk
newRowKey
string | "\"buffer\"".__global.Buffer
newRowKey of the new row
void
validateResetRow(chunk)
validateResetRow
(
chunk
:
Chunk
)
:
void
;
Validates resetRow condition for chunk
void
validateRowInProgress(chunk)
validateRowInProgress
(
chunk
:
Chunk
)
:
void
;
Validates state for rowInProgress
void
validateValueSizeAndCommitRow(chunk)
validateValueSizeAndCommitRow
(
chunk
:
Chunk
)
:
void
;
Validates valuesize and commitrow in a chunk
void
