Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

BigQuery Storage: copy lintified proto files (via synth). #7475

Merged
merged 1 commit into from
Mar 4, 2019
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@ option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storag
option java_outer_classname = "AvroProto";
option java_package = "com.google.cloud.bigquery.storage.v1beta1";


// Avro schema.
message AvroSchema {
// Json serialized schema, as described at
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ package google.cloud.bigquery.storage.v1beta1;
option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage";
option java_package = "com.google.cloud.bigquery.storage.v1beta1";


// Options dictating how we read a table.
message TableReadOptions {
// Optional. Names of the fields in the table that should be read. If empty,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ import "google/protobuf/timestamp.proto";
option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage";
option java_package = "com.google.cloud.bigquery.storage.v1beta1";


// BigQuery storage API.
//
// The BigQuery storage API can be used to read data stored in BigQuery.
Expand All @@ -43,8 +42,7 @@ service BigQueryStorage {
//
// Read sessions automatically expire 24 hours after they are created and do
// not require manual clean-up by the caller.
rpc CreateReadSession(CreateReadSessionRequest) returns (ReadSession) {
}
rpc CreateReadSession(CreateReadSessionRequest) returns (ReadSession) {}

// Reads rows from the table in the format prescribed by the read session.
// Each response contains one or more table rows, up to a maximum of 10 MiB
Expand All @@ -55,14 +53,13 @@ service BigQueryStorage {
// estimated total number of rows in the read stream. This number is computed
// based on the total table size and the number of active streams in the read
// session, and may change as other streams continue to read data.
rpc ReadRows(ReadRowsRequest) returns (stream ReadRowsResponse) {
}
rpc ReadRows(ReadRowsRequest) returns (stream ReadRowsResponse) {}

// Creates additional streams for a ReadSession. This API can be used to
// dynamically adjust the parallelism of a batch processing task upwards by
// adding additional workers.
rpc BatchCreateReadSessionStreams(BatchCreateReadSessionStreamsRequest) returns (BatchCreateReadSessionStreamsResponse) {
}
rpc BatchCreateReadSessionStreams(BatchCreateReadSessionStreamsRequest)
returns (BatchCreateReadSessionStreamsResponse) {}

// Triggers the graceful termination of a single stream in a ReadSession. This
// API can be used to dynamically adjust the parallelism of a batch processing
Expand All @@ -78,8 +75,7 @@ service BigQueryStorage {
// This method will return an error if there are no other live streams
// in the Session, or if SplitReadStream() has been called on the given
// Stream.
rpc FinalizeStream(FinalizeStreamRequest) returns (google.protobuf.Empty) {
}
rpc FinalizeStream(FinalizeStreamRequest) returns (google.protobuf.Empty) {}

// Splits a given read stream into two Streams. These streams are referred to
// as the primary and the residual of the split. The original stream can still
Expand All @@ -94,8 +90,8 @@ service BigQueryStorage {
// completion.
//
// This method is guaranteed to be idempotent.
rpc SplitReadStream(SplitReadStreamRequest) returns (SplitReadStreamResponse) {
}
rpc SplitReadStream(SplitReadStreamRequest)
returns (SplitReadStreamResponse) {}
}

// Information about a single data stream within a read session.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@ option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storag
option java_outer_classname = "TableReferenceProto";
option java_package = "com.google.cloud.bigquery.storage.v1beta1";


// Table reference that includes just the 3 strings needed to identify a table.
message TableReference {
// The assigned project ID of the project.
Expand Down
6 changes: 3 additions & 3 deletions bigquery_storage/synth.metadata
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
{
"updateTime": "2019-02-28T13:10:39.155085Z",
"updateTime": "2019-03-02T13:10:44.304044Z",
"sources": [
{
"generator": {
Expand All @@ -12,8 +12,8 @@
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
"sha": "9c769d3a0e67e4df9b9e8eee480124c2700a7e6c",
"internalRef": "235997788"
"sha": "41d72d444fbe445f4da89e13be02078734fb7875",
"internalRef": "236230004"
}
}
],
Expand Down