Package cloud.google.com/go/bigquery/storage/apiv1alpha/storagepb (v1.71.0)

const (
	MetastorePartitionService_BatchCreateMetastorePartitions_FullMethodName = "/google.cloud.bigquery.storage.v1alpha.MetastorePartitionService/BatchCreateMetastorePartitions"
	MetastorePartitionService_BatchDeleteMetastorePartitions_FullMethodName = "/google.cloud.bigquery.storage.v1alpha.MetastorePartitionService/BatchDeleteMetastorePartitions"
	MetastorePartitionService_BatchUpdateMetastorePartitions_FullMethodName = "/google.cloud.bigquery.storage.v1alpha.MetastorePartitionService/BatchUpdateMetastorePartitions"
	MetastorePartitionService_ListMetastorePartitions_FullMethodName        = "/google.cloud.bigquery.storage.v1alpha.MetastorePartitionService/ListMetastorePartitions"
	MetastorePartitionService_StreamMetastorePartitions_FullMethodName      = "/google.cloud.bigquery.storage.v1alpha.MetastorePartitionService/StreamMetastorePartitions"
)

var File_google_cloud_bigquery_storage_v1alpha_metastore_partition_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_storage_v1alpha_partition_proto protoreflect.FileDescriptor

var MetastorePartitionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.bigquery.storage.v1alpha.MetastorePartitionService",
	HandlerType: (*MetastorePartitionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BatchCreateMetastorePartitions",
			Handler:    _MetastorePartitionService_BatchCreateMetastorePartitions_Handler,
		},
		{
			MethodName: "BatchDeleteMetastorePartitions",
			Handler:    _MetastorePartitionService_BatchDeleteMetastorePartitions_Handler,
		},
		{
			MethodName: "BatchUpdateMetastorePartitions",
			Handler:    _MetastorePartitionService_BatchUpdateMetastorePartitions_Handler,
		},
		{
			MethodName: "ListMetastorePartitions",
			Handler:    _MetastorePartitionService_ListMetastorePartitions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamMetastorePartitions",
			Handler:       _MetastorePartitionService_StreamMetastorePartitions_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "google/cloud/bigquery/storage/v1alpha/metastore_partition.proto",
}

func RegisterMetastorePartitionServiceServer(s grpc.ServiceRegistrar, srv MetastorePartitionServiceServer)

type BatchCreateMetastorePartitionsRequest struct {

	// Required. Reference to the table to where the metastore partitions to be
	// added, in the format of
	// projects/{project}/locations/{location}/datasets/{dataset}/tables/{table}.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Requests to add metastore partitions to the table.
	Requests []*CreateMetastorePartitionRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// Optional. Mimics the ifNotExists flag in IMetaStoreClient
	// add_partitions(..). If the flag is set to false, the server will return
	// ALREADY_EXISTS if any partition already exists. If the flag is set to true,
	// the server will skip existing partitions and insert only the non-existing
	// partitions. A maximum of 900 partitions can be inserted in a batch.
	SkipExistingPartitions bool `protobuf:"varint,3,opt,name=skip_existing_partitions,json=skipExistingPartitions,proto3" json:"skip_existing_partitions,omitempty"`
	// Optional. Optional trace id to be used for debugging. It is expected that
	// the client sets the same `trace_id` for all the batches in the same
	// operation, so that it is possible to tie together the logs to all the
	// batches in the same operation. Limited to 256 characters. This is expected,
	// but not required, to be globally unique.
	TraceId string `protobuf:"bytes,4,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchCreateMetastorePartitionsRequest) Descriptor() ([]byte, []int)

func (x *BatchCreateMetastorePartitionsRequest) GetParent() string

func (x *BatchCreateMetastorePartitionsRequest) GetRequests() []*CreateMetastorePartitionRequest

func (x *BatchCreateMetastorePartitionsRequest) GetSkipExistingPartitions() bool

func (x *BatchCreateMetastorePartitionsRequest) GetTraceId() string

func (*BatchCreateMetastorePartitionsRequest) ProtoMessage()

func (x *BatchCreateMetastorePartitionsRequest) ProtoReflect() protoreflect.Message

func (x *BatchCreateMetastorePartitionsRequest) Reset()

func (x *BatchCreateMetastorePartitionsRequest) String() string

type BatchCreateMetastorePartitionsResponse struct {

	// The list of metastore partitions that have been created.
	Partitions []*MetastorePartition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchCreateMetastorePartitionsResponse) Descriptor() ([]byte, []int)

func (x *BatchCreateMetastorePartitionsResponse) GetPartitions() []*MetastorePartition

func (*BatchCreateMetastorePartitionsResponse) ProtoMessage()

func (x *BatchCreateMetastorePartitionsResponse) ProtoReflect() protoreflect.Message

func (x *BatchCreateMetastorePartitionsResponse) Reset()

func (x *BatchCreateMetastorePartitionsResponse) String() string

type BatchDeleteMetastorePartitionsRequest struct {

	// Required. Reference to the table to which these metastore partitions
	// belong, in the format of
	// projects/{project}/locations/{location}/datasets/{dataset}/tables/{table}.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The list of metastore partitions (identified by its values) to be
	// deleted. A maximum of 900 partitions can be deleted in a batch.
	PartitionValues []*MetastorePartitionValues `protobuf:"bytes,2,rep,name=partition_values,json=partitionValues,proto3" json:"partition_values,omitempty"`
	// Optional. Optional trace id to be used for debugging. It is expected that
	// the client sets the same `trace_id` for all the batches in the same
	// operation, so that it is possible to tie together the logs to all the
	// batches in the same operation. This is expected, but not required, to be
	// globally unique.
	TraceId string `protobuf:"bytes,4,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchDeleteMetastorePartitionsRequest) Descriptor() ([]byte, []int)

func (x *BatchDeleteMetastorePartitionsRequest) GetParent() string

func (x *BatchDeleteMetastorePartitionsRequest) GetPartitionValues() []*MetastorePartitionValues

func (x *BatchDeleteMetastorePartitionsRequest) GetTraceId() string

func (*BatchDeleteMetastorePartitionsRequest) ProtoMessage()

func (x *BatchDeleteMetastorePartitionsRequest) ProtoReflect() protoreflect.Message

func (x *BatchDeleteMetastorePartitionsRequest) Reset()

func (x *BatchDeleteMetastorePartitionsRequest) String() string

type BatchSizeTooLargeError struct {

	// The maximum number of items that are supported in a single batch. This is
	// returned as a hint to the client to adjust the batch size.
	MaxBatchSize int64 `protobuf:"varint,1,opt,name=max_batch_size,json=maxBatchSize,proto3" json:"max_batch_size,omitempty"`
	// Optional. The error message that is returned to the client.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchSizeTooLargeError) Descriptor() ([]byte, []int)

func (x *BatchSizeTooLargeError) GetErrorMessage() string

func (x *BatchSizeTooLargeError) GetMaxBatchSize() int64

func (*BatchSizeTooLargeError) ProtoMessage()

func (x *BatchSizeTooLargeError) ProtoReflect() protoreflect.Message

func (x *BatchSizeTooLargeError) Reset()

func (x *BatchSizeTooLargeError) String() string

type BatchUpdateMetastorePartitionsRequest struct {

	// Required. Reference to the table to which these metastore partitions
	// belong, in the format of
	// projects/{project}/locations/{location}/datasets/{dataset}/tables/{table}.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Requests to update metastore partitions in the table.
	Requests []*UpdateMetastorePartitionRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// Optional. Optional trace id to be used for debugging. It is expected that
	// the client sets the same `trace_id` for all the batches in the same
	// operation, so that it is possible to tie together the logs to all the
	// batches in the same operation. This is expected, but not required, to be
	// globally unique.
	TraceId string `protobuf:"bytes,4,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchUpdateMetastorePartitionsRequest) Descriptor() ([]byte, []int)

func (x *BatchUpdateMetastorePartitionsRequest) GetParent() string

func (x *BatchUpdateMetastorePartitionsRequest) GetRequests() []*UpdateMetastorePartitionRequest

func (x *BatchUpdateMetastorePartitionsRequest) GetTraceId() string

func (*BatchUpdateMetastorePartitionsRequest) ProtoMessage()

func (x *BatchUpdateMetastorePartitionsRequest) ProtoReflect() protoreflect.Message

func (x *BatchUpdateMetastorePartitionsRequest) Reset()

func (x *BatchUpdateMetastorePartitionsRequest) String() string

type BatchUpdateMetastorePartitionsResponse struct {

	// The list of metastore partitions that have been updated.
	// A maximum of 900 partitions can be updated in a batch.
	Partitions []*MetastorePartition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchUpdateMetastorePartitionsResponse) Descriptor() ([]byte, []int)

func (x *BatchUpdateMetastorePartitionsResponse) GetPartitions() []*MetastorePartition

func (*BatchUpdateMetastorePartitionsResponse) ProtoMessage()

func (x *BatchUpdateMetastorePartitionsResponse) ProtoReflect() protoreflect.Message

func (x *BatchUpdateMetastorePartitionsResponse) Reset()

func (x *BatchUpdateMetastorePartitionsResponse) String() string

type CreateMetastorePartitionRequest struct {

	// Required. Reference to the table to where the metastore partition to be
	// added, in the format of
	// projects/{project}/databases/{databases}/tables/{table}.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The metastore partition to be added.
	MetastorePartition *MetastorePartition `protobuf:"bytes,2,opt,name=metastore_partition,json=metastorePartition,proto3" json:"metastore_partition,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateMetastorePartitionRequest) Descriptor() ([]byte, []int)

func (x *CreateMetastorePartitionRequest) GetMetastorePartition() *MetastorePartition

func (x *CreateMetastorePartitionRequest) GetParent() string

func (*CreateMetastorePartitionRequest) ProtoMessage()

func (x *CreateMetastorePartitionRequest) ProtoReflect() protoreflect.Message

func (x *CreateMetastorePartitionRequest) Reset()

func (x *CreateMetastorePartitionRequest) String() string

type FieldSchema struct {

	// Required. The name of the column.
	// The maximum length of the name is 1024 characters
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The type of the metastore partition column. Maximum allowed
	// length is 1024 characters.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldSchema) Descriptor() ([]byte, []int)

func (x *FieldSchema) GetName() string

func (x *FieldSchema) GetType() string

func (*FieldSchema) ProtoMessage()

func (x *FieldSchema) ProtoReflect() protoreflect.Message

func (x *FieldSchema) Reset()

func (x *FieldSchema) String() string

type ListMetastorePartitionsRequest struct {

	// Required. Reference to the table to which these metastore partitions
	// belong, in the format of
	// projects/{project}/locations/{location}/datasets/{dataset}/tables/{table}.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. SQL text filtering statement, similar to a WHERE clause in a
	// query. Only supports single-row expressions.  Aggregate functions are not
	// supported.
	//
	// Examples: "int_field > 5"
	//
	//	"date_field = CAST('2014-9-27' as DATE)"
	//	"nullable_field is not NULL"
	//	"st_equals(geo_field, st_geofromtext("POINT(2, 2)"))"
	//	"numeric_field BETWEEN 1.0 AND 5.0"
	//
	// Restricted to a maximum length for 1 MB.
	Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// Optional. Optional trace id to be used for debugging. It is expected that
	// the client sets the same `trace_id` for all the batches in the same
	// operation, so that it is possible to tie together the logs to all the
	// batches in the same operation. Limited to 256 characters. This is expected,
	// but not required, to be globally unique.
	TraceId string `protobuf:"bytes,3,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMetastorePartitionsRequest) Descriptor() ([]byte, []int)

func (x *ListMetastorePartitionsRequest) GetFilter() string

func (x *ListMetastorePartitionsRequest) GetParent() string

func (x *ListMetastorePartitionsRequest) GetTraceId() string

func (*ListMetastorePartitionsRequest) ProtoMessage()

func (x *ListMetastorePartitionsRequest) ProtoReflect() protoreflect.Message

func (x *ListMetastorePartitionsRequest) Reset()

func (x *ListMetastorePartitionsRequest) String() string

type ListMetastorePartitionsResponse struct {

	// The response depends on the number of metastore partitions to be returned;
	// it can be a list of partitions or a list of
	// [ReadStream]((https://cloud.google.com/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1#readstream))
	// objects. For the second situation, the BigQuery [Read API
	// ReadRows](https://cloud.google.com/bigquery/docs/reference/storage#read_from_a_session_stream)
	// method must be used to stream the data and convert it into a list of
	// partitions.
	//
	// Types that are assignable to Response:
	//
	//	*ListMetastorePartitionsResponse_Partitions
	//	*ListMetastorePartitionsResponse_Streams
	Response isListMetastorePartitionsResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*ListMetastorePartitionsResponse) Descriptor() ([]byte, []int)

func (x *ListMetastorePartitionsResponse) GetPartitions() *MetastorePartitionList

func (m *ListMetastorePartitionsResponse) GetResponse() isListMetastorePartitionsResponse_Response

func (x *ListMetastorePartitionsResponse) GetStreams() *StreamList

func (*ListMetastorePartitionsResponse) ProtoMessage()

func (x *ListMetastorePartitionsResponse) ProtoReflect() protoreflect.Message

func (x *ListMetastorePartitionsResponse) Reset()

func (x *ListMetastorePartitionsResponse) String() string

type ListMetastorePartitionsResponse_Partitions struct {
	// The list of partitions.
	Partitions *MetastorePartitionList `protobuf:"bytes,1,opt,name=partitions,proto3,oneof"`
}

type ListMetastorePartitionsResponse_Streams struct {
	// The list of streams.
	Streams *StreamList `protobuf:"bytes,2,opt,name=streams,proto3,oneof"`
}

type MetastorePartition struct {

	// Required. Represents the values of the partition keys, where each value
	// corresponds to a specific partition key in the order in which the keys are
	// defined. Each value is limited to 1024 characters.
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// Output only. The creation time of the partition.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Optional. Contains information about the physical storage of the data in
	// the partition.
	StorageDescriptor *StorageDescriptor `protobuf:"bytes,3,opt,name=storage_descriptor,json=storageDescriptor,proto3" json:"storage_descriptor,omitempty"`
	// Optional. Additional parameters or metadata associated with the partition.
	// Maximum size 10 KiB.
	Parameters map[string]string `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. List of columns.
	Fields []*FieldSchema `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*MetastorePartition) Descriptor() ([]byte, []int)

func (x *MetastorePartition) GetCreateTime() *timestamppb.Timestamp

func (x *MetastorePartition) GetFields() []*FieldSchema

func (x *MetastorePartition) GetParameters() map[string]string

func (x *MetastorePartition) GetStorageDescriptor() *StorageDescriptor

func (x *MetastorePartition) GetValues() []string

func (*MetastorePartition) ProtoMessage()

func (x *MetastorePartition) ProtoReflect() protoreflect.Message

func (x *MetastorePartition) Reset()

func (x *MetastorePartition) String() string

type MetastorePartitionList struct {

	// Required. List of partitions.
	Partitions []*MetastorePartition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*MetastorePartitionList) Descriptor() ([]byte, []int)

func (x *MetastorePartitionList) GetPartitions() []*MetastorePartition

func (*MetastorePartitionList) ProtoMessage()

func (x *MetastorePartitionList) ProtoReflect() protoreflect.Message

func (x *MetastorePartitionList) Reset()

func (x *MetastorePartitionList) String() string

type MetastorePartitionServiceClient interface {
	// Adds metastore partitions to a table.
	BatchCreateMetastorePartitions(ctx context.Context, in *BatchCreateMetastorePartitionsRequest, opts ...grpc.CallOption) (*BatchCreateMetastorePartitionsResponse, error)
	// Deletes metastore partitions from a table.
	BatchDeleteMetastorePartitions(ctx context.Context, in *BatchDeleteMetastorePartitionsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Updates metastore partitions in a table.
	BatchUpdateMetastorePartitions(ctx context.Context, in *BatchUpdateMetastorePartitionsRequest, opts ...grpc.CallOption) (*BatchUpdateMetastorePartitionsResponse, error)
	// Gets metastore partitions from a table.
	ListMetastorePartitions(ctx context.Context, in *ListMetastorePartitionsRequest, opts ...grpc.CallOption) (*ListMetastorePartitionsResponse, error)
	// This is a bi-di streaming rpc method that allows the client to send
	// a stream of partitions and commit all of them atomically at the end.
	// If the commit is successful, the server will return a
	// response and close the stream. If the commit fails (due to duplicate
	// partitions or other reason), the server will close the stream with an
	// error. This method is only available via the gRPC API (not REST).
	StreamMetastorePartitions(ctx context.Context, opts ...grpc.CallOption) (MetastorePartitionService_StreamMetastorePartitionsClient, error)
}

func NewMetastorePartitionServiceClient(cc grpc.ClientConnInterface) MetastorePartitionServiceClient

type MetastorePartitionServiceServer interface {
	// Adds metastore partitions to a table.
	BatchCreateMetastorePartitions(context.Context, *BatchCreateMetastorePartitionsRequest) (*BatchCreateMetastorePartitionsResponse, error)
	// Deletes metastore partitions from a table.
	BatchDeleteMetastorePartitions(context.Context, *BatchDeleteMetastorePartitionsRequest) (*emptypb.Empty, error)
	// Updates metastore partitions in a table.
	BatchUpdateMetastorePartitions(context.Context, *BatchUpdateMetastorePartitionsRequest) (*BatchUpdateMetastorePartitionsResponse, error)
	// Gets metastore partitions from a table.
	ListMetastorePartitions(context.Context, *ListMetastorePartitionsRequest) (*ListMetastorePartitionsResponse, error)
	// This is a bi-di streaming rpc method that allows the client to send
	// a stream of partitions and commit all of them atomically at the end.
	// If the commit is successful, the server will return a
	// response and close the stream. If the commit fails (due to duplicate
	// partitions or other reason), the server will close the stream with an
	// error. This method is only available via the gRPC API (not REST).
	StreamMetastorePartitions(MetastorePartitionService_StreamMetastorePartitionsServer) error
}

type MetastorePartitionService_StreamMetastorePartitionsClient interface {
	Send(*StreamMetastorePartitionsRequest) error
	Recv() (*StreamMetastorePartitionsResponse, error)
	grpc.ClientStream
}

type MetastorePartitionService_StreamMetastorePartitionsServer interface {
	Send(*StreamMetastorePartitionsResponse) error
	Recv() (*StreamMetastorePartitionsRequest, error)
	grpc.ServerStream
}

type MetastorePartitionValues struct {

	// Required. The values of the partition keys, where each value corresponds to
	// a specific partition key in the order in which the keys are defined.
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MetastorePartitionValues) Descriptor() ([]byte, []int)

func (x *MetastorePartitionValues) GetValues() []string

func (*MetastorePartitionValues) ProtoMessage()

func (x *MetastorePartitionValues) ProtoReflect() protoreflect.Message

func (x *MetastorePartitionValues) Reset()

func (x *MetastorePartitionValues) String() string

type ReadStream struct {

	// Output only. Identifier. Name of the stream, in the form
	// `projects/{project_id}/locations/{location}/sessions/{session_id}/streams/{stream_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadStream) Descriptor() ([]byte, []int)

func (x *ReadStream) GetName() string

func (*ReadStream) ProtoMessage()

func (x *ReadStream) ProtoReflect() protoreflect.Message

func (x *ReadStream) Reset()

func (x *ReadStream) String() string

type SerDeInfo struct {

	// Optional. Name of the SerDe.
	// The maximum length is 256 characters.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Specifies a fully-qualified class name of the serialization
	// library that is responsible for the translation of data between table
	// representation and the underlying low-level input and output format
	// structures. The maximum length is 256 characters.
	SerializationLibrary string `protobuf:"bytes,2,opt,name=serialization_library,json=serializationLibrary,proto3" json:"serialization_library,omitempty"`
	// Optional. Key-value pairs that define the initialization parameters for the
	// serialization library.
	// Maximum size 10 Kib.
	Parameters map[string]string `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

func (*SerDeInfo) Descriptor() ([]byte, []int)

func (x *SerDeInfo) GetName() string

func (x *SerDeInfo) GetParameters() map[string]string

func (x *SerDeInfo) GetSerializationLibrary() string

func (*SerDeInfo) ProtoMessage()

func (x *SerDeInfo) ProtoReflect() protoreflect.Message

func (x *SerDeInfo) Reset()

func (x *SerDeInfo) String() string

type StorageDescriptor struct {

	// Optional. The physical location of the metastore partition
	// (e.g. `gs://spark-dataproc-data/pangea-data/case_sensitive/` or
	// `gs://spark-dataproc-data/pangea-data/*`).
	LocationUri string `protobuf:"bytes,1,opt,name=location_uri,json=locationUri,proto3" json:"location_uri,omitempty"`
	// Optional. Specifies the fully qualified class name of the InputFormat
	// (e.g. "org.apache.hadoop.hive.ql.io.orc.OrcInputFormat").
	// The maximum length is 128 characters.
	InputFormat string `protobuf:"bytes,2,opt,name=input_format,json=inputFormat,proto3" json:"input_format,omitempty"`
	// Optional. Specifies the fully qualified class name of the OutputFormat
	// (e.g. "org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat").
	// The maximum length is 128 characters.
	OutputFormat string `protobuf:"bytes,3,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"`
	// Optional. Serializer and deserializer information.
	SerdeInfo *SerDeInfo `protobuf:"bytes,4,opt,name=serde_info,json=serdeInfo,proto3" json:"serde_info,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageDescriptor) Descriptor() ([]byte, []int)

func (x *StorageDescriptor) GetInputFormat() string

func (x *StorageDescriptor) GetLocationUri() string

func (x *StorageDescriptor) GetOutputFormat() string

func (x *StorageDescriptor) GetSerdeInfo() *SerDeInfo

func (*StorageDescriptor) ProtoMessage()

func (x *StorageDescriptor) ProtoReflect() protoreflect.Message

func (x *StorageDescriptor) Reset()

func (x *StorageDescriptor) String() string

type StreamList struct {

	// Output only. List of streams.
	Streams []*ReadStream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamList) Descriptor() ([]byte, []int)

func (x *StreamList) GetStreams() []*ReadStream

func (*StreamList) ProtoMessage()

func (x *StreamList) ProtoReflect() protoreflect.Message

func (x *StreamList) Reset()

func (x *StreamList) String() string

type StreamMetastorePartitionsRequest struct {

	// Required. Reference to the table to where the partition to be added, in the
	// format of
	// projects/{project}/locations/{location}/datasets/{dataset}/tables/{table}.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. A list of metastore partitions to be added to the table.
	MetastorePartitions []*MetastorePartition `protobuf:"bytes,2,rep,name=metastore_partitions,json=metastorePartitions,proto3" json:"metastore_partitions,omitempty"`
	// Optional. Mimics the ifNotExists flag in IMetaStoreClient
	// add_partitions(..). If the flag is set to false, the server will return
	// ALREADY_EXISTS on commit if any partition already exists. If the flag is
	// set to true:
	//  1. the server will skip existing partitions
	//     insert only the non-existing partitions as part of the commit.
	//  2. The client must set the `skip_existing_partitions` field to true for
	//     all requests in the stream.
	SkipExistingPartitions bool `protobuf:"varint,3,opt,name=skip_existing_partitions,json=skipExistingPartitions,proto3" json:"skip_existing_partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMetastorePartitionsRequest) Descriptor() ([]byte, []int)

func (x *StreamMetastorePartitionsRequest) GetMetastorePartitions() []*MetastorePartition

func (x *StreamMetastorePartitionsRequest) GetParent() string

func (x *StreamMetastorePartitionsRequest) GetSkipExistingPartitions() bool

func (*StreamMetastorePartitionsRequest) ProtoMessage()

func (x *StreamMetastorePartitionsRequest) ProtoReflect() protoreflect.Message

func (x *StreamMetastorePartitionsRequest) Reset()

func (x *StreamMetastorePartitionsRequest) String() string

type StreamMetastorePartitionsResponse struct {

	// Total count of partitions streamed by the client during the lifetime of the
	// stream. This is only set in the final response message before closing the
	// stream.
	TotalPartitionsStreamedCount int64 `protobuf:"varint,2,opt,name=total_partitions_streamed_count,json=totalPartitionsStreamedCount,proto3" json:"total_partitions_streamed_count,omitempty"`
	// Total count of partitions inserted by the server during the lifetime of the
	// stream. This is only set in the final response message before closing the
	// stream.
	TotalPartitionsInsertedCount int64 `protobuf:"varint,3,opt,name=total_partitions_inserted_count,json=totalPartitionsInsertedCount,proto3" json:"total_partitions_inserted_count,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMetastorePartitionsResponse) Descriptor() ([]byte, []int)

func (x *StreamMetastorePartitionsResponse) GetTotalPartitionsInsertedCount() int64

func (x *StreamMetastorePartitionsResponse) GetTotalPartitionsStreamedCount() int64

func (*StreamMetastorePartitionsResponse) ProtoMessage()

func (x *StreamMetastorePartitionsResponse) ProtoReflect() protoreflect.Message

func (x *StreamMetastorePartitionsResponse) Reset()

func (x *StreamMetastorePartitionsResponse) String() string

type UnimplementedMetastorePartitionServiceServer struct {
}

func (UnimplementedMetastorePartitionServiceServer) BatchCreateMetastorePartitions(context.Context, *BatchCreateMetastorePartitionsRequest) (*BatchCreateMetastorePartitionsResponse, error)

func (UnimplementedMetastorePartitionServiceServer) BatchDeleteMetastorePartitions(context.Context, *BatchDeleteMetastorePartitionsRequest) (*emptypb.Empty, error)

func (UnimplementedMetastorePartitionServiceServer) BatchUpdateMetastorePartitions(context.Context, *BatchUpdateMetastorePartitionsRequest) (*BatchUpdateMetastorePartitionsResponse, error)

func (UnimplementedMetastorePartitionServiceServer) ListMetastorePartitions(context.Context, *ListMetastorePartitionsRequest) (*ListMetastorePartitionsResponse, error)

func (UnimplementedMetastorePartitionServiceServer) StreamMetastorePartitions(MetastorePartitionService_StreamMetastorePartitionsServer) error

type UnsafeMetastorePartitionServiceServer interface {
	// contains filtered or unexported methods
}

type UpdateMetastorePartitionRequest struct {

	// Required. The metastore partition to be updated.
	MetastorePartition *MetastorePartition `protobuf:"bytes,1,opt,name=metastore_partition,json=metastorePartition,proto3" json:"metastore_partition,omitempty"`
	// Optional. The list of fields to update.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMetastorePartitionRequest) Descriptor() ([]byte, []int)

func (x *UpdateMetastorePartitionRequest) GetMetastorePartition() *MetastorePartition

func (x *UpdateMetastorePartitionRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateMetastorePartitionRequest) ProtoMessage()

func (x *UpdateMetastorePartitionRequest) ProtoReflect() protoreflect.Message

func (x *UpdateMetastorePartitionRequest) Reset()

func (x *UpdateMetastorePartitionRequest) String() string