metastore

Documentation

Index

• Constants
• Variables
• func Diff(iterA, iterB Collection) (catalog.Differences, error)
• func DiffIterable(iterA, iterB Collection, callbackFn DiffCallbackFn) error
• func GetSymlinkLocation(location, locationPrefix string) (string, error)
• func ReplaceBranchName(location, branch string) (string, error)
• type Collection
• type CompareResult
• type DiffCallbackFn
• type MetaDiff

Constants

const SymlinkInputFormat = "org.apache.hadoop.hive.ql.io.SymlinkTextInputFormat"

Variables

var ErrInvalidLocation = errors.New("got empty schema or host wile parsing location url, location should be schema://host/path")

Functions

func Diff

func Diff(iterA, iterB Collection) (catalog.Differences, error)

func DiffIterable

func DiffIterable(iterA, iterB Collection, callbackFn DiffCallbackFn) error

func GetSymlinkLocation

func GetSymlinkLocation(location, locationPrefix string) (string, error)

func ReplaceBranchName

func ReplaceBranchName(location, branch string) (string, error)

Types

type Collection

type Collection interface {
	sort.Interface
	Value(i int) interface{}
	Name(i int) string
	CompareWith(i int, v interface{}, j int) CompareResult
}

type CompareResult

type CompareResult int

const (
	ItemLess CompareResult = iota
	ItemSameKey
	ItemSame
	ItemGreater
)

type DiffCallbackFn

type DiffCallbackFn func(difference catalog.DifferenceType, iter interface{}, name string) error

type MetaDiff

type MetaDiff struct {
	PartitionDiff catalog.Differences
	ColumnsDiff   catalog.Differences
}