Trino thrift connector. Golang

Trino thrift specs

Trino ожидает TBinaryProtocol и TFramedTransport как протокол и транспорт соответственно.

transportFactory := thrift.NewTFramedTransportFactoryConf(thrift.NewTTransportFactory(), nil)
protocolFactory := thrift.NewTBinaryProtocolFactoryConf(nil)

Ссылка на оригинал

Methods

TrinoListSchemaNames

func (ts *TrinoService) TrinoListSchemaNames(ctx context.Context) (_r []string, _err error) {
 
}

TrinoListTables

func (ts *TrinoService) TrinoListTables(ctx context.Context, schemaNameOrNull *trino.TrinoThriftNullableSchemaName) (_r []*trino.TrinoThriftSchemaTableName, _err error) {
 
}

TrinoGetTableMetadata

func (ts *TrinoService) TrinoGetTableMetadata(ctx context.Context, schemaTableName *trino.TrinoThriftSchemaTableName) (_r *trino.TrinoThriftNullableTableMetadata, _err error) {
 
}

TrinoGetSplits

func (ts *TrinoService) TrinoGetSplits(ctx context.Context, schemaTableName *trino.TrinoThriftSchemaTableName, desiredColumns *trino.TrinoThriftNullableColumnSet, outputConstraint *trino.TrinoThriftTupleDomain, maxSplitCount int32, nextToken *trino.TrinoThriftNullableToken) (_r *trino.TrinoThriftSplitBatch, _err error) {
 
}

TrinoGetIndexSplits

func (ts *TrinoService) TrinoGetIndexSplits(ctx context.Context, schemaTableName *trino.TrinoThriftSchemaTableName, indexColumnNames []string, outputColumnNames []string, keys *trino.TrinoThriftPageResult_, outputConstraint *trino.TrinoThriftTupleDomain, maxSplitCount int32, nextToken *trino.TrinoThriftNullableToken) (_r *trino.TrinoThriftSplitBatch, _err error) {
 
}

TrinoGetRows

func (ts *TrinoService) TrinoGetRows(ctx context.Context, splitId *trino.TrinoThriftId, columns []string, maxBytes int64, nextToken *trino.TrinoThriftNullableToken) (_r *trino.TrinoThriftPageResult_, _err error) {
 
}