Class RowQueue (8.0.0)

Standard row queue used for inserting rows.

Package

constructor(table: Table, dup: Stream, options?: InsertStreamOptions);

Constructs a new instance of the RowQueue class

batch: RowBatch;

batchOptions?: RowBatchOptions;

inFlight: boolean;

insertRowsOptions: InsertRowsOptions;

pending?: ReturnType<typeof setTimeout>;

stream: Stream;

table: Table;

_insert(rows: RowMetadata | RowMetadata[], callbacks: InsertRowsCallback[], cb?: InsertRowsCallback): void;

Accepts a batch of rows and inserts them into table.

Parameters
Name	Description
`rows`	`RowMetadata \| RowMetadata[]` The rows to insert.
`callbacks`	`InsertRowsCallback_2[]` The corresponding callback functions.
`cb`	`InsertRowsCallback`

Returns
Type	Description
`void`

add(row: RowMetadata, callback: InsertRowsCallback): void;

Adds a row to the queue.

Parameters
Name	Description
`row`	`RowMetadata` The row to insert.
`callback`	`InsertRowsCallback` The insert callback.

Returns
Type	Description
`void`

getOptionDefaults(): RowBatchOptions;

Returns
Type	Description
`RowBatchOptions`

insert(callback?: InsertRowsCallback): void;

Cancels any pending inserts and calls _insert immediately.

Parameter
Name	Description
`callback`	`InsertRowsCallback`

Returns
Type	Description
`void`

setOptions(options?: RowBatchOptions): void;

Sets the batching options.

Parameter
Name	Description
`options`	`RowBatchOptions` The batching options.

Returns
Type	Description
`void`