Trino thrift connector. Golang
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) {
}