Class RowQueue (8.0.0)
Standard row queue used for inserting rows.
Package
@google-cloud/bigqueryConstructors
(constructor)(table, dup, options)
constructor(table:Table,dup:Stream,options?:InsertStreamOptions);Constructs a new instance of theRowQueue class
| Parameters | |
|---|---|
| Name | Description |
table | Table |
dup | Stream |
options | InsertStreamOptions |
Properties
batch
batch:RowBatch;batchOptions
batchOptions?:RowBatchOptions;inFlight
inFlight:boolean;insertRowsOptions
insertRowsOptions:InsertRowsOptions;pending
pending?:ReturnType<typeofsetTimeout>;stream
stream:Stream;table
table: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;Adds a row to the queue.
| Parameters | |
|---|---|
| Name | Description |
row | RowMetadataThe row to insert. |
callback | InsertRowsCallbackThe 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 | RowBatchOptionsThe batching options. |
| Returns | |
|---|---|
| Type | Description |
void | |
Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-10-30 UTC.