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 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 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)