Class RowQueue (8.0.0)
Stay organized with collections
Save and categorize content based on your preferences.
Standard row queue used for inserting rows.
Package
@google-cloud/bigquery
Constructors
(constructor)(table, dup, options)
constructor(table: Table, dup: Stream, options?: InsertStreamOptions);
Constructs a new instance of the RowQueue
class
Properties
batch
batchOptions
batchOptions?: RowBatchOptions;
inFlight
insertRowsOptions
insertRowsOptions: InsertRowsOptions;
pending
pending?: ReturnType<typeof setTimeout>;
stream
table
Methods
_insert(rows, callbacks, cb)
_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, callback)
add(row: RowMetadata, callback: InsertRowsCallback): void;
Parameters |
Name |
Description |
row |
RowMetadata
The row to insert.
|
callback |
InsertRowsCallback
The insert callback.
|
Returns |
Type |
Description |
void |
|
getOptionDefaults()
getOptionDefaults(): RowBatchOptions;
Returns |
Type |
Description |
RowBatchOptions |
|
insert(callback)
insert(callback?: InsertRowsCallback): void;
Cancels any pending inserts and calls _insert immediately.
Parameter |
Name |
Description |
callback |
InsertRowsCallback
|
Returns |
Type |
Description |
void |
|
setOptions(options)
setOptions(options?: RowBatchOptions): void;
Sets the batching options.
Parameter |
Name |
Description |
options |
RowBatchOptions
The batching options.
|
Returns |
Type |
Description |
void |
|
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-08-28 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-28 UTC."],[],[],null,["# Class RowQueue (8.0.0)\n\nVersion latestkeyboard_arrow_down\n\n- [8.0.0 (latest)](/nodejs/docs/reference/bigquery/latest/bigquery/rowqueue)\n- [7.8.0](/nodejs/docs/reference/bigquery/7.8.0/bigquery/rowqueue)\n- [7.7.0](/nodejs/docs/reference/bigquery/7.7.0/bigquery/rowqueue)\n- [7.6.1](/nodejs/docs/reference/bigquery/7.6.1/bigquery/rowqueue)\n- [7.5.2](/nodejs/docs/reference/bigquery/7.5.2/bigquery/rowqueue)\n- [7.4.0](/nodejs/docs/reference/bigquery/7.4.0/bigquery/rowqueue)\n- [7.3.0](/nodejs/docs/reference/bigquery/7.3.0/bigquery/rowqueue)\n- [7.2.0](/nodejs/docs/reference/bigquery/7.2.0/bigquery/rowqueue)\n- [7.1.1](/nodejs/docs/reference/bigquery/7.1.1/bigquery/rowqueue)\n- [7.0.0](/nodejs/docs/reference/bigquery/7.0.0/bigquery/rowqueue)\n- [6.2.1](/nodejs/docs/reference/bigquery/6.2.1/bigquery/rowqueue)\n- [6.0.3](/nodejs/docs/reference/bigquery/6.0.3/bigquery/rowqueue)\n- [5.12.0](/nodejs/docs/reference/bigquery/5.12.0/bigquery/rowqueue)\n- [5.11.0](/nodejs/docs/reference/bigquery/5.11.0/bigquery/rowqueue)\n- [5.10.0](/nodejs/docs/reference/bigquery/5.10.0/bigquery/rowqueue)\n- [5.9.3](/nodejs/docs/reference/bigquery/5.9.3/bigquery/rowqueue)\n- [5.8.0](/nodejs/docs/reference/bigquery/5.8.0/bigquery/rowqueue)\n- [5.7.1](/nodejs/docs/reference/bigquery/5.7.1/bigquery/rowqueue)\n- [5.6.0](/nodejs/docs/reference/bigquery/5.6.0/bigquery/rowqueue)\n- [5.5.0](/nodejs/docs/reference/bigquery/5.5.0/bigquery/rowqueue) \nStandard row queue used for inserting rows.\n\nPackage\n-------\n\n[@google-cloud/bigquery](../overview.html)\n\nConstructors\n------------\n\n### (constructor)(table, dup, options)\n\n constructor(table: Table, dup: Stream, options?: InsertStreamOptions);\n\nConstructs a new instance of the `RowQueue` class\n\nProperties\n----------\n\n### batch\n\n batch: RowBatch;\n\n### batchOptions\n\n batchOptions?: RowBatchOptions;\n\n### inFlight\n\n inFlight: boolean;\n\n### insertRowsOptions\n\n insertRowsOptions: InsertRowsOptions;\n\n### pending\n\n pending?: ReturnType\u003ctypeof setTimeout\u003e;\n\n### stream\n\n stream: Stream;\n\n### table\n\n table: Table;\n\nMethods\n-------\n\n### _insert(rows, callbacks, cb)\n\n _insert(rows: RowMetadata | RowMetadata[], callbacks: InsertRowsCallback[], cb?: InsertRowsCallback): void;\n\nAccepts a batch of rows and inserts them into table.\n\n### add(row, callback)\n\n add(row: RowMetadata, callback: InsertRowsCallback): void;\n\nAdds a row to the queue.\n\n### getOptionDefaults()\n\n getOptionDefaults(): RowBatchOptions;\n\n### insert(callback)\n\n insert(callback?: InsertRowsCallback): void;\n\nCancels any pending inserts and calls _insert immediately.\n\n### setOptions(options)\n\n setOptions(options?: RowBatchOptions): void;\n\nSets the batching options."]]