-
Notifications
You must be signed in to change notification settings - Fork 461
Expand file tree
/
Copy pathStorage.php
More file actions
36 lines (30 loc) · 11.5 KB
/
Storage.php
File metadata and controls
36 lines (30 loc) · 11.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
<?php
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: google/cloud/bigquery/storage/v1/storage.proto
namespace GPBMetadata\Google\Cloud\Bigquery\Storage\V1;
class Storage
{
public static $is_initialized = false;
public static function initOnce() {
$pool = \Google\Protobuf\Internal\DescriptorPool::getGeneratedPool();
if (static::$is_initialized == true) {
return;
}
\GPBMetadata\Google\Api\Annotations::initOnce();
\GPBMetadata\Google\Api\Client::initOnce();
\GPBMetadata\Google\Api\FieldBehavior::initOnce();
\GPBMetadata\Google\Api\Resource::initOnce();
\GPBMetadata\Google\Cloud\Bigquery\Storage\V1\Arrow::initOnce();
\GPBMetadata\Google\Cloud\Bigquery\Storage\V1\Avro::initOnce();
\GPBMetadata\Google\Cloud\Bigquery\Storage\V1\Protobuf::initOnce();
\GPBMetadata\Google\Cloud\Bigquery\Storage\V1\Stream::initOnce();
\GPBMetadata\Google\Cloud\Bigquery\Storage\V1\Table::initOnce();
\GPBMetadata\Google\Protobuf\Timestamp::initOnce();
\GPBMetadata\Google\Protobuf\Wrappers::initOnce();
\GPBMetadata\Google\Rpc\Status::initOnce();
$pool->internalAddGeneratedFile(
"\x0A\xA2;\x0A.google/cloud/bigquery/storage/v1/storage.proto\x12 google.cloud.bigquery.storage.v1\x1A\x17google/api/client.proto\x1A\x1Fgoogle/api/field_behavior.proto\x1A\x19google/api/resource.proto\x1A,google/cloud/bigquery/storage/v1/arrow.proto\x1A+google/cloud/bigquery/storage/v1/avro.proto\x1A/google/cloud/bigquery/storage/v1/protobuf.proto\x1A-google/cloud/bigquery/storage/v1/stream.proto\x1A,google/cloud/bigquery/storage/v1/table.proto\x1A\x1Fgoogle/protobuf/timestamp.proto\x1A\x1Egoogle/protobuf/wrappers.proto\x1A\x17google/rpc/status.proto\"\xE7\x01\x0A\x18CreateReadSessionRequest\x12C\x0A\x06parent\x18\x01 \x01(\x09B3\xE0A\x02\xFAA-\x0A+cloudresourcemanager.googleapis.com/Project\x12H\x0A\x0Cread_session\x18\x02 \x01(\x0B2-.google.cloud.bigquery.storage.v1.ReadSessionB\x03\xE0A\x02\x12\x18\x0A\x10max_stream_count\x18\x03 \x01(\x05\x12\"\x0A\x1Apreferred_min_stream_count\x18\x04 \x01(\x05\"i\x0A\x0FReadRowsRequest\x12F\x0A\x0Bread_stream\x18\x01 \x01(\x09B1\xE0A\x02\xFAA+\x0A)bigquerystorage.googleapis.com/ReadStream\x12\x0E\x0A\x06offset\x18\x02 \x01(\x03\")\x0A\x0DThrottleState\x12\x18\x0A\x10throttle_percent\x18\x01 \x01(\x05\"\x97\x01\x0A\x0BStreamStats\x12H\x0A\x08progress\x18\x02 \x01(\x0B26.google.cloud.bigquery.storage.v1.StreamStats.Progress\x1A>\x0A\x08Progress\x12\x19\x0A\x11at_response_start\x18\x01 \x01(\x01\x12\x17\x0A\x0Fat_response_end\x18\x02 \x01(\x01\"\xAC\x04\x0A\x10ReadRowsResponse\x12?\x0A\x09avro_rows\x18\x03 \x01(\x0B2*.google.cloud.bigquery.storage.v1.AvroRowsH\x00\x12P\x0A\x12arrow_record_batch\x18\x04 \x01(\x0B22.google.cloud.bigquery.storage.v1.ArrowRecordBatchH\x00\x12\x11\x0A\x09row_count\x18\x06 \x01(\x03\x12<\x0A\x05stats\x18\x02 \x01(\x0B2-.google.cloud.bigquery.storage.v1.StreamStats\x12G\x0A\x0Ethrottle_state\x18\x05 \x01(\x0B2/.google.cloud.bigquery.storage.v1.ThrottleState\x12H\x0A\x0Bavro_schema\x18\x07 \x01(\x0B2,.google.cloud.bigquery.storage.v1.AvroSchemaB\x03\xE0A\x03H\x01\x12J\x0A\x0Carrow_schema\x18\x08 \x01(\x0B2-.google.cloud.bigquery.storage.v1.ArrowSchemaB\x03\xE0A\x03H\x01\x12(\x0A\x16uncompressed_byte_size\x18\x09 \x01(\x03B\x03\xE0A\x01H\x02\x88\x01\x01B\x06\x0A\x04rowsB\x08\x0A\x06schemaB\x19\x0A\x17_uncompressed_byte_size\"k\x0A\x16SplitReadStreamRequest\x12?\x0A\x04name\x18\x01 \x01(\x09B1\xE0A\x02\xFAA+\x0A)bigquerystorage.googleapis.com/ReadStream\x12\x10\x0A\x08fraction\x18\x02 \x01(\x01\"\xA7\x01\x0A\x17SplitReadStreamResponse\x12D\x0A\x0Eprimary_stream\x18\x01 \x01(\x0B2,.google.cloud.bigquery.storage.v1.ReadStream\x12F\x0A\x10remainder_stream\x18\x02 \x01(\x0B2,.google.cloud.bigquery.storage.v1.ReadStream\"\x9B\x01\x0A\x18CreateWriteStreamRequest\x125\x0A\x06parent\x18\x01 \x01(\x09B%\xE0A\x02\xFAA\x1F\x0A\x1Dbigquery.googleapis.com/Table\x12H\x0A\x0Cwrite_stream\x18\x02 \x01(\x0B2-.google.cloud.bigquery.storage.v1.WriteStreamB\x03\xE0A\x02\"\xF8\x08\x0A\x11AppendRowsRequest\x12H\x0A\x0Cwrite_stream\x18\x01 \x01(\x09B2\xE0A\x02\xFAA,\x0A*bigquerystorage.googleapis.com/WriteStream\x12+\x0A\x06offset\x18\x02 \x01(\x0B2\x1B.google.protobuf.Int64Value\x12S\x0A\x0Aproto_rows\x18\x04 \x01(\x0B2=.google.cloud.bigquery.storage.v1.AppendRowsRequest.ProtoDataH\x00\x12S\x0A\x0Aarrow_rows\x18\x05 \x01(\x0B2=.google.cloud.bigquery.storage.v1.AppendRowsRequest.ArrowDataH\x00\x12\x10\x0A\x08trace_id\x18\x06 \x01(\x09\x12{\x0A\x1Dmissing_value_interpretations\x18\x07 \x03(\x0B2T.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretationsEntry\x12\x81\x01\x0A\$default_missing_value_interpretation\x18\x08 \x01(\x0E2N.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretationB\x03\xE0A\x01\x1A\x93\x01\x0A\x09ArrowData\x12D\x0A\x0Dwriter_schema\x18\x01 \x01(\x0B2-.google.cloud.bigquery.storage.v1.ArrowSchema\x12@\x0A\x04rows\x18\x02 \x01(\x0B22.google.cloud.bigquery.storage.v1.ArrowRecordBatch\x1A\x8C\x01\x0A\x09ProtoData\x12D\x0A\x0Dwriter_schema\x18\x01 \x01(\x0B2-.google.cloud.bigquery.storage.v1.ProtoSchema\x129\x0A\x04rows\x18\x02 \x01(\x0B2+.google.cloud.bigquery.storage.v1.ProtoRows\x1A\x92\x01\x0A MissingValueInterpretationsEntry\x12\x0B\x0A\x03key\x18\x01 \x01(\x09\x12]\x0A\x05value\x18\x02 \x01(\x0E2N.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation:\x028\x01\"m\x0A\x1AMissingValueInterpretation\x12,\x0A(MISSING_VALUE_INTERPRETATION_UNSPECIFIED\x10\x00\x12\x0E\x0A\x0ANULL_VALUE\x10\x01\x12\x11\x0A\x0DDEFAULT_VALUE\x10\x02B\x06\x0A\x04rows\"\xFB\x02\x0A\x12AppendRowsResponse\x12Z\x0A\x0Dappend_result\x18\x01 \x01(\x0B2A.google.cloud.bigquery.storage.v1.AppendRowsResponse.AppendResultH\x00\x12#\x0A\x05error\x18\x02 \x01(\x0B2\x12.google.rpc.StatusH\x00\x12E\x0A\x0Eupdated_schema\x18\x03 \x01(\x0B2-.google.cloud.bigquery.storage.v1.TableSchema\x12>\x0A\x0Arow_errors\x18\x04 \x03(\x0B2*.google.cloud.bigquery.storage.v1.RowError\x12\x14\x0A\x0Cwrite_stream\x18\x05 \x01(\x09\x1A;\x0A\x0CAppendResult\x12+\x0A\x06offset\x18\x01 \x01(\x0B2\x1B.google.protobuf.Int64ValueB\x0A\x0A\x08response\"\x9A\x01\x0A\x15GetWriteStreamRequest\x12@\x0A\x04name\x18\x01 \x01(\x09B2\xE0A\x02\xFAA,\x0A*bigquerystorage.googleapis.com/WriteStream\x12?\x0A\x04view\x18\x03 \x01(\x0E21.google.cloud.bigquery.storage.v1.WriteStreamView\"s\x0A\x1EBatchCommitWriteStreamsRequest\x125\x0A\x06parent\x18\x01 \x01(\x09B%\xE0A\x02\xFAA\x1F\x0A\x1Dbigquery.googleapis.com/Table\x12\x1A\x0A\x0Dwrite_streams\x18\x02 \x03(\x09B\x03\xE0A\x02\"\x99\x01\x0A\x1FBatchCommitWriteStreamsResponse\x12/\x0A\x0Bcommit_time\x18\x01 \x01(\x0B2\x1A.google.protobuf.Timestamp\x12E\x0A\x0Dstream_errors\x18\x02 \x03(\x0B2..google.cloud.bigquery.storage.v1.StorageError\"^\x0A\x1AFinalizeWriteStreamRequest\x12@\x0A\x04name\x18\x01 \x01(\x09B2\xE0A\x02\xFAA,\x0A*bigquerystorage.googleapis.com/WriteStream\"0\x0A\x1BFinalizeWriteStreamResponse\x12\x11\x0A\x09row_count\x18\x01 \x01(\x03\"\x89\x01\x0A\x10FlushRowsRequest\x12H\x0A\x0Cwrite_stream\x18\x01 \x01(\x09B2\xE0A\x02\xFAA,\x0A*bigquerystorage.googleapis.com/WriteStream\x12+\x0A\x06offset\x18\x02 \x01(\x0B2\x1B.google.protobuf.Int64Value\"#\x0A\x11FlushRowsResponse\x12\x0E\x0A\x06offset\x18\x01 \x01(\x03\"\xA4\x04\x0A\x0CStorageError\x12M\x0A\x04code\x18\x01 \x01(\x0E2?.google.cloud.bigquery.storage.v1.StorageError.StorageErrorCode\x12\x0E\x0A\x06entity\x18\x02 \x01(\x09\x12\x15\x0A\x0Derror_message\x18\x03 \x01(\x09\"\x9D\x03\x0A\x10StorageErrorCode\x12\"\x0A\x1ESTORAGE_ERROR_CODE_UNSPECIFIED\x10\x00\x12\x13\x0A\x0FTABLE_NOT_FOUND\x10\x01\x12\x1C\x0A\x18STREAM_ALREADY_COMMITTED\x10\x02\x12\x14\x0A\x10STREAM_NOT_FOUND\x10\x03\x12\x17\x0A\x13INVALID_STREAM_TYPE\x10\x04\x12\x18\x0A\x14INVALID_STREAM_STATE\x10\x05\x12\x14\x0A\x10STREAM_FINALIZED\x10\x06\x12 \x0A\x1CSCHEMA_MISMATCH_EXTRA_FIELDS\x10\x07\x12\x19\x0A\x15OFFSET_ALREADY_EXISTS\x10\x08\x12\x17\x0A\x13OFFSET_OUT_OF_RANGE\x10\x09\x12\x15\x0A\x11CMEK_NOT_PROVIDED\x10\x0A\x12\x19\x0A\x15INVALID_CMEK_PROVIDED\x10\x0B\x12\x19\x0A\x15CMEK_ENCRYPTION_ERROR\x10\x0C\x12\x15\x0A\x11KMS_SERVICE_ERROR\x10\x0D\x12\x19\x0A\x15KMS_PERMISSION_DENIED\x10\x0E\"\xB3\x01\x0A\x08RowError\x12\x0D\x0A\x05index\x18\x01 \x01(\x03\x12E\x0A\x04code\x18\x02 \x01(\x0E27.google.cloud.bigquery.storage.v1.RowError.RowErrorCode\x12\x0F\x0A\x07message\x18\x03 \x01(\x09\"@\x0A\x0CRowErrorCode\x12\x1E\x0A\x1AROW_ERROR_CODE_UNSPECIFIED\x10\x00\x12\x10\x0A\x0CFIELDS_ERROR\x10\x012\x92\x06\x0A\x0CBigQueryRead\x12\xE9\x01\x0A\x11CreateReadSession\x12:.google.cloud.bigquery.storage.v1.CreateReadSessionRequest\x1A-.google.cloud.bigquery.storage.v1.ReadSession\"i\xDAA\$parent,read_session,max_stream_count\x82\xD3\xE4\x93\x02<\"7/v1/{read_session.table=projects/*/datasets/*/tables/*}:\x01*\x12\xCF\x01\x0A\x08ReadRows\x121.google.cloud.bigquery.storage.v1.ReadRowsRequest\x1A2.google.cloud.bigquery.storage.v1.ReadRowsResponse\"Z\xDAA\x12read_stream,offset\x82\xD3\xE4\x93\x02?\x12=/v1/{read_stream=projects/*/locations/*/sessions/*/streams/*}0\x01\x12\xC6\x01\x0A\x0FSplitReadStream\x128.google.cloud.bigquery.storage.v1.SplitReadStreamRequest\x1A9.google.cloud.bigquery.storage.v1.SplitReadStreamResponse\">\x82\xD3\xE4\x93\x028\x126/v1/{name=projects/*/locations/*/sessions/*/streams/*}\x1A{\xCAA\x1Ebigquerystorage.googleapis.com\xD2AWhttps://www.googleapis.com/auth/bigquery,https://www.googleapis.com/auth/cloud-platform2\xBC\x0B\x0A\x0DBigQueryWrite\x12\xD7\x01\x0A\x11CreateWriteStream\x12:.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest\x1A-.google.cloud.bigquery.storage.v1.WriteStream\"W\xDAA\x13parent,write_stream\x82\xD3\xE4\x93\x02;\"+/v1/{parent=projects/*/datasets/*/tables/*}:\x0Cwrite_stream\x12\xD2\x01\x0A\x0AAppendRows\x123.google.cloud.bigquery.storage.v1.AppendRowsRequest\x1A4.google.cloud.bigquery.storage.v1.AppendRowsResponse\"U\xDAA\x0Cwrite_stream\x82\xD3\xE4\x93\x02@\";/v1/{write_stream=projects/*/datasets/*/tables/*/streams/*}:\x01*(\x010\x01\x12\xBF\x01\x0A\x0EGetWriteStream\x127.google.cloud.bigquery.storage.v1.GetWriteStreamRequest\x1A-.google.cloud.bigquery.storage.v1.WriteStream\"E\xDAA\x04name\x82\xD3\xE4\x93\x028\"3/v1/{name=projects/*/datasets/*/tables/*/streams/*}:\x01*\x12\xD9\x01\x0A\x13FinalizeWriteStream\x12<.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest\x1A=.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse\"E\xDAA\x04name\x82\xD3\xE4\x93\x028\"3/v1/{name=projects/*/datasets/*/tables/*/streams/*}:\x01*\x12\xDC\x01\x0A\x17BatchCommitWriteStreams\x12@.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest\x1AA.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse\"<\xDAA\x06parent\x82\xD3\xE4\x93\x02-\x12+/v1/{parent=projects/*/datasets/*/tables/*}\x12\xCB\x01\x0A\x09FlushRows\x122.google.cloud.bigquery.storage.v1.FlushRowsRequest\x1A3.google.cloud.bigquery.storage.v1.FlushRowsResponse\"U\xDAA\x0Cwrite_stream\x82\xD3\xE4\x93\x02@\";/v1/{write_stream=projects/*/datasets/*/tables/*/streams/*}:\x01*\x1A\xB0\x01\xCAA\x1Ebigquerystorage.googleapis.com\xD2A\x8B\x01https://www.googleapis.com/auth/bigquery,https://www.googleapis.com/auth/bigquery.insertdata,https://www.googleapis.com/auth/cloud-platformB\x94\x02\x0A\$com.google.cloud.bigquery.storage.v1B\x0CStorageProtoP\x01Z>cloud.google.com/go/bigquery/storage/apiv1/storagepb;storagepb\xAA\x02 Google.Cloud.BigQuery.Storage.V1\xCA\x02 Google\\Cloud\\BigQuery\\Storage\\V1\xEAAU\x0A\x1Dbigquery.googleapis.com/Table\x124projects/{project}/datasets/{dataset}/tables/{table}b\x06proto3"
, true);
static::$is_initialized = true;
}
}