helpers

Documentation

Index

• func CanonizeDynamicYtTable(t *testing.T, ytClient yt.Client, tablePath ypath.Path, fileName string)
• func ChSchemaForYtTypesTestData() string
• func DumpDynamicYtTable(ytClient yt.Client, tablePath ypath.Path, writer io.Writer) error
• func NewEnvWithNode(t *testing.T, path string) *yttest.Env
• func RecipeYtTarget(path string) yt2.YtDestinationModel
• func SetRecipeYt(dst *yt2.YtDestination) *yt2.YtDestination
• func YtReadAllRowsFromAllTables[OutRow any](t *testing.T, cluster string, path string, expectedResCount int) []OutRow
• func YtTestDir(t *testing.T, testSuiteName string) ypath.Path
• func YtTypesTestData() ([]schema.Column, []map[string]any)

Functions

func CanonizeDynamicYtTable

func CanonizeDynamicYtTable(t *testing.T, ytClient yt.Client, tablePath ypath.Path, fileName string)

func ChSchemaForYtTypesTestData

func ChSchemaForYtTypesTestData() string

func DumpDynamicYtTable

func DumpDynamicYtTable(ytClient yt.Client, tablePath ypath.Path, writer io.Writer) error

func NewEnvWithNode

func NewEnvWithNode(t *testing.T, path string) *yttest.Env

func RecipeYtTarget

func RecipeYtTarget(path string) yt2.YtDestinationModel

func SetRecipeYt

func SetRecipeYt(dst *yt2.YtDestination) *yt2.YtDestination

func YtReadAllRowsFromAllTables

func YtReadAllRowsFromAllTables[OutRow any](t *testing.T, cluster string, path string, expectedResCount int) []OutRow

func YtTestDir

func YtTestDir(t *testing.T, testSuiteName string) ypath.Path

func YtTypesTestData

func YtTypesTestData() ([]schema.Column, []map[string]any)