presto

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 1, 2023

v1.6.0

Jun 7, 2022

v1.5.1

Jun 2, 2022

v1.5.0

May 6, 2022

v1.4.0

Dec 13, 2021

v1.3.1

Sep 17, 2021

Changes in this version

+ func NewServerCodec(conn thrift.Transport) rpc.ServerCodec

+ func ServeConn(conn thrift.Transport)

v1.3.0

Jul 2, 2021

v1.2.9

Jun 16, 2021

v1.2.8

May 13, 2021

v1.2.7

Apr 22, 2021

v1.2.6

Mar 31, 2021

v1.2.5

Mar 17, 2021

Changes in this version

type Column

+ At func(index int) interface{}

type PrestoThriftBigint

+ func (b *PrestoThriftBigint) At(index int) interface{}

type PrestoThriftBoolean

+ func (b *PrestoThriftBoolean) At(index int) interface{}

type PrestoThriftDouble

+ func (b *PrestoThriftDouble) At(index int) interface{}

type PrestoThriftInteger

+ func (b *PrestoThriftInteger) At(index int) interface{}

type PrestoThriftJson

+ func (b *PrestoThriftJson) At(index int) interface{}

type PrestoThriftTimestamp

+ func (b *PrestoThriftTimestamp) At(index int) interface{}

type PrestoThriftVarchar

+ func (b *PrestoThriftVarchar) At(index int) interface{}

v1.1.12

May 13, 2020

v1.1.6

Apr 20, 2020

v1.1.5

Apr 17, 2020

v1.1.4

Apr 14, 2020

Changes in this version

+ var PrestoThriftBoundByName = map[string]PrestoThriftBound

+ var PrestoThriftBoundByValue = map[PrestoThriftBound]string

+ func Serve(ctx context.Context, port int32, service PrestoThriftService) error

+ type Client interface

+ Call func(method string, request interface{}, response interface{}) error

+ type Column interface

+ Append func(v interface{}) int

+ AppendBlock func([]Column)

+ AsProto func() *talaria.Column

+ AsThrift func() *PrestoThriftBlock

+ Count func() int

+ Kind func() typeof.Type

+ Last func() interface{}

+ Min func() (int64, bool)

+ Range func(from int, until int, f func(int, interface{}))

+ Size func() int

+ type PrestoThriftAllOrNoneValueSet struct

+ All bool

+ type PrestoThriftBigint struct

+ Longs []int64

+ Nulls []bool

+ func (b *PrestoThriftBigint) Append(v interface{}) int

+ func (b *PrestoThriftBigint) AppendBlock(blocks []Column)

+ func (b *PrestoThriftBigint) AsProto() *talaria.Column

+ func (b *PrestoThriftBigint) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftBigint) Count() int

+ func (b *PrestoThriftBigint) Kind() typeof.Type

+ func (b *PrestoThriftBigint) Last() interface{}

+ func (b *PrestoThriftBigint) Min() (int64, bool)

+ func (b *PrestoThriftBigint) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftBigint) Size() int

+ type PrestoThriftBigintArray struct

+ Nulls []bool

+ Sizes []int32

+ Values *PrestoThriftBigint

+ type PrestoThriftBlock struct

+ BigintArrayData *PrestoThriftBigintArray

+ BigintData *PrestoThriftBigint

+ BooleanData *PrestoThriftBoolean

+ DateData *PrestoThriftDate

+ DoubleData *PrestoThriftDouble

+ HyperLogLogData *PrestoThriftHyperLogLog

+ IntegerData *PrestoThriftInteger

+ JsonData *PrestoThriftJson

+ TimestampData *PrestoThriftTimestamp

+ VarcharData *PrestoThriftVarchar

+ func (b *PrestoThriftBlock) Count() int

+ func (b *PrestoThriftBlock) Size() int

+ func (b *PrestoThriftBlock) Type() typeof.Type

+ type PrestoThriftBoolean struct

+ Booleans []bool

+ Nulls []bool

+ func (b *PrestoThriftBoolean) Append(v interface{}) int

+ func (b *PrestoThriftBoolean) AppendBlock(blocks []Column)

+ func (b *PrestoThriftBoolean) AsProto() *talaria.Column

+ func (b *PrestoThriftBoolean) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftBoolean) Count() int

+ func (b *PrestoThriftBoolean) Kind() typeof.Type

+ func (b *PrestoThriftBoolean) Last() interface{}

+ func (b *PrestoThriftBoolean) Min() (int64, bool)

+ func (b *PrestoThriftBoolean) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftBoolean) Size() int

+ type PrestoThriftBound int32

+ const PrestoThriftBoundAbove

+ const PrestoThriftBoundBelow

+ const PrestoThriftBoundExactly

+ func (e *PrestoThriftBound) UnmarshalJSON(b []byte) error

+ func (e PrestoThriftBound) MarshalJSON() ([]byte, error)

+ func (e PrestoThriftBound) String() string

+ type PrestoThriftColumnMetadata struct

+ Comment *string

+ Hidden bool

+ Name string

+ Type string

+ type PrestoThriftDate struct

+ Dates []int32

+ Nulls []bool

+ type PrestoThriftDomain struct

+ NullAllowed bool

+ ValueSet *PrestoThriftValueSet

+ type PrestoThriftDouble struct

+ Doubles []float64

+ Nulls []bool

+ func (b *PrestoThriftDouble) Append(v interface{}) int

+ func (b *PrestoThriftDouble) AppendBlock(blocks []Column)

+ func (b *PrestoThriftDouble) AsProto() *talaria.Column

+ func (b *PrestoThriftDouble) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftDouble) Count() int

+ func (b *PrestoThriftDouble) Kind() typeof.Type

+ func (b *PrestoThriftDouble) Last() interface{}

+ func (b *PrestoThriftDouble) Min() (int64, bool)

+ func (b *PrestoThriftDouble) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftDouble) Size() int

+ type PrestoThriftEquatableValueSet struct

+ Values []*PrestoThriftBlock

+ WhiteList bool

+ type PrestoThriftHostAddress struct

+ Host string

+ Port int32

+ type PrestoThriftHyperLogLog struct

+ Bytes []byte

+ Nulls []bool

+ Sizes []int32

+ type PrestoThriftId struct

+ Id []byte

+ type PrestoThriftInteger struct

+ Ints []int32

+ Nulls []bool

+ func (b *PrestoThriftInteger) Append(v interface{}) int

+ func (b *PrestoThriftInteger) AppendBlock(blocks []Column)

+ func (b *PrestoThriftInteger) AsProto() *talaria.Column

+ func (b *PrestoThriftInteger) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftInteger) Count() int

+ func (b *PrestoThriftInteger) Kind() typeof.Type

+ func (b *PrestoThriftInteger) Last() interface{}

+ func (b *PrestoThriftInteger) Min() (int64, bool)

+ func (b *PrestoThriftInteger) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftInteger) Size() int

+ type PrestoThriftJson struct

+ Bytes []byte

+ Nulls []bool

+ Sizes []int32

+ func (b *PrestoThriftJson) Append(v interface{}) int

+ func (b *PrestoThriftJson) AppendBlock(blocks []Column)

+ func (b *PrestoThriftJson) AsProto() *talaria.Column

+ func (b *PrestoThriftJson) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftJson) Count() int

+ func (b *PrestoThriftJson) Kind() typeof.Type

+ func (b *PrestoThriftJson) Last() interface{}

+ func (b *PrestoThriftJson) Min() (int64, bool)

+ func (b *PrestoThriftJson) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftJson) Size() int

+ type PrestoThriftMarker struct

+ Bound PrestoThriftBound

+ Value *PrestoThriftBlock

+ type PrestoThriftNullableColumnSet struct

+ Columns map[string]struct{}

+ type PrestoThriftNullableSchemaName struct

+ SchemaName *string

+ type PrestoThriftNullableTableMetadata struct

+ TableMetadata *PrestoThriftTableMetadata

+ type PrestoThriftNullableToken struct

+ Token *PrestoThriftId

+ type PrestoThriftPageResult struct

+ ColumnBlocks []*PrestoThriftBlock

+ NextToken *PrestoThriftId

+ RowCount int32

+ type PrestoThriftRange struct

+ High *PrestoThriftMarker

+ Low *PrestoThriftMarker

+ func (r *PrestoThriftRange) AsTimeRange() (time.Time, time.Time, bool)

+ type PrestoThriftRangeValueSet struct

+ Ranges []*PrestoThriftRange

+ type PrestoThriftSchemaTableName struct

+ SchemaName string

+ TableName string

+ type PrestoThriftService interface

+ PrestoGetIndexSplits func(schemaTableName *PrestoThriftSchemaTableName, indexColumnNames []string, ...) (*PrestoThriftSplitBatch, error)

+ PrestoGetRows func(splitId *PrestoThriftId, columns []string, maxBytes int64, ...) (*PrestoThriftPageResult, error)

+ PrestoGetSplits func(schemaTableName *PrestoThriftSchemaTableName, ...) (*PrestoThriftSplitBatch, error)

+ PrestoGetTableMetadata func(schemaTableName *PrestoThriftSchemaTableName) (*PrestoThriftNullableTableMetadata, error)

+ PrestoListSchemaNames func() ([]string, error)

+ PrestoListTables func(schemaNameOrNull *PrestoThriftNullableSchemaName) ([]*PrestoThriftSchemaTableName, error)

+ type PrestoThriftServiceClient struct

+ Client Client

+ func (s *PrestoThriftServiceClient) PrestoGetIndexSplits(schemaTableName *PrestoThriftSchemaTableName, indexColumnNames []string, ...) (ret *PrestoThriftSplitBatch, err error)

+ func (s *PrestoThriftServiceClient) PrestoGetRows(splitId *PrestoThriftId, columns []string, maxBytes int64, ...) (ret *PrestoThriftPageResult, err error)

+ func (s *PrestoThriftServiceClient) PrestoGetSplits(schemaTableName *PrestoThriftSchemaTableName, ...) (ret *PrestoThriftSplitBatch, err error)

+ func (s *PrestoThriftServiceClient) PrestoGetTableMetadata(schemaTableName *PrestoThriftSchemaTableName) (ret *PrestoThriftNullableTableMetadata, err error)

+ func (s *PrestoThriftServiceClient) PrestoListSchemaNames() (ret []string, err error)

+ func (s *PrestoThriftServiceClient) PrestoListTables(schemaNameOrNull *PrestoThriftNullableSchemaName) (ret []*PrestoThriftSchemaTableName, err error)

+ type PrestoThriftServiceException struct

+ Message string

+ Retryable bool

+ func (e *PrestoThriftServiceException) Error() string

+ type PrestoThriftServicePrestoGetIndexSplitsRequest struct

+ IndexColumnNames []string

+ Keys *PrestoThriftPageResult

+ MaxSplitCount int32

+ NextToken *PrestoThriftNullableToken

+ OutputColumnNames []string

+ OutputConstraint *PrestoThriftTupleDomain

+ SchemaTableName *PrestoThriftSchemaTableName

+ type PrestoThriftServicePrestoGetIndexSplitsResponse struct

+ Ex1 *PrestoThriftServiceException

+ Value *PrestoThriftSplitBatch

+ type PrestoThriftServicePrestoGetRowsRequest struct

+ Columns []string

+ MaxBytes int64

+ NextToken *PrestoThriftNullableToken

+ SplitId *PrestoThriftId

+ type PrestoThriftServicePrestoGetRowsResponse struct

+ Ex1 *PrestoThriftServiceException

+ Value *PrestoThriftPageResult

+ type PrestoThriftServicePrestoGetSplitsRequest struct

+ DesiredColumns *PrestoThriftNullableColumnSet

+ MaxSplitCount int32

+ NextToken *PrestoThriftNullableToken

+ OutputConstraint *PrestoThriftTupleDomain

+ SchemaTableName *PrestoThriftSchemaTableName

+ type PrestoThriftServicePrestoGetSplitsResponse struct

+ Ex1 *PrestoThriftServiceException

+ Value *PrestoThriftSplitBatch

+ type PrestoThriftServicePrestoGetTableMetadataRequest struct

+ SchemaTableName *PrestoThriftSchemaTableName

+ type PrestoThriftServicePrestoGetTableMetadataResponse struct

+ Ex1 *PrestoThriftServiceException

+ Value *PrestoThriftNullableTableMetadata

+ type PrestoThriftServicePrestoListSchemaNamesRequest struct

+ type PrestoThriftServicePrestoListSchemaNamesResponse struct

+ Ex1 *PrestoThriftServiceException

+ Value []string

+ type PrestoThriftServicePrestoListTablesRequest struct

+ SchemaNameOrNull *PrestoThriftNullableSchemaName

+ type PrestoThriftServicePrestoListTablesResponse struct

+ Ex1 *PrestoThriftServiceException

+ Value []*PrestoThriftSchemaTableName

+ type PrestoThriftServiceServer struct

+ Implementation PrestoThriftService

+ func (s *PrestoThriftServiceServer) PrestoGetIndexSplits(req *PrestoThriftServicePrestoGetIndexSplitsRequest, ...) error

+ func (s *PrestoThriftServiceServer) PrestoGetRows(req *PrestoThriftServicePrestoGetRowsRequest, ...) error

+ func (s *PrestoThriftServiceServer) PrestoGetSplits(req *PrestoThriftServicePrestoGetSplitsRequest, ...) error

+ func (s *PrestoThriftServiceServer) PrestoGetTableMetadata(req *PrestoThriftServicePrestoGetTableMetadataRequest, ...) error

+ func (s *PrestoThriftServiceServer) PrestoListSchemaNames(req *PrestoThriftServicePrestoListSchemaNamesRequest, ...) error

+ func (s *PrestoThriftServiceServer) PrestoListTables(req *PrestoThriftServicePrestoListTablesRequest, ...) error

+ type PrestoThriftSplit struct

+ Hosts []*PrestoThriftHostAddress

+ SplitId *PrestoThriftId

+ type PrestoThriftSplitBatch struct

+ NextToken *PrestoThriftId

+ Splits []*PrestoThriftSplit

+ type PrestoThriftTableMetadata struct

+ Columns []*PrestoThriftColumnMetadata

+ Comment *string

+ IndexableKeys []map[string]struct{}

+ SchemaTableName *PrestoThriftSchemaTableName

+ type PrestoThriftTimestamp struct

+ Nulls []bool

+ Timestamps []int64

+ func (b *PrestoThriftTimestamp) Append(v interface{}) int

+ func (b *PrestoThriftTimestamp) AppendBlock(blocks []Column)

+ func (b *PrestoThriftTimestamp) AsProto() *talaria.Column

+ func (b *PrestoThriftTimestamp) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftTimestamp) Count() int

+ func (b *PrestoThriftTimestamp) Kind() typeof.Type

+ func (b *PrestoThriftTimestamp) Last() interface{}

+ func (b *PrestoThriftTimestamp) Min() (int64, bool)

+ func (b *PrestoThriftTimestamp) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftTimestamp) Size() int

+ type PrestoThriftTupleDomain struct

+ Domains map[string]*PrestoThriftDomain

+ func NewDomain(hashKey, sortKey string, filters ...string) (*PrestoThriftTupleDomain, error)

+ type PrestoThriftValueSet struct

+ AllOrNoneValueSet *PrestoThriftAllOrNoneValueSet

+ EquatableValueSet *PrestoThriftEquatableValueSet

+ RangeValueSet *PrestoThriftRangeValueSet

+ type PrestoThriftVarchar struct

+ Bytes []byte

+ Nulls []bool

+ Sizes []int32

+ func (b *PrestoThriftVarchar) Append(v interface{}) int

+ func (b *PrestoThriftVarchar) AppendBlock(blocks []Column)

+ func (b *PrestoThriftVarchar) AsProto() *talaria.Column

+ func (b *PrestoThriftVarchar) AsThrift() *PrestoThriftBlock

+ func (b *PrestoThriftVarchar) Count() int

+ func (b *PrestoThriftVarchar) Kind() typeof.Type

+ func (b *PrestoThriftVarchar) Last() interface{}

+ func (b *PrestoThriftVarchar) Min() (int64, bool)

+ func (b *PrestoThriftVarchar) Range(from int, until int, f func(int, interface{}))

+ func (b *PrestoThriftVarchar) Size() int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL