datasource

type DataSource ¶

type DataSource struct {
	Instances []*api_common.TDataSourceInstance
}

type Record ¶

type Record struct {
	Columns map[string]any
}

Record is somewhat equivalent to arrow.Record Store columns in map because order of columns in some datasource is undefined (i.e. in YDB - https://st.yandex-team.ru/KIKIMR-20836)

func (r *Record) MatchRecord(t *testing.T, record arrow.Record, schema *api_service_protos.TSchema)

type Table ¶

type Table struct {
	Name    string
	Schema  *TableSchema
	Records []*Record // Large tables may consist of multiple records
}

func (tb *Table) MatchRecords(t *testing.T, records []arrow.Record, schema *api_service_protos.TSchema)

func (tb *Table) MatchSchema(t *testing.T, schema *api_service_protos.TSchema)

type TableSchema ¶ added in v0.1.2

type TableSchema struct {
	Columns map[string]*Ydb.Type
}