mock

Documentation

Index

• Variables
• func AddColumn(m *metastore.Partition, col *metastore.FieldSchema)
• func GetByPrefix(m map[string]*metastore.Partition, prefix string) []*metastore.Partition
• func GetKey(dbName, tableName string) string
• func GetPartitionKey(dbName, tableName string, partition []string) string
• func PartitionsListToMap(partitions []*metastore.Partition) map[string]*metastore.Partition
• type MSClient
  • func NewMSClient(t *testing.T, initialDatabases map[string]*metastore.Database, ...) *MSClient
  • func (m *MSClient) AddPartition(_ context.Context, tableName string, dbName string, ...) error
  • func (m *MSClient) AddPartitions(ctx context.Context, tableName string, dbName string, ...) error
  • func (m *MSClient) AlterPartition(_ context.Context, dbName string, tableName string, ...) error
  • func (m *MSClient) AlterPartitions(ctx context.Context, dbName string, tableName string, ...) error
  • func (m *MSClient) AlterTable(_ context.Context, dbName string, tableName string, newTable *metastore.Table) error
  • func (m *MSClient) CreateDatabase(_ context.Context, db *metastore.Database) error
  • func (m *MSClient) CreateTable(_ context.Context, table *metastore.Table) error
  • func (m *MSClient) DropPartition(_ context.Context, dbName string, tableName string, values []string) error
  • func (m *MSClient) GetDBLocation(dbName string) string
  • func (m *MSClient) GetDatabase(_ context.Context, name string) (*metastore.Database, error)
  • func (m *MSClient) GetDatabases(_ context.Context, name string) ([]*metastore.Database, error)
  • func (m *MSClient) GetPartition(_ context.Context, dbName string, tableName string, values []string) (*metastore.Partition, error)
  • func (m *MSClient) GetPartitionCollection(_ context.Context, _ string, _ string) (metastore.Collection, error)
  • func (m *MSClient) GetPartitions(_ context.Context, dbName string, tableName string) ([]*metastore.Partition, error)
  • func (m *MSClient) GetTable(_ context.Context, dbname string, tableName string) (*metastore.Table, error)
  • func (m *MSClient) GetTableCollection(_ context.Context, _ string, _ string) (metastore.Collection, error)
  • func (m *MSClient) GetTables(_ context.Context, _ string, _ string) ([]*metastore.Table, error)
  • func (m *MSClient) HasTable(_ context.Context, dbname string, tableName string) (bool, error)
  • func (m *MSClient) NormalizeDBName(name string) string

Variables

var (
	ErrNotFound      = errors.New("not found")
	ErrAlreadyExists = errors.New("already exists")
)

Functions

func AddColumn

func AddColumn(m *metastore.Partition, col *metastore.FieldSchema)

func GetByPrefix

func GetByPrefix(m map[string]*metastore.Partition, prefix string) []*metastore.Partition

func GetKey

func GetKey(dbName, tableName string) string

func GetPartitionKey

func GetPartitionKey(dbName, tableName string, partition []string) string

func PartitionsListToMap

func PartitionsListToMap(partitions []*metastore.Partition) map[string]*metastore.Partition

Types

type MSClient

type MSClient struct {
	Databases map[string]*metastore.Database
	Tables    map[string]*metastore.Table
	// contains filtered or unexported fields
}

func NewMSClient

func NewMSClient(t *testing.T, initialDatabases map[string]*metastore.Database, initialTables map[string]*metastore.Table, initialPartitions map[string]*metastore.Partition) *MSClient

func (*MSClient) AddPartition

func (m *MSClient) AddPartition(_ context.Context, tableName string, dbName string, newPartition *metastore.Partition) error

func (*MSClient) AddPartitions

func (m *MSClient) AddPartitions(ctx context.Context, tableName string, dbName string, newParts []*metastore.Partition) error

func (*MSClient) AlterPartition

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

func (*MSClient) AlterPartitions

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

func (*MSClient) AlterTable

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

func (*MSClient) CreateDatabase

func (m *MSClient) CreateDatabase(_ context.Context, db *metastore.Database) error

func (*MSClient) CreateTable

func (m *MSClient) CreateTable(_ context.Context, table *metastore.Table) error

func (*MSClient) DropPartition

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

func (*MSClient) GetDBLocation

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

func (*MSClient) GetDatabase

func (m *MSClient) GetDatabase(_ context.Context, name string) (*metastore.Database, error)

func (*MSClient) GetDatabases

func (m *MSClient) GetDatabases(_ context.Context, name string) ([]*metastore.Database, error)

func (*MSClient) GetPartition

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

func (*MSClient) GetPartitionCollection

func (m *MSClient) GetPartitionCollection(_ context.Context, _ string, _ string) (metastore.Collection, error)

func (*MSClient) GetPartitions

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

func (*MSClient) GetTable

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

func (*MSClient) GetTableCollection

func (m *MSClient) GetTableCollection(_ context.Context, _ string, _ string) (metastore.Collection, error)

func (*MSClient) GetTables

func (m *MSClient) GetTables(_ context.Context, _ string, _ string) ([]*metastore.Table, error)

func (*MSClient) HasTable

func (m *MSClient) HasTable(_ context.Context, dbname string, tableName string) (bool, error)

func (*MSClient) NormalizeDBName

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