statictable

Documentation

Index

• func Commit(client yt.Client, opts *CommitOptions) error
• func Init(client yt.Client, opts *InitOptions) error
• type CommitOptions
• type InitOptions
• type Writer
  • func NewWriter(cfg WriterConfig) (*Writer, error)
  • func (w *Writer) Commit() error
  • func (w *Writer) Write(items []changeitem.ChangeItem) error
• type WriterConfig

Functions

func Commit

func Commit(client yt.Client, opts *CommitOptions) error

func Init

func Init(client yt.Client, opts *InitOptions) error

Types

type CommitOptions

type CommitOptions struct {
	MainTxID         yt.TxID
	TransferID       string
	Schema           []abstract.ColSchema
	Path             ypath.Path
	CleanupType      model.CleanupType
	AllowedSorting   bool
	Pool             string
	OptimizeFor      string
	CustomAttributes map[string]any
	Logger           log.Logger
}

type InitOptions

type InitOptions struct {
	MainTxID         yt.TxID
	TransferID       string
	Schema           []abstract.ColSchema
	Path             ypath.Path
	OptimizeFor      string
	CustomAttributes map[string]any
	Logger           log.Logger
}

type Writer

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

func NewWriter

func NewWriter(cfg WriterConfig) (*Writer, error)

func (*Writer) Commit

func (w *Writer) Commit() error

func (*Writer) Write

func (w *Writer) Write(items []changeitem.ChangeItem) error

type WriterConfig

type WriterConfig struct {
	TransferID string
	TxClient   yt.Tx
	Path       ypath.Path
	Spec       map[string]interface{}
	ChunkSize  int
	Logger     log.Logger
	Metrics    *stats.SinkerStats
}