glue

package

v1.20.0 Latest Latest Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/treeverse/lakefs

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DatabaseGlueToLocal(db *types.Database) *metastore.Database
func DatabaseLocalToGlue(db *metastore.Database) *types.DatabaseInput
func DatabasesGlueToLocal(glueDatabases []types.Database) []*metastore.Database
func NewMSClient(client *glue.Client, catalogID, baselLocationURI string) (metastore.Client, error)
func PartitionGlueToLocal(gluePartition *types.Partition) *metastore.Partition
func PartitionLocalToGlue(partition *metastore.Partition) *types.PartitionInput
func PartitionsGlueToLocal(gluePartitions []types.Partition) []*metastore.Partition
func PartitionsLocalToGlue(partitions []*metastore.Partition) []*types.PartitionInput
func SDGlueToLocal(sd *types.StorageDescriptor) *metastore.StorageDescriptor
func SDLocalToGlue(sd *metastore.StorageDescriptor) *types.StorageDescriptor
func TableGlueToLocal(glueTable *types.Table) *metastore.Table
func TableLocalToGlue(table *metastore.Table) *types.TableInput
func TablesGlueToLocal(glueTables []types.Table) []*metastore.Table
type MSClient

Constants ¶

View Source

const MaxParts = 1000 // max possible 1000

Variables ¶

This section is empty.

Functions ¶

func DatabaseGlueToLocal ¶ added in v0.40.3

func DatabaseGlueToLocal(db *types.Database) *metastore.Database

func DatabaseLocalToGlue ¶ added in v0.40.3

func DatabaseLocalToGlue(db *metastore.Database) *types.DatabaseInput

func DatabasesGlueToLocal ¶ added in v0.40.3

func DatabasesGlueToLocal(glueDatabases []types.Database) []*metastore.Database

func NewMSClient ¶

func NewMSClient(client *glue.Client, catalogID, baselLocationURI string) (metastore.Client, error)

func PartitionGlueToLocal ¶ added in v0.40.3

func PartitionGlueToLocal(gluePartition *types.Partition) *metastore.Partition

func PartitionLocalToGlue ¶ added in v0.40.3

func PartitionLocalToGlue(partition *metastore.Partition) *types.PartitionInput

func PartitionsGlueToLocal ¶ added in v0.40.3

func PartitionsGlueToLocal(gluePartitions []types.Partition) []*metastore.Partition

func PartitionsLocalToGlue ¶ added in v0.40.3

func PartitionsLocalToGlue(partitions []*metastore.Partition) []*types.PartitionInput

func SDGlueToLocal ¶ added in v0.40.3

func SDGlueToLocal(sd *types.StorageDescriptor) *metastore.StorageDescriptor

func SDLocalToGlue ¶ added in v0.40.3

func SDLocalToGlue(sd *metastore.StorageDescriptor) *types.StorageDescriptor

func TableGlueToLocal ¶ added in v0.40.3

func TableGlueToLocal(glueTable *types.Table) *metastore.Table

func TableLocalToGlue ¶ added in v0.40.3

func TableLocalToGlue(table *metastore.Table) *types.TableInput

func TablesGlueToLocal ¶ added in v0.40.3

func TablesGlueToLocal(glueTables []types.Table) []*metastore.Table

Types ¶

type MSClient ¶

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

func (*MSClient) AddPartition ¶ added in v0.40.3

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

func (*MSClient) AddPartitions ¶ added in v0.40.3

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

func (*MSClient) AlterPartition ¶ added in v0.40.3

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

func (*MSClient) AlterPartitions ¶ added in v0.40.3

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

func (*MSClient) AlterTable ¶ added in v0.40.3

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

func (*MSClient) CreateDatabase ¶ added in v0.54.0

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

func (*MSClient) CreateTable ¶ added in v0.40.3

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

func (*MSClient) DropPartition ¶ added in v0.40.3

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

func (*MSClient) GetAllPartitions ¶ added in v0.40.3

func (g *MSClient) GetAllPartitions(ctx context.Context, dbName, tableName string) ([]types.Partition, error)

func (*MSClient) GetDBLocation ¶ added in v0.40.3

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

func (*MSClient) GetDatabase ¶ added in v0.40.3

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

func (*MSClient) GetDatabases ¶ added in v0.40.3

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

func (*MSClient) GetPartition ¶ added in v0.40.3

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

func (*MSClient) GetPartitions ¶ added in v0.40.3

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

func (*MSClient) GetTable ¶ added in v0.40.3

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

func (*MSClient) GetTables ¶ added in v0.40.3

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

func (*MSClient) HasTable ¶ added in v0.40.3

func (g *MSClient) HasTable(ctx context.Context, dbName string, tableName string) (bool, error)

func (*MSClient) NormalizeDBName ¶ added in v0.40.3

func (g *MSClient) NormalizeDBName(db string) string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL