presto

package
v1.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 1, 2023 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (

	// PrestoThriftBoundByName ...
	PrestoThriftBoundByName = map[string]PrestoThriftBound{
		"PrestoThriftBound.ABOVE":   PrestoThriftBoundAbove,
		"PrestoThriftBound.BELOW":   PrestoThriftBoundBelow,
		"PrestoThriftBound.EXACTLY": PrestoThriftBoundExactly,
	}

	// PrestoThriftBoundByValue ...
	PrestoThriftBoundByValue = map[PrestoThriftBound]string{
		PrestoThriftBoundAbove:   "PrestoThriftBound.ABOVE",
		PrestoThriftBoundBelow:   "PrestoThriftBound.BELOW",
		PrestoThriftBoundExactly: "PrestoThriftBound.EXACTLY",
	}
)

Functions

func NewServerCodec added in v1.3.1 

func NewServerCodec(conn thrift.Transport) rpc.ServerCodec

NewServerCodec returns a new rpc.ServerCodec using Thrift RPC on conn using the specified protocol.

func Serve 

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

Serve creates and serves thrift RPC for presto. Context is used for cancellation purposes.

func ServeConn added in v1.3.1 

func ServeConn(conn thrift.Transport)

ServeConn runs the Thrift RPC server on a single connection. ServeConn blocks, serving the connection until the client hangs up. The caller typically invokes ServeConn in a go statement.

Types

type Client 

type Client interface {
	Call(method string, request interface{}, response interface{}) error
}

Client is useful for testing the RPC

type Column 

type Column interface {
	Append(v interface{}) int
	AppendBlock([]Column)
	Count() int
	Size() int
	Kind() typeof.Type
	Last() interface{}
	Min() (int64, bool)
	AsThrift() *PrestoThriftBlock
	AsProto() *talaria.Column
	Range(from int, until int, f func(int, interface{}) error) error
	At(index int) interface{}
}

Column contract represent a column that can be appended.

type PrestoThriftAllOrNoneValueSet 

type PrestoThriftAllOrNoneValueSet struct {
	All bool `thrift:"1,required" json:"all"`
}

PrestoThriftAllOrNoneValueSet ...

type PrestoThriftBigint 

type PrestoThriftBigint struct {
	Nulls []bool  `thrift:"1" json:"nulls,omitempty"`
	Longs []int64 `thrift:"2" json:"longs,omitempty"`
}

PrestoThriftBigint ...

func (*PrestoThriftBigint) Append 

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

Append adds a value to the block.

func (*PrestoThriftBigint) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftBigint) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftBigint) AsThrift 

func (b *PrestoThriftBigint) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftBigint) At added in v1.2.5 

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

func (*PrestoThriftBigint) Count 

func (b *PrestoThriftBigint) Count() int

Count returns the number of elements in the block

func (*PrestoThriftBigint) Kind 

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

Kind returns a type of the block

func (*PrestoThriftBigint) Last 

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

Last returns the last value

func (*PrestoThriftBigint) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftBigint) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftBigint) Size 

func (b *PrestoThriftBigint) Size() int

Size returns the size of the column, in bytes.

type PrestoThriftBigintArray 

type PrestoThriftBigintArray struct {
	Nulls  []bool              `thrift:"1" json:"nulls,omitempty"`
	Sizes  []int32             `thrift:"2" json:"sizes,omitempty"`
	Values *PrestoThriftBigint `thrift:"3" json:"values,omitempty"`
}

PrestoThriftBigintArray ...

type PrestoThriftBlock 

type PrestoThriftBlock struct {
	IntegerData     *PrestoThriftInteger     `thrift:"1" json:"integerData,omitempty"`
	BigintData      *PrestoThriftBigint      `thrift:"2" json:"bigintData,omitempty"`
	DoubleData      *PrestoThriftDouble      `thrift:"3" json:"doubleData,omitempty"`
	VarcharData     *PrestoThriftVarchar     `thrift:"4" json:"varcharData,omitempty"`
	BooleanData     *PrestoThriftBoolean     `thrift:"5" json:"booleanData,omitempty"`
	DateData        *PrestoThriftDate        `thrift:"6" json:"dateData,omitempty"`
	TimestampData   *PrestoThriftTimestamp   `thrift:"7" json:"timestampData,omitempty"`
	JsonData        *PrestoThriftJson        `thrift:"8" json:"jsonData,omitempty"`
	HyperLogLogData *PrestoThriftHyperLogLog `thrift:"9" json:"hyperLogLogData,omitempty"`
	BigintArrayData *PrestoThriftBigintArray `thrift:"10" json:"bigintArrayData,omitempty"`
}

PrestoThriftBlock ...

func (*PrestoThriftBlock) Count 

func (b *PrestoThriftBlock) Count() int

Count returns the count of rows in the block.

func (*PrestoThriftBlock) Size 

func (b *PrestoThriftBlock) Size() int

Size returns the size of the block.

func (*PrestoThriftBlock) Type 

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

Type returns the data type for the block

type PrestoThriftBoolean 

type PrestoThriftBoolean struct {
	Nulls    []bool `thrift:"1" json:"nulls,omitempty"`
	Booleans []bool `thrift:"2" json:"booleans,omitempty"`
}

PrestoThriftBoolean ...

func (*PrestoThriftBoolean) Append 

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

Append adds a value to the block.

func (*PrestoThriftBoolean) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftBoolean) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftBoolean) AsThrift 

func (b *PrestoThriftBoolean) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftBoolean) At added in v1.2.5 

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

func (*PrestoThriftBoolean) Count 

func (b *PrestoThriftBoolean) Count() int

Count returns the number of elements in the block

func (*PrestoThriftBoolean) Kind 

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

Kind returns a type of the block

func (*PrestoThriftBoolean) Last 

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

Last returns the last value

func (*PrestoThriftBoolean) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftBoolean) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftBoolean) Size 

func (b *PrestoThriftBoolean) Size() int

Size returns the size of the column, in bytes.

type PrestoThriftBound 

type PrestoThriftBound int32

PrestoThriftBound ... 

const (

	// PrestoThriftBoundAbove ...
	PrestoThriftBoundAbove PrestoThriftBound = 3

	// PrestoThriftBoundBelow ...
	PrestoThriftBoundBelow PrestoThriftBound = 1

	// PrestoThriftBoundExactly ...
	PrestoThriftBoundExactly PrestoThriftBound = 2
)

func (PrestoThriftBound) MarshalJSON 

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

MarshalJSON ...

func (PrestoThriftBound) String 

func (e PrestoThriftBound) String() string

String ...

func (*PrestoThriftBound) UnmarshalJSON 

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

UnmarshalJSON ...

type PrestoThriftColumnMetadata 

type PrestoThriftColumnMetadata struct {
	Name    string  `thrift:"1,required" json:"name"`
	Type    string  `thrift:"2,required" json:"type"`
	Comment *string `thrift:"3" json:"comment,omitempty"`
	Hidden  bool    `thrift:"4,required" json:"hidden"`
}

PrestoThriftColumnMetadata ...

type PrestoThriftDate 

type PrestoThriftDate struct {
	Nulls []bool  `thrift:"1" json:"nulls,omitempty"`
	Dates []int32 `thrift:"2" json:"dates,omitempty"`
}

PrestoThriftDate ...

type PrestoThriftDomain 

type PrestoThriftDomain struct {
	ValueSet    *PrestoThriftValueSet `thrift:"1,required" json:"valueSet"`
	NullAllowed bool                  `thrift:"2,required" json:"nullAllowed"`
}

PrestoThriftDomain ...

type PrestoThriftDouble 

type PrestoThriftDouble struct {
	Nulls   []bool    `thrift:"1" json:"nulls,omitempty"`
	Doubles []float64 `thrift:"2" json:"doubles,omitempty"`
}

PrestoThriftDouble ...

func (*PrestoThriftDouble) Append 

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

Append adds a value to the block.

func (*PrestoThriftDouble) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftDouble) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftDouble) AsThrift 

func (b *PrestoThriftDouble) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftDouble) At added in v1.2.5 

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

func (*PrestoThriftDouble) Count 

func (b *PrestoThriftDouble) Count() int

Count returns the number of elements in the block

func (*PrestoThriftDouble) Kind 

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

Kind returns a type of the block

func (*PrestoThriftDouble) Last 

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

Last returns the last value

func (*PrestoThriftDouble) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftDouble) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftDouble) Size 

func (b *PrestoThriftDouble) Size() int

Size returns the size of the column, in bytes.

type PrestoThriftEquatableValueSet 

type PrestoThriftEquatableValueSet struct {
	WhiteList bool                 `thrift:"1,required" json:"whiteList"`
	Values    []*PrestoThriftBlock `thrift:"2,required" json:"values"`
}

PrestoThriftEquatableValueSet ...

type PrestoThriftHostAddress 

type PrestoThriftHostAddress struct {
	Host string `thrift:"1,required" json:"host"`
	Port int32  `thrift:"2,required" json:"port"`
}

PrestoThriftHostAddress ...

type PrestoThriftHyperLogLog 

type PrestoThriftHyperLogLog struct {
	Nulls []bool  `thrift:"1" json:"nulls,omitempty"`
	Sizes []int32 `thrift:"2" json:"sizes,omitempty"`
	Bytes []byte  `thrift:"3" json:"bytes,omitempty"`
}

PrestoThriftHyperLogLog ...

type PrestoThriftId 

type PrestoThriftId struct {
	Id []byte `thrift:"1,required" json:"id"`
}

PrestoThriftId ...

type PrestoThriftInteger 

type PrestoThriftInteger struct {
	Nulls []bool  `thrift:"1" json:"nulls,omitempty"`
	Ints  []int32 `thrift:"2" json:"ints,omitempty"`
}

PrestoThriftInteger ...

func (*PrestoThriftInteger) Append 

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

Append adds a value to the block.

func (*PrestoThriftInteger) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftInteger) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftInteger) AsThrift 

func (b *PrestoThriftInteger) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftInteger) At added in v1.2.5 

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

func (*PrestoThriftInteger) Count 

func (b *PrestoThriftInteger) Count() int

Count returns the number of elements in the block

func (*PrestoThriftInteger) Kind 

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

Kind returns a type of the block

func (*PrestoThriftInteger) Last 

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

Last returns the last value

func (*PrestoThriftInteger) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftInteger) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftInteger) Size 

func (b *PrestoThriftInteger) Size() int

Size returns the size of the column, in bytes.

type PrestoThriftJson 

type PrestoThriftJson struct {
	Nulls []bool  `thrift:"1" json:"nulls,omitempty"`
	Sizes []int32 `thrift:"2" json:"sizes,omitempty"`
	Bytes []byte  `thrift:"3" json:"bytes,omitempty"`
}

PrestoThriftJson ...

func (*PrestoThriftJson) Append 

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

Append adds a value to the block.

func (*PrestoThriftJson) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftJson) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftJson) AsThrift 

func (b *PrestoThriftJson) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftJson) At added in v1.2.5 

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

func (*PrestoThriftJson) Count 

func (b *PrestoThriftJson) Count() int

Count returns the number of elements in the block

func (*PrestoThriftJson) Kind 

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

Kind returns a type of the block

func (*PrestoThriftJson) Last 

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

Last returns the last value

func (*PrestoThriftJson) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftJson) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftJson) Size 

func (b *PrestoThriftJson) Size() int

Size returns the size of the column, in bytes.

type PrestoThriftMarker 

type PrestoThriftMarker struct {
	Value *PrestoThriftBlock `thrift:"1" json:"value,omitempty"`
	Bound PrestoThriftBound  `thrift:"2,required" json:"bound"`
}

PrestoThriftMarker ...

type PrestoThriftNullableColumnSet 

type PrestoThriftNullableColumnSet struct {
	Columns map[string]struct{} `thrift:"1" json:"columns,omitempty"`
}

PrestoThriftNullableColumnSet ...

type PrestoThriftNullableSchemaName 

type PrestoThriftNullableSchemaName struct {
	SchemaName *string `thrift:"1" json:"schemaName,omitempty"`
}

PrestoThriftNullableSchemaName ...

type PrestoThriftNullableTableMetadata 

type PrestoThriftNullableTableMetadata struct {
	TableMetadata *PrestoThriftTableMetadata `thrift:"1" json:"tableMetadata,omitempty"`
}

PrestoThriftNullableTableMetadata ...

type PrestoThriftNullableToken 

type PrestoThriftNullableToken struct {
	Token *PrestoThriftId `thrift:"1" json:"token,omitempty"`
}

PrestoThriftNullableToken ...

type PrestoThriftPageResult 

type PrestoThriftPageResult struct {
	ColumnBlocks []*PrestoThriftBlock `thrift:"1,required" json:"columnBlocks"`
	RowCount     int32                `thrift:"2,required" json:"rowCount"`
	NextToken    *PrestoThriftId      `thrift:"3" json:"nextToken,omitempty"`
}

PrestoThriftPageResult ...

type PrestoThriftRange 

type PrestoThriftRange struct {
	Low  *PrestoThriftMarker `thrift:"1,required" json:"low"`
	High *PrestoThriftMarker `thrift:"2,required" json:"high"`
}

PrestoThriftRange ...

func (*PrestoThriftRange) AsTimeRange 

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

AsTimeRange converts thrift range as a time range

type PrestoThriftRangeValueSet 

type PrestoThriftRangeValueSet struct {
	Ranges []*PrestoThriftRange `thrift:"1,required" json:"ranges"`
}

PrestoThriftRangeValueSet ...

type PrestoThriftSchemaTableName 

type PrestoThriftSchemaTableName struct {
	SchemaName string `thrift:"1,required" json:"schemaName"`
	TableName  string `thrift:"2,required" json:"tableName"`
}

PrestoThriftSchemaTableName ...

type PrestoThriftService 

type PrestoThriftService interface {
	PrestoGetIndexSplits(schemaTableName *PrestoThriftSchemaTableName, indexColumnNames []string, outputColumnNames []string, keys *PrestoThriftPageResult, outputConstraint *PrestoThriftTupleDomain, maxSplitCount int32, nextToken *PrestoThriftNullableToken) (*PrestoThriftSplitBatch, error)
	PrestoGetRows(splitId *PrestoThriftId, columns []string, maxBytes int64, nextToken *PrestoThriftNullableToken) (*PrestoThriftPageResult, error)
	PrestoGetSplits(schemaTableName *PrestoThriftSchemaTableName, desiredColumns *PrestoThriftNullableColumnSet, outputConstraint *PrestoThriftTupleDomain, maxSplitCount int32, nextToken *PrestoThriftNullableToken) (*PrestoThriftSplitBatch, error)
	PrestoGetTableMetadata(schemaTableName *PrestoThriftSchemaTableName) (*PrestoThriftNullableTableMetadata, error)
	PrestoListSchemaNames() ([]string, error)
	PrestoListTables(schemaNameOrNull *PrestoThriftNullableSchemaName) ([]*PrestoThriftSchemaTableName, error)
}

PrestoThriftService ...

type PrestoThriftServiceClient 

type PrestoThriftServiceClient struct {
	Client Client
}

PrestoThriftServiceClient ...

func (*PrestoThriftServiceClient) PrestoGetIndexSplits 

func (s *PrestoThriftServiceClient) PrestoGetIndexSplits(schemaTableName *PrestoThriftSchemaTableName, indexColumnNames []string, outputColumnNames []string, keys *PrestoThriftPageResult, outputConstraint *PrestoThriftTupleDomain, maxSplitCount int32, nextToken *PrestoThriftNullableToken) (ret *PrestoThriftSplitBatch, err error)

PrestoGetIndexSplits ...

func (*PrestoThriftServiceClient) PrestoGetRows 

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

func (*PrestoThriftServiceClient) PrestoGetSplits 

func (s *PrestoThriftServiceClient) PrestoGetSplits(schemaTableName *PrestoThriftSchemaTableName, desiredColumns *PrestoThriftNullableColumnSet, outputConstraint *PrestoThriftTupleDomain, maxSplitCount int32, nextToken *PrestoThriftNullableToken) (ret *PrestoThriftSplitBatch, err error)

func (*PrestoThriftServiceClient) PrestoGetTableMetadata 

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

PrestoGetTableMetadata ...

func (*PrestoThriftServiceClient) PrestoListSchemaNames 

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

PrestoListSchemaNames ...

func (*PrestoThriftServiceClient) PrestoListTables 

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

PrestoListTables ...

type PrestoThriftServiceException 

type PrestoThriftServiceException struct {
	Message   string `thrift:"1,required" json:"message"`
	Retryable bool   `thrift:"2,required" json:"retryable"`
}

PrestoThriftServiceException ...

func (*PrestoThriftServiceException) Error 

func (e *PrestoThriftServiceException) Error() string

type PrestoThriftServicePrestoGetIndexSplitsRequest 

type PrestoThriftServicePrestoGetIndexSplitsRequest struct {
	SchemaTableName   *PrestoThriftSchemaTableName `thrift:"1,required" json:"schemaTableName"`
	IndexColumnNames  []string                     `thrift:"2,required" json:"indexColumnNames"`
	OutputColumnNames []string                     `thrift:"3,required" json:"outputColumnNames"`
	Keys              *PrestoThriftPageResult      `thrift:"4,required" json:"keys"`
	OutputConstraint  *PrestoThriftTupleDomain     `thrift:"5,required" json:"outputConstraint"`
	MaxSplitCount     int32                        `thrift:"6,required" json:"maxSplitCount"`
	NextToken         *PrestoThriftNullableToken   `thrift:"7,required" json:"nextToken"`
}

PrestoThriftServicePrestoGetIndexSplitsRequest ...

type PrestoThriftServicePrestoGetIndexSplitsResponse 

type PrestoThriftServicePrestoGetIndexSplitsResponse struct {
	Value *PrestoThriftSplitBatch       `thrift:"0" json:"value,omitempty"`
	Ex1   *PrestoThriftServiceException `thrift:"1" json:"ex1,omitempty"`
}

PrestoThriftServicePrestoGetIndexSplitsResponse ...

type PrestoThriftServicePrestoGetRowsRequest 

type PrestoThriftServicePrestoGetRowsRequest struct {
	SplitId   *PrestoThriftId            `thrift:"1,required" json:"splitId"`
	Columns   []string                   `thrift:"2,required" json:"columns"`
	MaxBytes  int64                      `thrift:"3,required" json:"maxBytes"`
	NextToken *PrestoThriftNullableToken `thrift:"4,required" json:"nextToken"`
}

PrestoThriftServicePrestoGetRowsRequest ...

type PrestoThriftServicePrestoGetRowsResponse 

type PrestoThriftServicePrestoGetRowsResponse struct {
	Value *PrestoThriftPageResult       `thrift:"0" json:"value,omitempty"`
	Ex1   *PrestoThriftServiceException `thrift:"1" json:"ex1,omitempty"`
}

PrestoThriftServicePrestoGetRowsResponse ...

type PrestoThriftServicePrestoGetSplitsRequest 

type PrestoThriftServicePrestoGetSplitsRequest struct {
	SchemaTableName  *PrestoThriftSchemaTableName   `thrift:"1,required" json:"schemaTableName"`
	DesiredColumns   *PrestoThriftNullableColumnSet `thrift:"2,required" json:"desiredColumns"`
	OutputConstraint *PrestoThriftTupleDomain       `thrift:"3,required" json:"outputConstraint"`
	MaxSplitCount    int32                          `thrift:"4,required" json:"maxSplitCount"`
	NextToken        *PrestoThriftNullableToken     `thrift:"5,required" json:"nextToken"`
}

PrestoThriftServicePrestoGetSplitsRequest ...

type PrestoThriftServicePrestoGetSplitsResponse 

type PrestoThriftServicePrestoGetSplitsResponse struct {
	Value *PrestoThriftSplitBatch       `thrift:"0" json:"value,omitempty"`
	Ex1   *PrestoThriftServiceException `thrift:"1" json:"ex1,omitempty"`
}

PrestoThriftServicePrestoGetSplitsResponse ...

type PrestoThriftServicePrestoGetTableMetadataRequest 

type PrestoThriftServicePrestoGetTableMetadataRequest struct {
	SchemaTableName *PrestoThriftSchemaTableName `thrift:"1,required" json:"schemaTableName"`
}

PrestoThriftServicePrestoGetTableMetadataRequest ...

type PrestoThriftServicePrestoGetTableMetadataResponse 

type PrestoThriftServicePrestoGetTableMetadataResponse struct {
	Value *PrestoThriftNullableTableMetadata `thrift:"0" json:"value,omitempty"`
	Ex1   *PrestoThriftServiceException      `thrift:"1" json:"ex1,omitempty"`
}

PrestoThriftServicePrestoGetTableMetadataResponse ...

type PrestoThriftServicePrestoListSchemaNamesRequest 

type PrestoThriftServicePrestoListSchemaNamesRequest struct {
}

PrestoThriftServicePrestoListSchemaNamesRequest ...

type PrestoThriftServicePrestoListSchemaNamesResponse 

type PrestoThriftServicePrestoListSchemaNamesResponse struct {
	Value []string                      `thrift:"0" json:"value,omitempty"`
	Ex1   *PrestoThriftServiceException `thrift:"1" json:"ex1,omitempty"`
}

PrestoThriftServicePrestoListSchemaNamesResponse ...

type PrestoThriftServicePrestoListTablesRequest 

type PrestoThriftServicePrestoListTablesRequest struct {
	SchemaNameOrNull *PrestoThriftNullableSchemaName `thrift:"1,required" json:"schemaNameOrNull"`
}

PrestoThriftServicePrestoListTablesRequest ...

type PrestoThriftServicePrestoListTablesResponse 

type PrestoThriftServicePrestoListTablesResponse struct {
	Value []*PrestoThriftSchemaTableName `thrift:"0" json:"value,omitempty"`
	Ex1   *PrestoThriftServiceException  `thrift:"1" json:"ex1,omitempty"`
}

PrestoThriftServicePrestoListTablesResponse ...

type PrestoThriftServiceServer 

type PrestoThriftServiceServer struct {
	Implementation PrestoThriftService
}

PrestoThriftServiceServer ...

func (*PrestoThriftServiceServer) PrestoGetIndexSplits 

func (s *PrestoThriftServiceServer) PrestoGetIndexSplits(req *PrestoThriftServicePrestoGetIndexSplitsRequest, res *PrestoThriftServicePrestoGetIndexSplitsResponse) error

PrestoGetIndexSplits ...

func (*PrestoThriftServiceServer) PrestoGetRows 

func (s *PrestoThriftServiceServer) PrestoGetRows(req *PrestoThriftServicePrestoGetRowsRequest, res *PrestoThriftServicePrestoGetRowsResponse) error

PrestoGetRows ...

func (*PrestoThriftServiceServer) PrestoGetSplits 

func (s *PrestoThriftServiceServer) PrestoGetSplits(req *PrestoThriftServicePrestoGetSplitsRequest, res *PrestoThriftServicePrestoGetSplitsResponse) error

PrestoGetSplits ...

func (*PrestoThriftServiceServer) PrestoGetTableMetadata 

func (s *PrestoThriftServiceServer) PrestoGetTableMetadata(req *PrestoThriftServicePrestoGetTableMetadataRequest, res *PrestoThriftServicePrestoGetTableMetadataResponse) error

PrestoGetTableMetadata ...

func (*PrestoThriftServiceServer) PrestoListSchemaNames 

func (s *PrestoThriftServiceServer) PrestoListSchemaNames(req *PrestoThriftServicePrestoListSchemaNamesRequest, res *PrestoThriftServicePrestoListSchemaNamesResponse) error

PrestoListSchemaNames ...

func (*PrestoThriftServiceServer) PrestoListTables 

func (s *PrestoThriftServiceServer) PrestoListTables(req *PrestoThriftServicePrestoListTablesRequest, res *PrestoThriftServicePrestoListTablesResponse) error

PrestoListTables ...

type PrestoThriftSplit 

type PrestoThriftSplit struct {
	SplitId *PrestoThriftId            `thrift:"1,required" json:"splitId"`
	Hosts   []*PrestoThriftHostAddress `thrift:"2,required" json:"hosts"`
}

PrestoThriftSplit ...

type PrestoThriftSplitBatch 

type PrestoThriftSplitBatch struct {
	Splits    []*PrestoThriftSplit `thrift:"1,required" json:"splits"`
	NextToken *PrestoThriftId      `thrift:"2" json:"nextToken,omitempty"`
}

PrestoThriftSplitBatch ...

type PrestoThriftTableMetadata 

type PrestoThriftTableMetadata struct {
	SchemaTableName *PrestoThriftSchemaTableName  `thrift:"1,required" json:"schemaTableName"`
	Columns         []*PrestoThriftColumnMetadata `thrift:"2,required" json:"columns"`
	Comment         *string                       `thrift:"3" json:"comment,omitempty"`
	IndexableKeys   []map[string]struct{}         `thrift:"4" json:"indexableKeys,omitempty"`
}

PrestoThriftTableMetadata ...

type PrestoThriftTimestamp 

type PrestoThriftTimestamp struct {
	Nulls      []bool  `thrift:"1" json:"nulls,omitempty"`
	Timestamps []int64 `thrift:"2" json:"timestamps,omitempty"`
}

PrestoThriftTimestamp ...

func (*PrestoThriftTimestamp) Append 

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

Append adds a value to the block.

func (*PrestoThriftTimestamp) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftTimestamp) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftTimestamp) AsThrift 

func (b *PrestoThriftTimestamp) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftTimestamp) At added in v1.2.5 

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

func (*PrestoThriftTimestamp) Count 

func (b *PrestoThriftTimestamp) Count() int

Count returns the number of elements in the block

func (*PrestoThriftTimestamp) Kind 

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

Kind returns a type of the block

func (*PrestoThriftTimestamp) Last 

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

Last returns the last value

func (*PrestoThriftTimestamp) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftTimestamp) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftTimestamp) Size 

func (b *PrestoThriftTimestamp) Size() int

Size returns the size of the column, in bytes.

type PrestoThriftTupleDomain 

type PrestoThriftTupleDomain struct {
	Domains map[string]*PrestoThriftDomain `thrift:"1" json:"domains,omitempty"`
}

PrestoThriftTupleDomain ...

func NewDomain 

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

NewDomain creates a new domain from a set of filters

type PrestoThriftValueSet 

type PrestoThriftValueSet struct {
	AllOrNoneValueSet *PrestoThriftAllOrNoneValueSet `thrift:"1" json:"allOrNoneValueSet,omitempty"`
	EquatableValueSet *PrestoThriftEquatableValueSet `thrift:"2" json:"equatableValueSet,omitempty"`
	RangeValueSet     *PrestoThriftRangeValueSet     `thrift:"3" json:"rangeValueSet,omitempty"`
}

PrestoThriftValueSet ...

type PrestoThriftVarchar 

type PrestoThriftVarchar struct {
	Nulls []bool  `thrift:"1" json:"nulls,omitempty"`
	Sizes []int32 `thrift:"2" json:"sizes,omitempty"`
	Bytes []byte  `thrift:"3" json:"bytes,omitempty"`
}

PrestoThriftVarchar ...

func (*PrestoThriftVarchar) Append 

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

Append adds a value to the block.

func (*PrestoThriftVarchar) AppendBlock 

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

AppendBlock appends an entire block

func (*PrestoThriftVarchar) AsProto 

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

AsProto returns a block for the response.

func (*PrestoThriftVarchar) AsThrift 

func (b *PrestoThriftVarchar) AsThrift() *PrestoThriftBlock

AsThrift returns a block for the response.

func (*PrestoThriftVarchar) At added in v1.2.5 

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

func (*PrestoThriftVarchar) Count 

func (b *PrestoThriftVarchar) Count() int

Count returns the number of elements in the block

func (*PrestoThriftVarchar) Kind 

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

Kind returns a type of the block

func (*PrestoThriftVarchar) Last 

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

Last returns the last value

func (*PrestoThriftVarchar) Min 

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

Min returns the minimum value of the column (only works for numbers).

func (*PrestoThriftVarchar) Range 

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

Range iterates over the column executing f on its elements

func (*PrestoThriftVarchar) Size 

func (b *PrestoThriftVarchar) Size() int

Size returns the size of the column, in bytes.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.