NAME
Google::Cloud::Bigquery::Storage::V1::Storage::CreateReadSessionRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::CreateReadSessionRequest->new(
parent => $value,
);
FIELDS
parent
Type: String
read_session
Type: Message (.google.cloud.bigquery.storage.v1.ReadSession)
max_stream_count
Type: Int32
preferred_min_stream_count
Type: Int32
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::ReadRowsRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::ReadRowsRequest->new(
read_stream => $value,
);
FIELDS
read_stream
Type: String
offset
Type: Int64
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::ThrottleState - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::ThrottleState->new(
throttle_percent => $value,
);
FIELDS
throttle_percent
Type: Int32
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::StreamStats - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::StreamStats->new(
progress => $value,
);
FIELDS
progress
Type: Message (.google.cloud.bigquery.storage.v1.StreamStats.Progress)
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::ReadRowsResponse - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::ReadRowsResponse->new(
avro_rows => $value,
);
FIELDS
avro_rows
Type: Message (.google.cloud.bigquery.storage.v1.AvroRows)
arrow_record_batch
Type: Message (.google.cloud.bigquery.storage.v1.ArrowRecordBatch)
row_count
Type: Int64
stats
Type: Message (.google.cloud.bigquery.storage.v1.StreamStats)
throttle_state
Type: Message (.google.cloud.bigquery.storage.v1.ThrottleState)
avro_schema
Type: Message (.google.cloud.bigquery.storage.v1.AvroSchema)
arrow_schema
Type: Message (.google.cloud.bigquery.storage.v1.ArrowSchema)
uncompressed_byte_size
Type: Int64
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::SplitReadStreamRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::SplitReadStreamRequest->new(
name => $value,
);
FIELDS
name
Type: String
fraction
Type: Double
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::SplitReadStreamResponse - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::SplitReadStreamResponse->new(
primary_stream => $value,
);
FIELDS
primary_stream
Type: Message (.google.cloud.bigquery.storage.v1.ReadStream)
remainder_stream
Type: Message (.google.cloud.bigquery.storage.v1.ReadStream)
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::CreateWriteStreamRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::CreateWriteStreamRequest->new(
parent => $value,
);
FIELDS
parent
Type: String
write_stream
Type: Message (.google.cloud.bigquery.storage.v1.WriteStream)
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::AppendRowsRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::AppendRowsRequest->new(
write_stream => $value,
);
FIELDS
write_stream
Type: String
offset
Type: Message (.google.protobuf.Int64Value)
proto_rows
Type: Message (.google.cloud.bigquery.storage.v1.AppendRowsRequest.ProtoData)
arrow_rows
Type: Message (.google.cloud.bigquery.storage.v1.AppendRowsRequest.ArrowData)
trace_id
Type: String
missing_value_interpretations
Type: Message (.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretationsEntry)
default_missing_value_interpretation
Type: Enum (.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation)
Enum: AppendRowsRequest::MissingValueInterpretation
Values:
MISSING_VALUE_INTERPRETATION_UNSPECIFIED=> 0NULL_VALUE=> 1DEFAULT_VALUE=> 2
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::AppendRowsResponse - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::AppendRowsResponse->new(
append_result => $value,
);
FIELDS
append_result
Type: Message (.google.cloud.bigquery.storage.v1.AppendRowsResponse.AppendResult)
error
Type: Message (.google.rpc.Status)
updated_schema
Type: Message (.google.cloud.bigquery.storage.v1.TableSchema)
row_errors
Type: Message (.google.cloud.bigquery.storage.v1.RowError)
write_stream
Type: String
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::GetWriteStreamRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::GetWriteStreamRequest->new(
name => $value,
);
FIELDS
name
Type: String
view
Type: Enum (.google.cloud.bigquery.storage.v1.WriteStreamView)
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::BatchCommitWriteStreamsRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::BatchCommitWriteStreamsRequest->new(
parent => $value,
);
FIELDS
parent
Type: String
write_streams
Type: String
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::BatchCommitWriteStreamsResponse - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::BatchCommitWriteStreamsResponse->new(
commit_time => $value,
);
FIELDS
commit_time
Type: Message (.google.protobuf.Timestamp)
stream_errors
Type: Message (.google.cloud.bigquery.storage.v1.StorageError)
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::FinalizeWriteStreamRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::FinalizeWriteStreamRequest->new(
name => $value,
);
FIELDS
name
Type: String
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::FinalizeWriteStreamResponse - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::FinalizeWriteStreamResponse->new(
row_count => $value,
);
FIELDS
row_count
Type: Int64
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::FlushRowsRequest - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::FlushRowsRequest->new(
write_stream => $value,
);
FIELDS
write_stream
Type: String
offset
Type: Message (.google.protobuf.Int64Value)
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::FlushRowsResponse - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::FlushRowsResponse->new(
offset => $value,
);
FIELDS
offset
Type: Int64
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::StorageError - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::StorageError->new(
code => $value,
);
FIELDS
code
Type: Enum (.google.cloud.bigquery.storage.v1.StorageError.StorageErrorCode)
entity
Type: String
error_message
Type: String
Enum: StorageError::StorageErrorCode
Values:
STORAGE_ERROR_CODE_UNSPECIFIED=> 0TABLE_NOT_FOUND=> 1STREAM_ALREADY_COMMITTED=> 2STREAM_NOT_FOUND=> 3INVALID_STREAM_TYPE=> 4INVALID_STREAM_STATE=> 5STREAM_FINALIZED=> 6SCHEMA_MISMATCH_EXTRA_FIELDS=> 7OFFSET_ALREADY_EXISTS=> 8OFFSET_OUT_OF_RANGE=> 9CMEK_NOT_PROVIDED=> 10INVALID_CMEK_PROVIDED=> 11CMEK_ENCRYPTION_ERROR=> 12KMS_SERVICE_ERROR=> 13KMS_PERMISSION_DENIED=> 14
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::RowError - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Cloud::Bigquery::Storage::V1::Storage;
my $msg = Google::Cloud::Bigquery::Storage::V1::Storage::RowError->new(
index => $value,
);
FIELDS
index
Type: Int64
code
Type: Enum (.google.cloud.bigquery.storage.v1.RowError.RowErrorCode)
message
Type: String
Enum: RowError::RowErrorCode
Values:
ROW_ERROR_CODE_UNSPECIFIED=> 0FIELDS_ERROR=> 1
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::BigqueryReadClient - Client stub representing the remote BigQueryRead service
DESCRIPTION
This class acts as a local client stub for the remote gRPC service. It delegates call dispatching to an underlying Google::gRPC::Client instance, ensuring type-safe request parsing and response mapping.
CONFIGURATION AND ENVIRONMENT
target
The endpoint target address. Defaults to bigquery.googleapis.com:443.
credentials
The authentication credentials provider. Defaults to application default credentials via Google::Auth.
NAME
Google::Cloud::Bigquery::Storage::V1::Storage::BigqueryWriteClient - Client stub representing the remote BigQueryWrite service
DESCRIPTION
This class acts as a local client stub for the remote gRPC service. It delegates call dispatching to an underlying Google::gRPC::Client instance, ensuring type-safe request parsing and response mapping.
CONFIGURATION AND ENVIRONMENT
target
The endpoint target address. Defaults to bigquery.googleapis.com:443.
credentials
The authentication credentials provider. Defaults to application default credentials via Google::Auth.
NAME
Google::Cloud::Bigquery::Storage::V1::Storage - Protocol Buffers schema definition
DESCRIPTION
Auto-generated Protocol Buffers schema definition class.
LICENSE AND COPYRIGHT
Copyright (C) 2026 Google LLC
This program is released under the Apache 2.0 license.