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 => 0

  • NULL_VALUE => 1

  • DEFAULT_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 => 0

  • TABLE_NOT_FOUND => 1

  • STREAM_ALREADY_COMMITTED => 2

  • STREAM_NOT_FOUND => 3

  • INVALID_STREAM_TYPE => 4

  • INVALID_STREAM_STATE => 5

  • STREAM_FINALIZED => 6

  • SCHEMA_MISMATCH_EXTRA_FIELDS => 7

  • OFFSET_ALREADY_EXISTS => 8

  • OFFSET_OUT_OF_RANGE => 9

  • CMEK_NOT_PROVIDED => 10

  • INVALID_CMEK_PROVIDED => 11

  • CMEK_ENCRYPTION_ERROR => 12

  • KMS_SERVICE_ERROR => 13

  • KMS_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 => 0

  • FIELDS_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.