datasource

Documentation

Index

• type DataSource
• type Record
  • func (r *Record) MatchRecord(t *testing.T, record arrow.Record, schema *api_service_protos.TSchema)
• type Table
  • 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

Types

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 (*Record) MatchRecord

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 (*Table) MatchRecords

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

func (*Table) MatchSchema

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

type TableSchema

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