loader

Documentation

Index

• Constants
• func NewAppendLoader(logger *slog.Logger) (*appendLoader, error)
• func NewMergeLoader(logger *slog.Logger) *mergeLoader
• func NewReplaceLoader(logger *slog.Logger) *replaceLoader
• type Loader
  • func GetLoader(name string, logger *slog.Logger) (Loader, error)

Constants

const (
	APPEND  = "APPEND"
	REPLACE = "REPLACE"
	MERGE   = "MERGE"
)

Functions

func NewAppendLoader

func NewAppendLoader(logger *slog.Logger) (*appendLoader, error)

func NewMergeLoader

func NewMergeLoader(logger *slog.Logger) *mergeLoader

func NewReplaceLoader

func NewReplaceLoader(logger *slog.Logger) *replaceLoader

Types

type Loader

type Loader interface {
	GetQuery(tableID, query string) string
	GetPartitionedQuery(tableID, query string, partitionName []string) string
}

func GetLoader

func GetLoader(name string, logger *slog.Logger) (Loader, error)