storage

Documentation

Index

• func ExactYTTableRowsCount(ytClient yt.Client, pathToTable ypath.Path) (uint64, error)
• type Storage
  • func NewStorage(config *ytprovider.YtStorageParams) (*Storage, error)
  • func (s *Storage) Close()
  • func (s *Storage) EstimateTableRowsCount(table abstract.TableID) (uint64, error)
  • func (s *Storage) ExactTableRowsCount(table abstract.TableID) (uint64, error)
  • func (s *Storage) LoadRandomSample(table abstract.TableDescription, pusher abstract.Pusher) error
  • func (s *Storage) LoadSampleBySet(table abstract.TableDescription, keySet []map[string]interface{}, ...) error
  • func (s *Storage) LoadSchema() (dbSchema abstract.DBSchema, err error)
  • func (s *Storage) LoadTable(ctx context.Context, t abstract.TableDescription, pusher abstract.Pusher) error
  • func (s *Storage) LoadTopBottomSample(table abstract.TableDescription, pusher abstract.Pusher) error
  • func (s *Storage) Ping() error
  • func (s *Storage) TableAccessible(table abstract.TableDescription) bool
  • func (s *Storage) TableExists(table abstract.TableID) (bool, error)
  • func (s *Storage) TableList(includeTableFilter abstract.IncludeTableList) (abstract.TableMap, error)
  • func (s *Storage) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)
  • func (s *Storage) TableSizeInBytes(table abstract.TableID) (uint64, error)

Functions

func ExactYTTableRowsCount

func ExactYTTableRowsCount(ytClient yt.Client, pathToTable ypath.Path) (uint64, error)

Types

type Storage

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

func NewStorage

func NewStorage(config *ytprovider.YtStorageParams) (*Storage, error)

func (*Storage) Close

func (s *Storage) Close()

func (*Storage) EstimateTableRowsCount

func (s *Storage) EstimateTableRowsCount(table abstract.TableID) (uint64, error)

func (*Storage) ExactTableRowsCount

func (s *Storage) ExactTableRowsCount(table abstract.TableID) (uint64, error)

func (*Storage) LoadRandomSample

func (s *Storage) LoadRandomSample(table abstract.TableDescription, pusher abstract.Pusher) error

func (*Storage) LoadSampleBySet

func (s *Storage) LoadSampleBySet(table abstract.TableDescription, keySet []map[string]interface{}, pusher abstract.Pusher) error

func (*Storage) LoadSchema

func (s *Storage) LoadSchema() (dbSchema abstract.DBSchema, err error)

func (*Storage) LoadTable

func (s *Storage) LoadTable(ctx context.Context, t abstract.TableDescription, pusher abstract.Pusher) error

func (*Storage) LoadTopBottomSample

func (s *Storage) LoadTopBottomSample(table abstract.TableDescription, pusher abstract.Pusher) error

func (*Storage) Ping

func (s *Storage) Ping() error

func (*Storage) TableAccessible

func (s *Storage) TableAccessible(table abstract.TableDescription) bool

func (*Storage) TableExists

func (s *Storage) TableExists(table abstract.TableID) (bool, error)

func (*Storage) TableList

func (s *Storage) TableList(includeTableFilter abstract.IncludeTableList) (abstract.TableMap, error)

func (*Storage) TableSchema

func (s *Storage) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)

func (*Storage) TableSizeInBytes

func (s *Storage) TableSizeInBytes(table abstract.TableID) (uint64, error)