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

var File_google_cloud_bigquery_storage_v1alpha_metastore_partition_proto protoreflect.FileDescriptor

var File_google_cloud_bigquery_storage_v1alpha_partition_proto protoreflect.FileDescriptor

func RegisterMetastorePartitionServiceServer(s *grpc.Server, srv MetastorePartitionServiceServer)

type BatchCreateMetastorePartitionsRequest struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`

	Requests []*CreateMetastorePartitionRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`

	SkipExistingPartitions bool "" /* 130 byte string literal not displayed */

}

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

func (x *BatchCreateMetastorePartitionsRequest) GetParent() string

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

func (x *BatchCreateMetastorePartitionsRequest) GetSkipExistingPartitions() bool

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 100 partitions can be deleted in a batch.
	PartitionValues []*MetastorePartitionValues `protobuf:"bytes,2,rep,name=partition_values,json=partitionValues,proto3" json:"partition_values,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *BatchDeleteMetastorePartitionsRequest) GetParent() string

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

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"`
	// contains filtered or unexported fields
}

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

func (x *BatchUpdateMetastorePartitionsRequest) GetParent() string

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

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.
	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"`
	// contains filtered or unexported fields
}

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

func (x *ListMetastorePartitionsRequest) GetFilter() string

func (x *ListMetastorePartitionsRequest) GetParent() 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 {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	StorageDescriptor *StorageDescriptor `protobuf:"bytes,3,opt,name=storage_descriptor,json=storageDescriptor,proto3" json:"storage_descriptor,omitempty"`

	Parameters map[string]string "" /* 161 byte string literal not displayed */

	Fields []*FieldSchema `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`

}

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 {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	SerializationLibrary string `protobuf:"bytes,2,opt,name=serialization_library,json=serializationLibrary,proto3" json:"serialization_library,omitempty"`

	Parameters map[string]string "" /* 161 byte string literal not displayed */

}

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 {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`

	MetastorePartitions []*MetastorePartition `protobuf:"bytes,2,rep,name=metastore_partitions,json=metastorePartitions,proto3" json:"metastore_partitions,omitempty"`

	SkipExistingPartitions bool "" /* 130 byte string literal not displayed */

}

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 {
	TotalPartitionsStreamedCount int64 "" /* 150 byte string literal not displayed */

	TotalPartitionsInsertedCount int64 "" /* 150 byte string literal not displayed */

}

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