@google-cloud/bigquery-storage
Advanced tools
Comparing version 3.1.1 to 3.2.0
@@ -259,2 +259,3 @@ "use strict"; | ||
createReadSession(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -274,3 +275,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
'read_session.table': request.readSession.table || '', | ||
'read_session.table': (_a = request.readSession.table) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -281,2 +282,3 @@ this.initialize(); | ||
splitReadStream(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -296,3 +298,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
name: request.name || '', | ||
name: (_a = request.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -330,2 +332,3 @@ this.initialize(); | ||
readRows(request, options) { | ||
var _a; | ||
request = request || {}; | ||
@@ -337,3 +340,3 @@ options = options || {}; | ||
this._gaxModule.routingHeader.fromParams({ | ||
read_stream: request.readStream || '', | ||
read_stream: (_a = request.readStream) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -340,0 +343,0 @@ this.initialize(); |
@@ -153,2 +153,5 @@ import type * as gax from 'google-gax'; | ||
* `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`. | ||
* @param {google.cloud.bigquery.storage.v1.WriteStreamView} request.view | ||
* Indicates whether to get full or partial view of the WriteStream. If | ||
* not set, view returned will be basic. | ||
* @param {object} [options] | ||
@@ -296,9 +299,2 @@ * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. | ||
* | ||
* Note: For users coding against the gRPC api directly, it may be | ||
* necessary to supply the x-goog-request-params system parameter | ||
* with `write_stream=<full_write_stream_name>`. | ||
* | ||
* More information about system parameters: | ||
* https://cloud.google.com/apis/docs/system-parameters | ||
* | ||
* @param {object} [options] | ||
@@ -305,0 +301,0 @@ * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. |
@@ -266,2 +266,3 @@ "use strict"; | ||
createWriteStream(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -281,3 +282,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
parent: request.parent || '', | ||
parent: (_a = request.parent) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -288,2 +289,3 @@ this.initialize(); | ||
getWriteStream(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -303,3 +305,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
name: request.name || '', | ||
name: (_a = request.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -310,2 +312,3 @@ this.initialize(); | ||
finalizeWriteStream(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -325,3 +328,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
name: request.name || '', | ||
name: (_a = request.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -332,2 +335,3 @@ this.initialize(); | ||
batchCommitWriteStreams(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -347,3 +351,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
parent: request.parent || '', | ||
parent: (_a = request.parent) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -354,2 +358,3 @@ this.initialize(); | ||
flushRows(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -369,3 +374,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
write_stream: request.writeStream || '', | ||
write_stream: (_a = request.writeStream) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -408,9 +413,2 @@ this.initialize(); | ||
* | ||
* Note: For users coding against the gRPC api directly, it may be | ||
* necessary to supply the x-goog-request-params system parameter | ||
* with `write_stream=<full_write_stream_name>`. | ||
* | ||
* More information about system parameters: | ||
* https://cloud.google.com/apis/docs/system-parameters | ||
* | ||
* @param {object} [options] | ||
@@ -417,0 +415,0 @@ * Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details. |
@@ -260,2 +260,3 @@ "use strict"; | ||
createReadSession(request, optionsOrCallback, callback) { | ||
var _a, _b; | ||
request = request || {}; | ||
@@ -275,4 +276,4 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
'table_reference.project_id': request.tableReference.projectId || '', | ||
'table_reference.dataset_id': request.tableReference.datasetId || '', | ||
'table_reference.project_id': (_a = request.tableReference.projectId) !== null && _a !== void 0 ? _a : '', | ||
'table_reference.dataset_id': (_b = request.tableReference.datasetId) !== null && _b !== void 0 ? _b : '', | ||
}); | ||
@@ -283,2 +284,3 @@ this.initialize(); | ||
batchCreateReadSessionStreams(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -298,3 +300,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
'session.name': request.session.name || '', | ||
'session.name': (_a = request.session.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -305,2 +307,3 @@ this.initialize(); | ||
finalizeStream(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -320,3 +323,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
'stream.name': request.stream.name || '', | ||
'stream.name': (_a = request.stream.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -327,2 +330,3 @@ this.initialize(); | ||
splitReadStream(request, optionsOrCallback, callback) { | ||
var _a; | ||
request = request || {}; | ||
@@ -342,3 +346,3 @@ let options; | ||
this._gaxModule.routingHeader.fromParams({ | ||
'original_stream.name': request.originalStream.name || '', | ||
'original_stream.name': (_a = request.originalStream.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -376,2 +380,3 @@ this.initialize(); | ||
readRows(request, options) { | ||
var _a; | ||
request = request || {}; | ||
@@ -383,3 +388,3 @@ options = options || {}; | ||
this._gaxModule.routingHeader.fromParams({ | ||
'read_position.stream.name': request.readPosition.stream.name || '', | ||
'read_position.stream.name': (_a = request.readPosition.stream.name) !== null && _a !== void 0 ? _a : '', | ||
}); | ||
@@ -386,0 +391,0 @@ this.initialize(); |
# Changelog | ||
## [3.2.0](https://github.com/googleapis/nodejs-bigquery-storage/compare/v3.1.1...v3.2.0) (2022-11-11) | ||
### Features | ||
* Add location to WriteStream and add WriteStreamView support ([#295](https://github.com/googleapis/nodejs-bigquery-storage/issues/295)) ([ba3c5ef](https://github.com/googleapis/nodejs-bigquery-storage/commit/ba3c5ef05366b1e9a542b9b13fc0c7a25118b2a3)) | ||
## [3.1.1](https://github.com/googleapis/nodejs-bigquery-storage/compare/v3.1.0...v3.1.1) (2022-09-01) | ||
@@ -4,0 +11,0 @@ |
{ | ||
"name": "@google-cloud/bigquery-storage", | ||
"version": "3.1.1", | ||
"version": "3.2.0", | ||
"description": "Client for the BigQuery Storage API", | ||
@@ -30,11 +30,11 @@ "repository": "googleapis/nodejs-bigquery-storage", | ||
"dependencies": { | ||
"google-gax": "^3.3.0" | ||
"google-gax": "^3.5.2" | ||
}, | ||
"devDependencies": { | ||
"@types/mocha": "^9.0.0", | ||
"@types/node": "^16.0.0", | ||
"@types/node": "^18.0.0", | ||
"@types/sinon": "^10.0.0", | ||
"c8": "^7.1.0", | ||
"gts": "^3.1.0", | ||
"jsdoc": "^3.6.3", | ||
"jsdoc": "^4.0.0", | ||
"jsdoc-fresh": "^2.0.0", | ||
@@ -48,3 +48,3 @@ "jsdoc-region-tag": "^2.0.0", | ||
"ts-loader": "^9.0.0", | ||
"typescript": "^4.6.4", | ||
"typescript": "^4.8.3", | ||
"webpack": "^5.0.0", | ||
@@ -51,0 +51,0 @@ "webpack-cli": "^4.0.0" |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
2872630
40
44158
Updatedgoogle-gax@^3.5.2