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.
callbacks
InsertRowsCallback_2
[]
The corresponding callback functions.
add(row, callback)
add
(
row
:
RowMetadata
,
callback
:
InsertRowsCallback
)
:
void
;
callback
InsertRowsCallback
The insert callback.
getOptionDefaults()
getOptionDefaults
()
:
RowBatchOptions
;
insert(callback)
insert
(
callback
?:
InsertRowsCallback
)
:
void
;
Cancels any pending inserts and calls _insert immediately.
callback
InsertRowsCallback
setOptions(options)
setOptions
(
options
?:
RowBatchOptions
)
:
void
;
Sets the batching options.
options
RowBatchOptions
The batching options.
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-09-04 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-09-04 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."]]
