Documentation
¶
Index ¶
- Variables
- func CopyOrMergeAll(ctx context.Context, fromClient, toClient *MSClient, ...) error
- func FieldSchemaEqual(f1, f2 *hive_metastore.FieldSchema) bool
- type FSCollection
- type MSClient
- func (c *MSClient) Close() error
- func (c *MSClient) Copy(fromDB, fromTable, toDB, toTable, toBranch, serde string, ...) error
- func (c *MSClient) CopyOrMerge(fromDB, fromTable, toDB, toTable, toBranch, serde string, partition []string) error
- func (c *MSClient) CopyOrMergeTo(fromDB, fromTable, toDB, toTable, toBranch, serde string, partition []string, ...) error
- func (c *MSClient) CopyPartition(fromDB, fromTable, toDB, toTable, toBranch, serde string, partition []string) error
- func (c *MSClient) Diff(fromDB, fromTable, toDB, toTable string) (*metastore.MetaDiff, error)
- func (c *MSClient) Merge(fromDB, fromTable, toDB, toTable, toBranch, serde string, ...) error
- type PartitionCollection
- func (p *PartitionCollection) CompareWith(i int, v interface{}, j int) metastore.CompareResult
- func (p *PartitionCollection) Len() int
- func (p *PartitionCollection) Less(i, j int) bool
- func (p *PartitionCollection) Name(i int) string
- func (p *PartitionCollection) Swap(i, j int)
- func (p *PartitionCollection) Value(i int) interface{}
- type ThriftHiveMetastoreClient
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func CopyOrMergeAll ¶ added in v0.40.0
func FieldSchemaEqual ¶
func FieldSchemaEqual(f1, f2 *hive_metastore.FieldSchema) bool
Types ¶
type FSCollection ¶
type FSCollection struct {
// contains filtered or unexported fields
}
func NewFSCollection ¶
func NewFSCollection(fsList []*hive_metastore.FieldSchema) *FSCollection
func (*FSCollection) CompareWith ¶
func (p *FSCollection) CompareWith(i int, v interface{}, j int) metastore.CompareResult
func (*FSCollection) Len ¶
func (p *FSCollection) Len() int
func (*FSCollection) Less ¶
func (p *FSCollection) Less(i, j int) bool
func (*FSCollection) Name ¶
func (p *FSCollection) Name(i int) string
func (*FSCollection) Swap ¶
func (p *FSCollection) Swap(i, j int)
func (*FSCollection) Value ¶
func (p *FSCollection) Value(i int) interface{}
type MSClient ¶
type MSClient struct {
// contains filtered or unexported fields
}
func NewMSClient ¶
func (*MSClient) Copy ¶
func (c *MSClient) Copy(fromDB, fromTable, toDB, toTable, toBranch, serde string, toClient ThriftHiveMetastoreClient) error
func (*MSClient) CopyOrMerge ¶
func (*MSClient) CopyOrMergeTo ¶ added in v0.40.0
func (c *MSClient) CopyOrMergeTo(fromDB, fromTable, toDB, toTable, toBranch, serde string, partition []string, toClient ThriftHiveMetastoreClient) error
func (*MSClient) CopyPartition ¶
type PartitionCollection ¶
type PartitionCollection struct {
// contains filtered or unexported fields
}
func NewPartitionCollection ¶
func NewPartitionCollection(partition []*hive_metastore.Partition) *PartitionCollection
func (*PartitionCollection) CompareWith ¶
func (p *PartitionCollection) CompareWith(i int, v interface{}, j int) metastore.CompareResult
func (*PartitionCollection) Len ¶
func (p *PartitionCollection) Len() int
func (*PartitionCollection) Less ¶
func (p *PartitionCollection) Less(i, j int) bool
func (*PartitionCollection) Name ¶
func (p *PartitionCollection) Name(i int) string
func (*PartitionCollection) Swap ¶
func (p *PartitionCollection) Swap(i, j int)
func (*PartitionCollection) Value ¶
func (p *PartitionCollection) Value(i int) interface{}
type ThriftHiveMetastoreClient ¶
type ThriftHiveMetastoreClient interface { CreateTable(ctx context.Context, tbl *hive_metastore.Table) (err error) GetTable(ctx context.Context, dbname string, tableName string) (r *hive_metastore.Table, err error) AlterTable(ctx context.Context, dbname string, tableName string, newTable *hive_metastore.Table) (err error) AddPartitions(ctx context.Context, newParts []*hive_metastore.Partition) (r int32, err 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) (err error) AlterPartition(ctx context.Context, dbName string, tableName string, values *hive_metastore.Partition) (err 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) (r bool, err 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) (err error) GetTables(ctx context.Context, dbName string, pattern string) (r []string, err error) }
Source Files
¶
Click to show internal directories.
Click to hide internal directories.