hive

package
v1.20.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DatabaseHiveToLocal added in v0.40.3 

func DatabaseHiveToLocal(db *hive_metastore.Database) *metastore.Database

func DatabaseLocalToHive added in v0.40.3 

func DatabaseLocalToHive(db *metastore.Database) *hive_metastore.Database

func PartitionHiveToLocal added in v0.40.3 

func PartitionHiveToLocal(hivePartition *hive_metastore.Partition) *metastore.Partition

func PartitionLocalToHive added in v0.40.3 

func PartitionLocalToHive(partition *metastore.Partition) *hive_metastore.Partition

func PartitionsHiveToLocal added in v0.40.3 

func PartitionsHiveToLocal(gluePartitions []*hive_metastore.Partition) []*metastore.Partition

func PartitionsLocalToHive added in v0.40.3 

func PartitionsLocalToHive(partitions []*metastore.Partition) []*hive_metastore.Partition

func SDHiveToLocal added in v0.40.3 

func SDHiveToLocal(sd *hive_metastore.StorageDescriptor) *metastore.StorageDescriptor

func SDLocalToHive added in v0.40.3 

func SDLocalToHive(sd *metastore.StorageDescriptor) *hive_metastore.StorageDescriptor

func TableHiveToLocal added in v0.40.3 

func TableHiveToLocal(hiveTable *hive_metastore.Table) *metastore.Table

func TableLocalToHive added in v0.40.3 

func TableLocalToHive(table *metastore.Table) *hive_metastore.Table

Types

type MSClient 

type MSClient struct {
	Client ThriftHiveMetastoreClient
	// contains filtered or unexported fields
}

func NewMSClient 

func NewMSClient(addr string, secure bool, baseLocationURI string) (*MSClient, error)

func (*MSClient) AddPartition added in v0.40.3 

func (h *MSClient) AddPartition(ctx context.Context, _ string, _ string, newPartition *metastore.Partition) error

func (*MSClient) AddPartitions added in v0.40.3 

func (h *MSClient) AddPartitions(ctx context.Context, _ string, _ string, newParts []*metastore.Partition) error

func (*MSClient) AlterPartition added in v0.40.3 

func (h *MSClient) AlterPartition(ctx context.Context, dbName string, tableName string, partition *metastore.Partition) error

func (*MSClient) AlterPartitions added in v0.40.3 

func (h *MSClient) AlterPartitions(ctx context.Context, dbName string, tableName string, newPartitions []*metastore.Partition) error

func (*MSClient) AlterTable added in v0.40.3 

func (h *MSClient) AlterTable(ctx context.Context, dbName string, tableName string, newTable *metastore.Table) error

func (*MSClient) Close 

func (h *MSClient) Close() error

func (*MSClient) CreateDatabase added in v0.54.0 

func (h *MSClient) CreateDatabase(ctx context.Context, database *metastore.Database) error

func (*MSClient) CreateTable added in v0.40.3 

func (h *MSClient) CreateTable(ctx context.Context, tbl *metastore.Table) error

func (*MSClient) DropPartition added in v0.40.3 

func (h *MSClient) DropPartition(ctx context.Context, dbName string, tableName string, values []string) error

func (*MSClient) GetAllDatabases added in v0.40.3 

func (h *MSClient) GetAllDatabases(ctx context.Context) ([]*metastore.Database, error)

func (*MSClient) GetDBLocation added in v0.40.3 

func (h *MSClient) GetDBLocation(dbName string) string

func (*MSClient) GetDatabase added in v0.40.3 

func (h *MSClient) GetDatabase(ctx context.Context, name string) (*metastore.Database, error)

func (*MSClient) GetDatabases added in v0.40.3 

func (h *MSClient) GetDatabases(ctx context.Context, pattern string) ([]*metastore.Database, error)

func (*MSClient) GetPartition added in v0.40.3 

func (h *MSClient) GetPartition(ctx context.Context, dbName string, tableName string, values []string) (*metastore.Partition, error)

func (*MSClient) GetPartitions added in v0.40.3 

func (h *MSClient) GetPartitions(ctx context.Context, dbName string, tableName string) ([]*metastore.Partition, error)

func (*MSClient) GetTable added in v0.40.3 

func (h *MSClient) GetTable(ctx context.Context, dbname string, tableName string) (*metastore.Table, error)

func (*MSClient) GetTables added in v0.40.3 

func (h *MSClient) GetTables(ctx context.Context, dbName string, pattern string) ([]*metastore.Table, error)

func (*MSClient) HasTable added in v0.40.3 

func (h *MSClient) HasTable(ctx context.Context, dbname string, tableName string) (bool, error)

func (*MSClient) NormalizeDBName added in v0.40.3 

func (h *MSClient) NormalizeDBName(name string) string

type ThriftHiveMetastoreClient 

type ThriftHiveMetastoreClient interface {
	CreateTable(ctx context.Context, tbl *hive_metastore.Table) error
	GetTable(ctx context.Context, dbname string, tableName string) (*hive_metastore.Table, error)
	AlterTable(ctx context.Context, dbname string, tableName string, newTable *hive_metastore.Table) error
	AddPartitions(ctx context.Context, newParts []*hive_metastore.Partition) (int32, error)
	GetPartitions(ctx context.Context, dbName string, tableName string, maxPartitions int16) (r []*hive_metastore.Partition, err error)
	GetPartition(ctx context.Context, dbName string, tableName string, values []string) (r *hive_metastore.Partition, err error)
	AlterPartitions(ctx context.Context, dbName string, tableName string, newPartitions []*hive_metastore.Partition) error
	AlterPartition(ctx context.Context, dbName string, tableName string, values *hive_metastore.Partition) error
	AddPartition(ctx context.Context, newPartition *hive_metastore.Partition) (r *hive_metastore.Partition, err error)
	DropPartition(ctx context.Context, dbName string, tableName string, values []string, deleteData bool) (bool, error)
	GetDatabase(ctx context.Context, name string) (r *hive_metastore.Database, err error)
	GetDatabases(ctx context.Context, pattern string) (r []string, err error)
	GetAllDatabases(ctx context.Context) (r []string, err error)
	CreateDatabase(ctx context.Context, database *hive_metastore.Database) error
	GetTables(ctx context.Context, dbName string, pattern string) ([]string, error)
}

Source Files

View all Source files

Directories

Path Synopsis
gen-go
hive_metastore
hive_metastore/thrift_hive_metastore-remote

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.