Enum value maps for TableView.
var (
TableView_name = map[int32]string{
0: "TABLE_VIEW_UNSPECIFIED",
1: "BASIC",
2: "FULL",
}
TableView_value = map[string]int32{
"TABLE_VIEW_UNSPECIFIED": 0,
"BASIC": 1,
"FULL": 2,
}
)
Enum value maps for Database_Type.
var (
Database_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "HIVE",
}
Database_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"HIVE": 1,
}
)
Enum value maps for Table_Type.
var (
Table_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "HIVE",
}
Table_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"HIVE": 1,
}
)
var File_google_cloud_bigquery_biglake_v1_metastore_proto protoreflect.FileDescriptor
func RegisterMetastoreServiceServer(s *grpc.Server, srv MetastoreServiceServer)
Catalog is the container of databases.
type Catalog struct {
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the catalog.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last modification time of the catalog.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The deletion time of the catalog. Only set after the catalog
// is deleted.
DeleteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
// Output only. The time when this catalog is considered expired. Only set
// after the catalog is deleted.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// contains filtered or unexported fields
}
func (*Catalog) Descriptor() ([]byte, []int)
Deprecated: Use Catalog.ProtoReflect.Descriptor instead.
func (x *Catalog) GetCreateTime() *timestamppb.Timestamp
func (x *Catalog) GetDeleteTime() *timestamppb.Timestamp
func (x *Catalog) GetExpireTime() *timestamppb.Timestamp
func (x *Catalog) GetName() string
func (x *Catalog) GetUpdateTime() *timestamppb.Timestamp
func (*Catalog) ProtoMessage()
func (x *Catalog) ProtoReflect() protoreflect.Message
func (x *Catalog) Reset()
func (x *Catalog) String() string
Request message for the CreateCatalog method.
type CreateCatalogRequest struct {
// Required. The parent resource where this catalog will be created.
// Format: projects/{project_id_or_number}/locations/{location_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The catalog to create.
// The `name` field does not need to be provided.
Catalog *Catalog `protobuf:"bytes,2,opt,name=catalog,proto3" json:"catalog,omitempty"`
// Required. The ID to use for the catalog, which will become the final
// component of the catalog's resource name.
CatalogId string `protobuf:"bytes,3,opt,name=catalog_id,json=catalogId,proto3" json:"catalog_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateCatalogRequest.ProtoReflect.Descriptor instead.
func (x *CreateCatalogRequest) GetCatalog() *Catalog
func (x *CreateCatalogRequest) GetCatalogId() string
func (x *CreateCatalogRequest) GetParent() string
func (*CreateCatalogRequest) ProtoMessage()
func (x *CreateCatalogRequest) ProtoReflect() protoreflect.Message
func (x *CreateCatalogRequest) Reset()
func (x *CreateCatalogRequest) String() string
Request message for the CreateDatabase method.
type CreateDatabaseRequest struct {
// Required. The parent resource where this database will be created.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The database to create.
// The `name` field does not need to be provided.
Database *Database `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
// Required. The ID to use for the database, which will become the final
// component of the database's resource name.
DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDatabaseRequest.ProtoReflect.Descriptor instead.
func (x *CreateDatabaseRequest) GetDatabase() *Database
func (x *CreateDatabaseRequest) GetDatabaseId() string
func (x *CreateDatabaseRequest) GetParent() string
func (*CreateDatabaseRequest) ProtoMessage()
func (x *CreateDatabaseRequest) ProtoReflect() protoreflect.Message
func (x *CreateDatabaseRequest) Reset()
func (x *CreateDatabaseRequest) String() string
Request message for the CreateTable method.
type CreateTableRequest struct {
// Required. The parent resource where this table will be created.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The table to create. The `name` field does not need to be
// provided for the table creation.
Table *Table `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
// Required. The ID to use for the table, which will become the final
// component of the table's resource name.
TableId string `protobuf:"bytes,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.
func (x *CreateTableRequest) GetParent() string
func (x *CreateTableRequest) GetTable() *Table
func (x *CreateTableRequest) GetTableId() string
func (*CreateTableRequest) ProtoMessage()
func (x *CreateTableRequest) ProtoReflect() protoreflect.Message
func (x *CreateTableRequest) Reset()
func (x *CreateTableRequest) String() string
Database is the container of tables.
type Database struct {
// Options specified for the database type.
//
// Types that are assignable to Options:
//
// *Database_HiveOptions
Options isDatabase_Options `protobuf_oneof:"options"`
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the database.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last modification time of the database.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The deletion time of the database. Only set after the database
// is deleted.
DeleteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
// Output only. The time when this database is considered expired. Only set
// after the database is deleted.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// The database type.
Type Database_Type `protobuf:"varint,6,opt,name=type,proto3,enum=google.cloud.bigquery.biglake.v1.Database_Type" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*Database) Descriptor() ([]byte, []int)
Deprecated: Use Database.ProtoReflect.Descriptor instead.
func (x *Database) GetCreateTime() *timestamppb.Timestamp
func (x *Database) GetDeleteTime() *timestamppb.Timestamp
func (x *Database) GetExpireTime() *timestamppb.Timestamp
func (x *Database) GetHiveOptions() *HiveDatabaseOptions
func (x *Database) GetName() string
func (m *Database) GetOptions() isDatabase_Options
func (x *Database) GetType() Database_Type
func (x *Database) GetUpdateTime() *timestamppb.Timestamp
func (*Database) ProtoMessage()
func (x *Database) ProtoReflect() protoreflect.Message
func (x *Database) Reset()
func (x *Database) String() string
type Database_HiveOptions struct {
// Options of a Hive database.
HiveOptions *HiveDatabaseOptions `protobuf:"bytes,7,opt,name=hive_options,json=hiveOptions,proto3,oneof"`
}
The database type.
type Database_Type int32
const (
// The type is not specified.
Database_TYPE_UNSPECIFIED Database_Type = 0
// Represents a database storing tables compatible with Hive Metastore
// tables.
Database_HIVE Database_Type = 1
)
func (Database_Type) Descriptor() protoreflect.EnumDescriptor
func (x Database_Type) Enum() *Database_Type
func (Database_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Database_Type.Descriptor instead.
func (x Database_Type) Number() protoreflect.EnumNumber
func (x Database_Type) String() string
func (Database_Type) Type() protoreflect.EnumType
Request message for the DeleteCatalog method.
type DeleteCatalogRequest struct {
// Required. The name of the catalog to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCatalogRequest.ProtoReflect.Descriptor instead.
func (x *DeleteCatalogRequest) GetName() string
func (*DeleteCatalogRequest) ProtoMessage()
func (x *DeleteCatalogRequest) ProtoReflect() protoreflect.Message
func (x *DeleteCatalogRequest) Reset()
func (x *DeleteCatalogRequest) String() string
Request message for the DeleteDatabase method.
type DeleteDatabaseRequest struct {
// Required. The name of the database to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDatabaseRequest.ProtoReflect.Descriptor instead.
func (x *DeleteDatabaseRequest) GetName() string
func (*DeleteDatabaseRequest) ProtoMessage()
func (x *DeleteDatabaseRequest) ProtoReflect() protoreflect.Message
func (x *DeleteDatabaseRequest) Reset()
func (x *DeleteDatabaseRequest) String() string
Request message for the DeleteTable method.
type DeleteTableRequest struct {
// Required. The name of the table to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTableRequest.ProtoReflect.Descriptor instead.
func (x *DeleteTableRequest) GetName() string
func (*DeleteTableRequest) ProtoMessage()
func (x *DeleteTableRequest) ProtoReflect() protoreflect.Message
func (x *DeleteTableRequest) Reset()
func (x *DeleteTableRequest) String() string
Request message for the GetCatalog method.
type GetCatalogRequest struct {
// Required. The name of the catalog to retrieve.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCatalogRequest.ProtoReflect.Descriptor instead.
func (x *GetCatalogRequest) GetName() string
func (*GetCatalogRequest) ProtoMessage()
func (x *GetCatalogRequest) ProtoReflect() protoreflect.Message
func (x *GetCatalogRequest) Reset()
func (x *GetCatalogRequest) String() string
Request message for the GetDatabase method.
type GetDatabaseRequest struct {
// Required. The name of the database to retrieve.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDatabaseRequest.ProtoReflect.Descriptor instead.
func (x *GetDatabaseRequest) GetName() string
func (*GetDatabaseRequest) ProtoMessage()
func (x *GetDatabaseRequest) ProtoReflect() protoreflect.Message
func (x *GetDatabaseRequest) Reset()
func (x *GetDatabaseRequest) String() string
Request message for the GetTable method.
type GetTableRequest struct {
// Required. The name of the table to retrieve.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTableRequest.ProtoReflect.Descriptor instead.
func (x *GetTableRequest) GetName() string
func (*GetTableRequest) ProtoMessage()
func (x *GetTableRequest) ProtoReflect() protoreflect.Message
func (x *GetTableRequest) Reset()
func (x *GetTableRequest) String() string
Options of a Hive database.
type HiveDatabaseOptions struct {
// Cloud Storage folder URI where the database data is stored, starting with
// "gs://".
LocationUri string `protobuf:"bytes,1,opt,name=location_uri,json=locationUri,proto3" json:"location_uri,omitempty"`
// Stores user supplied Hive database parameters.
Parameters map[string]string `protobuf:"bytes,2,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 (*HiveDatabaseOptions) Descriptor() ([]byte, []int)
Deprecated: Use HiveDatabaseOptions.ProtoReflect.Descriptor instead.
func (x *HiveDatabaseOptions) GetLocationUri() string
func (x *HiveDatabaseOptions) GetParameters() map[string]string
func (*HiveDatabaseOptions) ProtoMessage()
func (x *HiveDatabaseOptions) ProtoReflect() protoreflect.Message
func (x *HiveDatabaseOptions) Reset()
func (x *HiveDatabaseOptions) String() string
Options of a Hive table.
type HiveTableOptions struct {
// Stores user supplied Hive table parameters.
Parameters map[string]string `protobuf:"bytes,1,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Hive table type. For example, MANAGED_TABLE, EXTERNAL_TABLE.
TableType string `protobuf:"bytes,2,opt,name=table_type,json=tableType,proto3" json:"table_type,omitempty"`
// Stores physical storage information of the data.
StorageDescriptor *HiveTableOptions_StorageDescriptor `protobuf:"bytes,3,opt,name=storage_descriptor,json=storageDescriptor,proto3" json:"storage_descriptor,omitempty"`
// contains filtered or unexported fields
}
func (*HiveTableOptions) Descriptor() ([]byte, []int)
Deprecated: Use HiveTableOptions.ProtoReflect.Descriptor instead.
func (x *HiveTableOptions) GetParameters() map[string]string
func (x *HiveTableOptions) GetStorageDescriptor() *HiveTableOptions_StorageDescriptor
func (x *HiveTableOptions) GetTableType() string
func (*HiveTableOptions) ProtoMessage()
func (x *HiveTableOptions) ProtoReflect() protoreflect.Message
func (x *HiveTableOptions) Reset()
func (x *HiveTableOptions) String() string
Serializer and deserializer information.
type HiveTableOptions_SerDeInfo struct {
// The fully qualified Java class name of the serialization library.
SerializationLib string `protobuf:"bytes,1,opt,name=serialization_lib,json=serializationLib,proto3" json:"serialization_lib,omitempty"`
// contains filtered or unexported fields
}
func (*HiveTableOptions_SerDeInfo) Descriptor() ([]byte, []int)
Deprecated: Use HiveTableOptions_SerDeInfo.ProtoReflect.Descriptor instead.
func (x *HiveTableOptions_SerDeInfo) GetSerializationLib() string
func (*HiveTableOptions_SerDeInfo) ProtoMessage()
func (x *HiveTableOptions_SerDeInfo) ProtoReflect() protoreflect.Message
func (x *HiveTableOptions_SerDeInfo) Reset()
func (x *HiveTableOptions_SerDeInfo) String() string
Stores physical storage information of the data.
type HiveTableOptions_StorageDescriptor struct {
// Cloud Storage folder URI where the table data is stored, starting with
// "gs://".
LocationUri string `protobuf:"bytes,1,opt,name=location_uri,json=locationUri,proto3" json:"location_uri,omitempty"`
// The fully qualified Java class name of the input format.
InputFormat string `protobuf:"bytes,2,opt,name=input_format,json=inputFormat,proto3" json:"input_format,omitempty"`
// The fully qualified Java class name of the output format.
OutputFormat string `protobuf:"bytes,3,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"`
// Serializer and deserializer information.
SerdeInfo *HiveTableOptions_SerDeInfo `protobuf:"bytes,4,opt,name=serde_info,json=serdeInfo,proto3" json:"serde_info,omitempty"`
// contains filtered or unexported fields
}
func (*HiveTableOptions_StorageDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use HiveTableOptions_StorageDescriptor.ProtoReflect.Descriptor instead.
func (x *HiveTableOptions_StorageDescriptor) GetInputFormat() string
func (x *HiveTableOptions_StorageDescriptor) GetLocationUri() string
func (x *HiveTableOptions_StorageDescriptor) GetOutputFormat() string
func (x *HiveTableOptions_StorageDescriptor) GetSerdeInfo() *HiveTableOptions_SerDeInfo
func (*HiveTableOptions_StorageDescriptor) ProtoMessage()
func (x *HiveTableOptions_StorageDescriptor) ProtoReflect() protoreflect.Message
func (x *HiveTableOptions_StorageDescriptor) Reset()
func (x *HiveTableOptions_StorageDescriptor) String() string
Request message for the ListCatalogs method.
type ListCatalogsRequest struct {
// Required. The parent, which owns this collection of catalogs.
// Format: projects/{project_id_or_number}/locations/{location_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of catalogs to return. The service may return fewer than
// this value.
// If unspecified, at most 50 catalogs will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListCatalogs` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListCatalogs` must match
// the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListCatalogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListCatalogsRequest.ProtoReflect.Descriptor instead.
func (x *ListCatalogsRequest) GetPageSize() int32
func (x *ListCatalogsRequest) GetPageToken() string
func (x *ListCatalogsRequest) GetParent() string
func (*ListCatalogsRequest) ProtoMessage()
func (x *ListCatalogsRequest) ProtoReflect() protoreflect.Message
func (x *ListCatalogsRequest) Reset()
func (x *ListCatalogsRequest) String() string
Response message for the ListCatalogs method.
type ListCatalogsResponse struct {
// The catalogs from the specified project.
Catalogs []*Catalog `protobuf:"bytes,1,rep,name=catalogs,proto3" json:"catalogs,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListCatalogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListCatalogsResponse.ProtoReflect.Descriptor instead.
func (x *ListCatalogsResponse) GetCatalogs() []*Catalog
func (x *ListCatalogsResponse) GetNextPageToken() string
func (*ListCatalogsResponse) ProtoMessage()
func (x *ListCatalogsResponse) ProtoReflect() protoreflect.Message
func (x *ListCatalogsResponse) Reset()
func (x *ListCatalogsResponse) String() string
Request message for the ListDatabases method.
type ListDatabasesRequest struct {
// Required. The parent, which owns this collection of databases.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of databases to return. The service may return fewer
// than this value.
// If unspecified, at most 50 databases will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListDatabases` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListDatabases` must
// match the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListDatabasesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDatabasesRequest.ProtoReflect.Descriptor instead.
func (x *ListDatabasesRequest) GetPageSize() int32
func (x *ListDatabasesRequest) GetPageToken() string
func (x *ListDatabasesRequest) GetParent() string
func (*ListDatabasesRequest) ProtoMessage()
func (x *ListDatabasesRequest) ProtoReflect() protoreflect.Message
func (x *ListDatabasesRequest) Reset()
func (x *ListDatabasesRequest) String() string
Response message for the ListDatabases method.
type ListDatabasesResponse struct {
// The databases from the specified catalog.
Databases []*Database `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListDatabasesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDatabasesResponse.ProtoReflect.Descriptor instead.
func (x *ListDatabasesResponse) GetDatabases() []*Database
func (x *ListDatabasesResponse) GetNextPageToken() string
func (*ListDatabasesResponse) ProtoMessage()
func (x *ListDatabasesResponse) ProtoReflect() protoreflect.Message
func (x *ListDatabasesResponse) Reset()
func (x *ListDatabasesResponse) String() string
Request message for the ListTables method.
type ListTablesRequest struct {
// Required. The parent, which owns this collection of tables.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of tables to return. The service may return fewer than
// this value.
// If unspecified, at most 50 tables will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListTables` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListTables` must match
// the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// The view for the returned tables.
View TableView `protobuf:"varint,4,opt,name=view,proto3,enum=google.cloud.bigquery.biglake.v1.TableView" json:"view,omitempty"`
// contains filtered or unexported fields
}
func (*ListTablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTablesRequest.ProtoReflect.Descriptor instead.
func (x *ListTablesRequest) GetPageSize() int32
func (x *ListTablesRequest) GetPageToken() string
func (x *ListTablesRequest) GetParent() string
func (x *ListTablesRequest) GetView() TableView
func (*ListTablesRequest) ProtoMessage()
func (x *ListTablesRequest) ProtoReflect() protoreflect.Message
func (x *ListTablesRequest) Reset()
func (x *ListTablesRequest) String() string
Response message for the ListTables method.
type ListTablesResponse struct {
// The tables from the specified database.
Tables []*Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListTablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListTablesResponse.ProtoReflect.Descriptor instead.
func (x *ListTablesResponse) GetNextPageToken() string
func (x *ListTablesResponse) GetTables() []*Table
func (*ListTablesResponse) ProtoMessage()
func (x *ListTablesResponse) ProtoReflect() protoreflect.Message
func (x *ListTablesResponse) Reset()
func (x *ListTablesResponse) String() string
MetastoreServiceClient is the client API for MetastoreService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type MetastoreServiceClient interface {
// Creates a new catalog.
CreateCatalog(ctx context.Context, in *CreateCatalogRequest, opts ...grpc.CallOption) (*Catalog, error)
// Deletes an existing catalog specified by the catalog ID.
DeleteCatalog(ctx context.Context, in *DeleteCatalogRequest, opts ...grpc.CallOption) (*Catalog, error)
// Gets the catalog specified by the resource name.
GetCatalog(ctx context.Context, in *GetCatalogRequest, opts ...grpc.CallOption) (*Catalog, error)
// List all catalogs in a specified project.
ListCatalogs(ctx context.Context, in *ListCatalogsRequest, opts ...grpc.CallOption) (*ListCatalogsResponse, error)
// Creates a new database.
CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// Deletes an existing database specified by the database ID.
DeleteDatabase(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// Updates an existing database specified by the database ID.
UpdateDatabase(ctx context.Context, in *UpdateDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// Gets the database specified by the resource name.
GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// List all databases in a specified catalog.
ListDatabases(ctx context.Context, in *ListDatabasesRequest, opts ...grpc.CallOption) (*ListDatabasesResponse, error)
// Creates a new table.
CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*Table, error)
// Deletes an existing table specified by the table ID.
DeleteTable(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*Table, error)
// Updates an existing table specified by the table ID.
UpdateTable(ctx context.Context, in *UpdateTableRequest, opts ...grpc.CallOption) (*Table, error)
// Renames an existing table specified by the table ID.
RenameTable(ctx context.Context, in *RenameTableRequest, opts ...grpc.CallOption) (*Table, error)
// Gets the table specified by the resource name.
GetTable(ctx context.Context, in *GetTableRequest, opts ...grpc.CallOption) (*Table, error)
// List all tables in a specified database.
ListTables(ctx context.Context, in *ListTablesRequest, opts ...grpc.CallOption) (*ListTablesResponse, error)
}
func NewMetastoreServiceClient(cc grpc.ClientConnInterface) MetastoreServiceClient
MetastoreServiceServer is the server API for MetastoreService service.
type MetastoreServiceServer interface {
// Creates a new catalog.
CreateCatalog(context.Context, *CreateCatalogRequest) (*Catalog, error)
// Deletes an existing catalog specified by the catalog ID.
DeleteCatalog(context.Context, *DeleteCatalogRequest) (*Catalog, error)
// Gets the catalog specified by the resource name.
GetCatalog(context.Context, *GetCatalogRequest) (*Catalog, error)
// List all catalogs in a specified project.
ListCatalogs(context.Context, *ListCatalogsRequest) (*ListCatalogsResponse, error)
// Creates a new database.
CreateDatabase(context.Context, *CreateDatabaseRequest) (*Database, error)
// Deletes an existing database specified by the database ID.
DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*Database, error)
// Updates an existing database specified by the database ID.
UpdateDatabase(context.Context, *UpdateDatabaseRequest) (*Database, error)
// Gets the database specified by the resource name.
GetDatabase(context.Context, *GetDatabaseRequest) (*Database, error)
// List all databases in a specified catalog.
ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error)
// Creates a new table.
CreateTable(context.Context, *CreateTableRequest) (*Table, error)
// Deletes an existing table specified by the table ID.
DeleteTable(context.Context, *DeleteTableRequest) (*Table, error)
// Updates an existing table specified by the table ID.
UpdateTable(context.Context, *UpdateTableRequest) (*Table, error)
// Renames an existing table specified by the table ID.
RenameTable(context.Context, *RenameTableRequest) (*Table, error)
// Gets the table specified by the resource name.
GetTable(context.Context, *GetTableRequest) (*Table, error)
// List all tables in a specified database.
ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
}
Request message for the RenameTable method in MetastoreService
type RenameTableRequest struct {
// Required. The table's `name` field is used to identify the table to rename.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Required. The new `name` for the specified table, must be in the same
// database. Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
NewName string `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
// contains filtered or unexported fields
}
func (*RenameTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenameTableRequest.ProtoReflect.Descriptor instead.
func (x *RenameTableRequest) GetName() string
func (x *RenameTableRequest) GetNewName() string
func (*RenameTableRequest) ProtoMessage()
func (x *RenameTableRequest) ProtoReflect() protoreflect.Message
func (x *RenameTableRequest) Reset()
func (x *RenameTableRequest) String() string
Represents a table.
type Table struct {
// Options specified for the table type.
//
// Types that are assignable to Options:
//
// *Table_HiveOptions
Options isTable_Options `protobuf_oneof:"options"`
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the table.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last modification time of the table.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The deletion time of the table. Only set after the table is
// deleted.
DeleteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
// Output only. The time when this table is considered expired. Only set after
// the table is deleted.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// The table type.
Type Table_Type `protobuf:"varint,6,opt,name=type,proto3,enum=google.cloud.bigquery.biglake.v1.Table_Type" json:"type,omitempty"`
// The checksum of a table object computed by the server based on the value of
// other fields. It may be sent on update requests to ensure the client has an
// up-to-date value before proceeding. It is only checked for update table
// operations.
Etag string `protobuf:"bytes,8,opt,name=etag,proto3" json:"etag,omitempty"`
// contains filtered or unexported fields
}
func (*Table) Descriptor() ([]byte, []int)
Deprecated: Use Table.ProtoReflect.Descriptor instead.
func (x *Table) GetCreateTime() *timestamppb.Timestamp
func (x *Table) GetDeleteTime() *timestamppb.Timestamp
func (x *Table) GetEtag() string
func (x *Table) GetExpireTime() *timestamppb.Timestamp
func (x *Table) GetHiveOptions() *HiveTableOptions
func (x *Table) GetName() string
func (m *Table) GetOptions() isTable_Options
func (x *Table) GetType() Table_Type
func (x *Table) GetUpdateTime() *timestamppb.Timestamp
func (*Table) ProtoMessage()
func (x *Table) ProtoReflect() protoreflect.Message
func (x *Table) Reset()
func (x *Table) String() string
View on Table. Represents which fields will be populated for calls that return Table objects.
type TableView int32
const (
// Default value. The API will default to the BASIC view.
TableView_TABLE_VIEW_UNSPECIFIED TableView = 0
// Include only table names.
// This is the default value.
TableView_BASIC TableView = 1
// Include everything.
TableView_FULL TableView = 2
)
func (TableView) Descriptor() protoreflect.EnumDescriptor
func (x TableView) Enum() *TableView
func (TableView) EnumDescriptor() ([]byte, []int)
Deprecated: Use TableView.Descriptor instead.
func (x TableView) Number() protoreflect.EnumNumber
func (x TableView) String() string
func (TableView) Type() protoreflect.EnumType
type Table_HiveOptions struct {
// Options of a Hive table.
HiveOptions *HiveTableOptions `protobuf:"bytes,7,opt,name=hive_options,json=hiveOptions,proto3,oneof"`
}
The table type.
type Table_Type int32
const (
// The type is not specified.
Table_TYPE_UNSPECIFIED Table_Type = 0
// Represents a table compatible with Hive Metastore tables.
Table_HIVE Table_Type = 1
)
func (Table_Type) Descriptor() protoreflect.EnumDescriptor
func (x Table_Type) Enum() *Table_Type
func (Table_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Table_Type.Descriptor instead.
func (x Table_Type) Number() protoreflect.EnumNumber
func (x Table_Type) String() string
func (Table_Type) Type() protoreflect.EnumType
UnimplementedMetastoreServiceServer can be embedded to have forward compatible implementations.
type UnimplementedMetastoreServiceServer struct {
}
func (*UnimplementedMetastoreServiceServer) CreateCatalog(context.Context, *CreateCatalogRequest) (*Catalog, error)
func (*UnimplementedMetastoreServiceServer) CreateDatabase(context.Context, *CreateDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) CreateTable(context.Context, *CreateTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) DeleteCatalog(context.Context, *DeleteCatalogRequest) (*Catalog, error)
func (*UnimplementedMetastoreServiceServer) DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) DeleteTable(context.Context, *DeleteTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) GetCatalog(context.Context, *GetCatalogRequest) (*Catalog, error)
func (*UnimplementedMetastoreServiceServer) GetDatabase(context.Context, *GetDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) GetTable(context.Context, *GetTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) ListCatalogs(context.Context, *ListCatalogsRequest) (*ListCatalogsResponse, error)
func (*UnimplementedMetastoreServiceServer) ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error)
func (*UnimplementedMetastoreServiceServer) ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
func (*UnimplementedMetastoreServiceServer) RenameTable(context.Context, *RenameTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) UpdateDatabase(context.Context, *UpdateDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) UpdateTable(context.Context, *UpdateTableRequest) (*Table, error)
Request message for the UpdateDatabase method.
type UpdateDatabaseRequest struct {
// Required. The database to update.
//
// The database's `name` field is used to identify the database to update.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Database *Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
// The list of fields to update.
//
// For the `FieldMask` definition, see
// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#fieldmask
// If not set, defaults to all of the fields that are allowed 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 (*UpdateDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDatabaseRequest.ProtoReflect.Descriptor instead.
func (x *UpdateDatabaseRequest) GetDatabase() *Database
func (x *UpdateDatabaseRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateDatabaseRequest) ProtoMessage()
func (x *UpdateDatabaseRequest) ProtoReflect() protoreflect.Message
func (x *UpdateDatabaseRequest) Reset()
func (x *UpdateDatabaseRequest) String() string
Request message for the UpdateTable method.
type UpdateTableRequest struct {
// Required. The table to update.
//
// The table's `name` field is used to identify the table to update.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Table *Table `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
// The list of fields to update.
//
// For the `FieldMask` definition, see
// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#fieldmask
// If not set, defaults to all of the fields that are allowed 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 (*UpdateTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTableRequest.ProtoReflect.Descriptor instead.
func (x *UpdateTableRequest) GetTable() *Table
func (x *UpdateTableRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateTableRequest) ProtoMessage()
func (x *UpdateTableRequest) ProtoReflect() protoreflect.Message
func (x *UpdateTableRequest) Reset()
func (x *UpdateTableRequest) String() string