types

package
v0.16.0 Latest Latest
Warning

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

Go to latest
Published: Sep 22, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int
View Source
var TAggregateFunction_FinalizeFnSymbol_DEFAULT string
View Source
var TAggregateFunction_GetValueFnSymbol_DEFAULT string
View Source
var TAggregateFunction_IgnoresDistinct_DEFAULT bool
View Source
var TAggregateFunction_MergeFnSymbol_DEFAULT string
View Source
var TAggregateFunction_RemoveFnSymbol_DEFAULT string
View Source
var TAggregateFunction_SerializeFnSymbol_DEFAULT string
View Source
var TFunctionName_DbName_DEFAULT string
View Source
var TFunction_ArgTypes_DEFAULT []*TColumnType
View Source
var TFunction_Comment_DEFAULT string
View Source
var TFunction_HasVarArgs__DEFAULT bool
View Source
var TFunction_HdfsLocation_DEFAULT string
View Source
var TFunction_IsPersistent_DEFAULT bool
View Source
var TFunction_LastModifiedTime_DEFAULT int64
View Source
var TFunction_Signature_DEFAULT string
View Source
var TNetworkAddress_UdsAddress_DEFAULT string
View Source
var TScalarFunction_CloseFnSymbol_DEFAULT string
View Source
var TScalarFunction_PrepareFnSymbol_DEFAULT string
View Source
var TScalarType_Len_DEFAULT int32
View Source
var TScalarType_Precision_DEFAULT int32
View Source
var TScalarType_Scale_DEFAULT int32
View Source
var TStructField_Comment_DEFAULT string
View Source
var TStructField_FieldID_DEFAULT int32
View Source
var TTypeNode_StructFields_DEFAULT []*TStructField

Functions

This section is empty.

Types

type TAggregateFunction

type TAggregateFunction struct {
	IntermediateType  *TColumnType `thrift:"intermediate_type,1,required" db:"intermediate_type" json:"intermediate_type"`
	IsAnalyticOnlyFn  bool         `thrift:"is_analytic_only_fn,2,required" db:"is_analytic_only_fn" json:"is_analytic_only_fn"`
	UpdateFnSymbol    string       `thrift:"update_fn_symbol,3,required" db:"update_fn_symbol" json:"update_fn_symbol"`
	InitFnSymbol      string       `thrift:"init_fn_symbol,4,required" db:"init_fn_symbol" json:"init_fn_symbol"`
	SerializeFnSymbol *string      `thrift:"serialize_fn_symbol,5" db:"serialize_fn_symbol" json:"serialize_fn_symbol,omitempty"`
	MergeFnSymbol     *string      `thrift:"merge_fn_symbol,6" db:"merge_fn_symbol" json:"merge_fn_symbol,omitempty"`
	FinalizeFnSymbol  *string      `thrift:"finalize_fn_symbol,7" db:"finalize_fn_symbol" json:"finalize_fn_symbol,omitempty"`
	GetValueFnSymbol  *string      `thrift:"get_value_fn_symbol,8" db:"get_value_fn_symbol" json:"get_value_fn_symbol,omitempty"`
	RemoveFnSymbol    *string      `thrift:"remove_fn_symbol,9" db:"remove_fn_symbol" json:"remove_fn_symbol,omitempty"`
	IgnoresDistinct   *bool        `thrift:"ignores_distinct,10" db:"ignores_distinct" json:"ignores_distinct,omitempty"`
}

Attributes:

  • IntermediateType
  • IsAnalyticOnlyFn
  • UpdateFnSymbol
  • InitFnSymbol
  • SerializeFnSymbol
  • MergeFnSymbol
  • FinalizeFnSymbol
  • GetValueFnSymbol
  • RemoveFnSymbol
  • IgnoresDistinct
var TFunction_AggregateFn_DEFAULT *TAggregateFunction

func NewTAggregateFunction

func NewTAggregateFunction() *TAggregateFunction

func (*TAggregateFunction) Equals added in v0.16.0

func (p *TAggregateFunction) Equals(other *TAggregateFunction) bool

func (*TAggregateFunction) GetFinalizeFnSymbol

func (p *TAggregateFunction) GetFinalizeFnSymbol() string

func (*TAggregateFunction) GetGetValueFnSymbol

func (p *TAggregateFunction) GetGetValueFnSymbol() string

func (*TAggregateFunction) GetIgnoresDistinct

func (p *TAggregateFunction) GetIgnoresDistinct() bool

func (*TAggregateFunction) GetInitFnSymbol

func (p *TAggregateFunction) GetInitFnSymbol() string

func (*TAggregateFunction) GetIntermediateType

func (p *TAggregateFunction) GetIntermediateType() *TColumnType

func (*TAggregateFunction) GetIsAnalyticOnlyFn

func (p *TAggregateFunction) GetIsAnalyticOnlyFn() bool

func (*TAggregateFunction) GetMergeFnSymbol

func (p *TAggregateFunction) GetMergeFnSymbol() string

func (*TAggregateFunction) GetRemoveFnSymbol

func (p *TAggregateFunction) GetRemoveFnSymbol() string

func (*TAggregateFunction) GetSerializeFnSymbol

func (p *TAggregateFunction) GetSerializeFnSymbol() string

func (*TAggregateFunction) GetUpdateFnSymbol

func (p *TAggregateFunction) GetUpdateFnSymbol() string

func (*TAggregateFunction) IsSetFinalizeFnSymbol

func (p *TAggregateFunction) IsSetFinalizeFnSymbol() bool

func (*TAggregateFunction) IsSetGetValueFnSymbol

func (p *TAggregateFunction) IsSetGetValueFnSymbol() bool

func (*TAggregateFunction) IsSetIgnoresDistinct

func (p *TAggregateFunction) IsSetIgnoresDistinct() bool

func (*TAggregateFunction) IsSetIntermediateType

func (p *TAggregateFunction) IsSetIntermediateType() bool

func (*TAggregateFunction) IsSetMergeFnSymbol

func (p *TAggregateFunction) IsSetMergeFnSymbol() bool

func (*TAggregateFunction) IsSetRemoveFnSymbol

func (p *TAggregateFunction) IsSetRemoveFnSymbol() bool

func (*TAggregateFunction) IsSetSerializeFnSymbol

func (p *TAggregateFunction) IsSetSerializeFnSymbol() bool

func (*TAggregateFunction) Read

func (*TAggregateFunction) ReadField1

func (p *TAggregateFunction) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField10

func (p *TAggregateFunction) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField2

func (p *TAggregateFunction) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField3

func (p *TAggregateFunction) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField4

func (p *TAggregateFunction) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField5

func (p *TAggregateFunction) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField6

func (p *TAggregateFunction) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField7

func (p *TAggregateFunction) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField8

func (p *TAggregateFunction) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) ReadField9

func (p *TAggregateFunction) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TAggregateFunction) String

func (p *TAggregateFunction) String() string

func (*TAggregateFunction) Write

func (p *TAggregateFunction) Write(ctx context.Context, oprot thrift.TProtocol) error

type TBackendId

type TBackendId *TUniqueId

func TBackendIdPtr

func TBackendIdPtr(v TBackendId) *TBackendId

type TColumnType

type TColumnType struct {
	Types []*TTypeNode `thrift:"types,1" db:"types" json:"types"`
}

Attributes:

  • Types
var TAggregateFunction_IntermediateType_DEFAULT *TColumnType
var TFunction_RetType_DEFAULT *TColumnType

func NewTColumnType

func NewTColumnType() *TColumnType

func (*TColumnType) Equals added in v0.16.0

func (p *TColumnType) Equals(other *TColumnType) bool

func (*TColumnType) GetTypes

func (p *TColumnType) GetTypes() []*TTypeNode

func (*TColumnType) Read

func (p *TColumnType) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnType) ReadField1

func (p *TColumnType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnType) String

func (p *TColumnType) String() string

func (*TColumnType) Write

func (p *TColumnType) Write(ctx context.Context, oprot thrift.TProtocol) error

type TDataSinkId

type TDataSinkId int32

func TDataSinkIdPtr

func TDataSinkIdPtr(v TDataSinkId) *TDataSinkId

type TExplainLevel

type TExplainLevel int64
const (
	TExplainLevel_MINIMAL  TExplainLevel = 0
	TExplainLevel_STANDARD TExplainLevel = 1
	TExplainLevel_EXTENDED TExplainLevel = 2
	TExplainLevel_VERBOSE  TExplainLevel = 3
)

func TExplainLevelFromString

func TExplainLevelFromString(s string) (TExplainLevel, error)

func TExplainLevelPtr

func TExplainLevelPtr(v TExplainLevel) *TExplainLevel

func (TExplainLevel) MarshalText

func (p TExplainLevel) MarshalText() ([]byte, error)

func (*TExplainLevel) Scan

func (p *TExplainLevel) Scan(value interface{}) error

func (TExplainLevel) String

func (p TExplainLevel) String() string

func (*TExplainLevel) UnmarshalText

func (p *TExplainLevel) UnmarshalText(text []byte) error

func (*TExplainLevel) Value

func (p *TExplainLevel) Value() (driver.Value, error)

type TFragmentIdx

type TFragmentIdx int32

func TFragmentIdxPtr

func TFragmentIdxPtr(v TFragmentIdx) *TFragmentIdx

type TFunction

type TFunction struct {
	Name             *TFunctionName       `thrift:"name,1,required" db:"name" json:"name"`
	BinaryType       *TFunctionBinaryType `thrift:"binary_type,2" db:"binary_type" json:"binary_type,omitempty"`
	ArgTypes         []*TColumnType       `thrift:"arg_types,3" db:"arg_types" json:"arg_types,omitempty"`
	RetType          *TColumnType         `thrift:"ret_type,4" db:"ret_type" json:"ret_type,omitempty"`
	HasVarArgs_      *bool                `thrift:"has_var_args,5" db:"has_var_args" json:"has_var_args,omitempty"`
	Comment          *string              `thrift:"comment,6" db:"comment" json:"comment,omitempty"`
	Signature        *string              `thrift:"signature,7" db:"signature" json:"signature,omitempty"`
	HdfsLocation     *string              `thrift:"hdfs_location,8" db:"hdfs_location" json:"hdfs_location,omitempty"`
	ScalarFn         *TScalarFunction     `thrift:"scalar_fn,9" db:"scalar_fn" json:"scalar_fn,omitempty"`
	AggregateFn      *TAggregateFunction  `thrift:"aggregate_fn,10" db:"aggregate_fn" json:"aggregate_fn,omitempty"`
	IsPersistent     *bool                `thrift:"is_persistent,11" db:"is_persistent" json:"is_persistent,omitempty"`
	LastModifiedTime *int64               `thrift:"last_modified_time,12" db:"last_modified_time" json:"last_modified_time,omitempty"`
}

Attributes:

  • Name
  • BinaryType
  • ArgTypes
  • RetType
  • HasVarArgs_
  • Comment
  • Signature
  • HdfsLocation
  • ScalarFn
  • AggregateFn
  • IsPersistent
  • LastModifiedTime

func NewTFunction

func NewTFunction() *TFunction

func (*TFunction) Equals added in v0.16.0

func (p *TFunction) Equals(other *TFunction) bool

func (*TFunction) GetAggregateFn

func (p *TFunction) GetAggregateFn() *TAggregateFunction

func (*TFunction) GetArgTypes

func (p *TFunction) GetArgTypes() []*TColumnType

func (*TFunction) GetBinaryType

func (p *TFunction) GetBinaryType() TFunctionBinaryType

func (*TFunction) GetComment

func (p *TFunction) GetComment() string

func (*TFunction) GetHasVarArgs_

func (p *TFunction) GetHasVarArgs_() bool

func (*TFunction) GetHdfsLocation

func (p *TFunction) GetHdfsLocation() string

func (*TFunction) GetIsPersistent

func (p *TFunction) GetIsPersistent() bool

func (*TFunction) GetLastModifiedTime

func (p *TFunction) GetLastModifiedTime() int64

func (*TFunction) GetName

func (p *TFunction) GetName() *TFunctionName

func (*TFunction) GetRetType

func (p *TFunction) GetRetType() *TColumnType

func (*TFunction) GetScalarFn

func (p *TFunction) GetScalarFn() *TScalarFunction

func (*TFunction) GetSignature

func (p *TFunction) GetSignature() string

func (*TFunction) IsSetAggregateFn

func (p *TFunction) IsSetAggregateFn() bool

func (*TFunction) IsSetArgTypes

func (p *TFunction) IsSetArgTypes() bool

func (*TFunction) IsSetBinaryType

func (p *TFunction) IsSetBinaryType() bool

func (*TFunction) IsSetComment

func (p *TFunction) IsSetComment() bool

func (*TFunction) IsSetHasVarArgs_

func (p *TFunction) IsSetHasVarArgs_() bool

func (*TFunction) IsSetHdfsLocation

func (p *TFunction) IsSetHdfsLocation() bool

func (*TFunction) IsSetIsPersistent

func (p *TFunction) IsSetIsPersistent() bool

func (*TFunction) IsSetLastModifiedTime

func (p *TFunction) IsSetLastModifiedTime() bool

func (*TFunction) IsSetName

func (p *TFunction) IsSetName() bool

func (*TFunction) IsSetRetType

func (p *TFunction) IsSetRetType() bool

func (*TFunction) IsSetScalarFn

func (p *TFunction) IsSetScalarFn() bool

func (*TFunction) IsSetSignature

func (p *TFunction) IsSetSignature() bool

func (*TFunction) Read

func (p *TFunction) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField1

func (p *TFunction) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField10

func (p *TFunction) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField11

func (p *TFunction) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField12

func (p *TFunction) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField2

func (p *TFunction) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField3

func (p *TFunction) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField4

func (p *TFunction) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField5

func (p *TFunction) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField6

func (p *TFunction) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField7

func (p *TFunction) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField8

func (p *TFunction) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) ReadField9

func (p *TFunction) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunction) String

func (p *TFunction) String() string

func (*TFunction) Write

func (p *TFunction) Write(ctx context.Context, oprot thrift.TProtocol) error

type TFunctionBinaryType

type TFunctionBinaryType int64
const (
	TFunctionBinaryType_BUILTIN TFunctionBinaryType = 0
	TFunctionBinaryType_JAVA    TFunctionBinaryType = 1
	TFunctionBinaryType_NATIVE  TFunctionBinaryType = 2
	TFunctionBinaryType_IR      TFunctionBinaryType = 3
)
var TFunction_BinaryType_DEFAULT TFunctionBinaryType

func TFunctionBinaryTypeFromString

func TFunctionBinaryTypeFromString(s string) (TFunctionBinaryType, error)

func TFunctionBinaryTypePtr

func TFunctionBinaryTypePtr(v TFunctionBinaryType) *TFunctionBinaryType

func (TFunctionBinaryType) MarshalText

func (p TFunctionBinaryType) MarshalText() ([]byte, error)

func (*TFunctionBinaryType) Scan

func (p *TFunctionBinaryType) Scan(value interface{}) error

func (TFunctionBinaryType) String

func (p TFunctionBinaryType) String() string

func (*TFunctionBinaryType) UnmarshalText

func (p *TFunctionBinaryType) UnmarshalText(text []byte) error

func (*TFunctionBinaryType) Value

func (p *TFunctionBinaryType) Value() (driver.Value, error)

type TFunctionCategory

type TFunctionCategory int64
const (
	TFunctionCategory_SCALAR    TFunctionCategory = 0
	TFunctionCategory_AGGREGATE TFunctionCategory = 1
	TFunctionCategory_ANALYTIC  TFunctionCategory = 2
)

func TFunctionCategoryFromString

func TFunctionCategoryFromString(s string) (TFunctionCategory, error)

func TFunctionCategoryPtr

func TFunctionCategoryPtr(v TFunctionCategory) *TFunctionCategory

func (TFunctionCategory) MarshalText

func (p TFunctionCategory) MarshalText() ([]byte, error)

func (*TFunctionCategory) Scan

func (p *TFunctionCategory) Scan(value interface{}) error

func (TFunctionCategory) String

func (p TFunctionCategory) String() string

func (*TFunctionCategory) UnmarshalText

func (p *TFunctionCategory) UnmarshalText(text []byte) error

func (*TFunctionCategory) Value

func (p *TFunctionCategory) Value() (driver.Value, error)

type TFunctionName

type TFunctionName struct {
	DbName       *string `thrift:"db_name,1" db:"db_name" json:"db_name,omitempty"`
	FunctionName string  `thrift:"function_name,2,required" db:"function_name" json:"function_name"`
}

Attributes:

  • DbName
  • FunctionName
var TFunction_Name_DEFAULT *TFunctionName

func NewTFunctionName

func NewTFunctionName() *TFunctionName

func (*TFunctionName) Equals added in v0.16.0

func (p *TFunctionName) Equals(other *TFunctionName) bool

func (*TFunctionName) GetDbName

func (p *TFunctionName) GetDbName() string

func (*TFunctionName) GetFunctionName

func (p *TFunctionName) GetFunctionName() string

func (*TFunctionName) IsSetDbName

func (p *TFunctionName) IsSetDbName() bool

func (*TFunctionName) Read

func (p *TFunctionName) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunctionName) ReadField1

func (p *TFunctionName) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunctionName) ReadField2

func (p *TFunctionName) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TFunctionName) String

func (p *TFunctionName) String() string

func (*TFunctionName) Write

func (p *TFunctionName) Write(ctx context.Context, oprot thrift.TProtocol) error

type TNetworkAddress

type TNetworkAddress struct {
	Hostname   string  `thrift:"hostname,1,required" db:"hostname" json:"hostname"`
	Port       int32   `thrift:"port,2,required" db:"port" json:"port"`
	UdsAddress *string `thrift:"uds_address,3" db:"uds_address" json:"uds_address,omitempty"`
}

Attributes:

  • Hostname
  • Port
  • UdsAddress

func NewTNetworkAddress

func NewTNetworkAddress() *TNetworkAddress

func (*TNetworkAddress) Equals added in v0.16.0

func (p *TNetworkAddress) Equals(other *TNetworkAddress) bool

func (*TNetworkAddress) GetHostname

func (p *TNetworkAddress) GetHostname() string

func (*TNetworkAddress) GetPort

func (p *TNetworkAddress) GetPort() int32

func (*TNetworkAddress) GetUdsAddress

func (p *TNetworkAddress) GetUdsAddress() string

func (*TNetworkAddress) IsSetUdsAddress

func (p *TNetworkAddress) IsSetUdsAddress() bool

func (*TNetworkAddress) Read

func (p *TNetworkAddress) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TNetworkAddress) ReadField1

func (p *TNetworkAddress) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TNetworkAddress) ReadField2

func (p *TNetworkAddress) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TNetworkAddress) ReadField3

func (p *TNetworkAddress) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TNetworkAddress) String

func (p *TNetworkAddress) String() string

func (*TNetworkAddress) Write

func (p *TNetworkAddress) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPlanNodeId

type TPlanNodeId int32

func TPlanNodeIdPtr

func TPlanNodeIdPtr(v TPlanNodeId) *TPlanNodeId

type TPrefetchMode

type TPrefetchMode int64
const (
	TPrefetchMode_NONE      TPrefetchMode = 0
	TPrefetchMode_HT_BUCKET TPrefetchMode = 1
)

func TPrefetchModeFromString

func TPrefetchModeFromString(s string) (TPrefetchMode, error)

func TPrefetchModePtr

func TPrefetchModePtr(v TPrefetchMode) *TPrefetchMode

func (TPrefetchMode) MarshalText

func (p TPrefetchMode) MarshalText() ([]byte, error)

func (*TPrefetchMode) Scan

func (p *TPrefetchMode) Scan(value interface{}) error

func (TPrefetchMode) String

func (p TPrefetchMode) String() string

func (*TPrefetchMode) UnmarshalText

func (p *TPrefetchMode) UnmarshalText(text []byte) error

func (*TPrefetchMode) Value

func (p *TPrefetchMode) Value() (driver.Value, error)

type TPrimitiveType

type TPrimitiveType int64
const (
	TPrimitiveType_INVALID_TYPE           TPrimitiveType = 0
	TPrimitiveType_NULL_TYPE              TPrimitiveType = 1
	TPrimitiveType_BOOLEAN                TPrimitiveType = 2
	TPrimitiveType_TINYINT                TPrimitiveType = 3
	TPrimitiveType_SMALLINT               TPrimitiveType = 4
	TPrimitiveType_INT                    TPrimitiveType = 5
	TPrimitiveType_BIGINT                 TPrimitiveType = 6
	TPrimitiveType_FLOAT                  TPrimitiveType = 7
	TPrimitiveType_DOUBLE                 TPrimitiveType = 8
	TPrimitiveType_DATE                   TPrimitiveType = 9
	TPrimitiveType_DATETIME               TPrimitiveType = 10
	TPrimitiveType_TIMESTAMP              TPrimitiveType = 11
	TPrimitiveType_STRING                 TPrimitiveType = 12
	TPrimitiveType_BINARY                 TPrimitiveType = 13
	TPrimitiveType_DECIMAL                TPrimitiveType = 14
	TPrimitiveType_CHAR                   TPrimitiveType = 15
	TPrimitiveType_VARCHAR                TPrimitiveType = 16
	TPrimitiveType_FIXED_UDA_INTERMEDIATE TPrimitiveType = 17
)

func TPrimitiveTypeFromString

func TPrimitiveTypeFromString(s string) (TPrimitiveType, error)

func TPrimitiveTypePtr

func TPrimitiveTypePtr(v TPrimitiveType) *TPrimitiveType

func (TPrimitiveType) MarshalText

func (p TPrimitiveType) MarshalText() ([]byte, error)

func (*TPrimitiveType) Scan

func (p *TPrimitiveType) Scan(value interface{}) error

func (TPrimitiveType) String

func (p TPrimitiveType) String() string

func (*TPrimitiveType) UnmarshalText

func (p *TPrimitiveType) UnmarshalText(text []byte) error

func (*TPrimitiveType) Value

func (p *TPrimitiveType) Value() (driver.Value, error)

type TRuntimeFilterMode

type TRuntimeFilterMode int64
const (
	TRuntimeFilterMode_OFF    TRuntimeFilterMode = 0
	TRuntimeFilterMode_LOCAL  TRuntimeFilterMode = 1
	TRuntimeFilterMode_GLOBAL TRuntimeFilterMode = 2
)

func TRuntimeFilterModeFromString

func TRuntimeFilterModeFromString(s string) (TRuntimeFilterMode, error)

func TRuntimeFilterModePtr

func TRuntimeFilterModePtr(v TRuntimeFilterMode) *TRuntimeFilterMode

func (TRuntimeFilterMode) MarshalText

func (p TRuntimeFilterMode) MarshalText() ([]byte, error)

func (*TRuntimeFilterMode) Scan

func (p *TRuntimeFilterMode) Scan(value interface{}) error

func (TRuntimeFilterMode) String

func (p TRuntimeFilterMode) String() string

func (*TRuntimeFilterMode) UnmarshalText

func (p *TRuntimeFilterMode) UnmarshalText(text []byte) error

func (*TRuntimeFilterMode) Value

func (p *TRuntimeFilterMode) Value() (driver.Value, error)

type TScalarFunction

type TScalarFunction struct {
	Symbol          string  `thrift:"symbol,1,required" db:"symbol" json:"symbol"`
	PrepareFnSymbol *string `thrift:"prepare_fn_symbol,2" db:"prepare_fn_symbol" json:"prepare_fn_symbol,omitempty"`
	CloseFnSymbol   *string `thrift:"close_fn_symbol,3" db:"close_fn_symbol" json:"close_fn_symbol,omitempty"`
}

Attributes:

  • Symbol
  • PrepareFnSymbol
  • CloseFnSymbol
var TFunction_ScalarFn_DEFAULT *TScalarFunction

func NewTScalarFunction

func NewTScalarFunction() *TScalarFunction

func (*TScalarFunction) Equals added in v0.16.0

func (p *TScalarFunction) Equals(other *TScalarFunction) bool

func (*TScalarFunction) GetCloseFnSymbol

func (p *TScalarFunction) GetCloseFnSymbol() string

func (*TScalarFunction) GetPrepareFnSymbol

func (p *TScalarFunction) GetPrepareFnSymbol() string

func (*TScalarFunction) GetSymbol

func (p *TScalarFunction) GetSymbol() string

func (*TScalarFunction) IsSetCloseFnSymbol

func (p *TScalarFunction) IsSetCloseFnSymbol() bool

func (*TScalarFunction) IsSetPrepareFnSymbol

func (p *TScalarFunction) IsSetPrepareFnSymbol() bool

func (*TScalarFunction) Read

func (p *TScalarFunction) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarFunction) ReadField1

func (p *TScalarFunction) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarFunction) ReadField2

func (p *TScalarFunction) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarFunction) ReadField3

func (p *TScalarFunction) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarFunction) String

func (p *TScalarFunction) String() string

func (*TScalarFunction) Write

func (p *TScalarFunction) Write(ctx context.Context, oprot thrift.TProtocol) error

type TScalarType

type TScalarType struct {
	Type      TPrimitiveType `thrift:"type,1,required" db:"type" json:"type"`
	Len       *int32         `thrift:"len,2" db:"len" json:"len,omitempty"`
	Precision *int32         `thrift:"precision,3" db:"precision" json:"precision,omitempty"`
	Scale     *int32         `thrift:"scale,4" db:"scale" json:"scale,omitempty"`
}

Attributes:

  • Type
  • Len
  • Precision
  • Scale
var TTypeNode_ScalarType_DEFAULT *TScalarType

func NewTScalarType

func NewTScalarType() *TScalarType

func (*TScalarType) Equals added in v0.16.0

func (p *TScalarType) Equals(other *TScalarType) bool

func (*TScalarType) GetLen

func (p *TScalarType) GetLen() int32

func (*TScalarType) GetPrecision

func (p *TScalarType) GetPrecision() int32

func (*TScalarType) GetScale

func (p *TScalarType) GetScale() int32

func (*TScalarType) GetType

func (p *TScalarType) GetType() TPrimitiveType

func (*TScalarType) IsSetLen

func (p *TScalarType) IsSetLen() bool

func (*TScalarType) IsSetPrecision

func (p *TScalarType) IsSetPrecision() bool

func (*TScalarType) IsSetScale

func (p *TScalarType) IsSetScale() bool

func (*TScalarType) Read

func (p *TScalarType) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarType) ReadField1

func (p *TScalarType) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarType) ReadField2

func (p *TScalarType) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarType) ReadField3

func (p *TScalarType) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarType) ReadField4

func (p *TScalarType) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TScalarType) String

func (p *TScalarType) String() string

func (*TScalarType) Write

func (p *TScalarType) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSlotId

type TSlotId int32

func TSlotIdPtr

func TSlotIdPtr(v TSlotId) *TSlotId

type TSortingOrder

type TSortingOrder int64
const (
	TSortingOrder_LEXICAL TSortingOrder = 0
	TSortingOrder_ZORDER  TSortingOrder = 1
)

func TSortingOrderFromString

func TSortingOrderFromString(s string) (TSortingOrder, error)

func TSortingOrderPtr

func TSortingOrderPtr(v TSortingOrder) *TSortingOrder

func (TSortingOrder) MarshalText

func (p TSortingOrder) MarshalText() ([]byte, error)

func (*TSortingOrder) Scan

func (p *TSortingOrder) Scan(value interface{}) error

func (TSortingOrder) String

func (p TSortingOrder) String() string

func (*TSortingOrder) UnmarshalText

func (p *TSortingOrder) UnmarshalText(text []byte) error

func (*TSortingOrder) Value

func (p *TSortingOrder) Value() (driver.Value, error)

type TStmtType

type TStmtType int64
const (
	TStmtType_QUERY    TStmtType = 0
	TStmtType_DDL      TStmtType = 1
	TStmtType_DML      TStmtType = 2
	TStmtType_EXPLAIN  TStmtType = 3
	TStmtType_LOAD     TStmtType = 4
	TStmtType_SET      TStmtType = 5
	TStmtType_ADMIN_FN TStmtType = 6
	TStmtType_TESTCASE TStmtType = 7
)

func TStmtTypeFromString

func TStmtTypeFromString(s string) (TStmtType, error)

func TStmtTypePtr

func TStmtTypePtr(v TStmtType) *TStmtType

func (TStmtType) MarshalText

func (p TStmtType) MarshalText() ([]byte, error)

func (*TStmtType) Scan

func (p *TStmtType) Scan(value interface{}) error

func (TStmtType) String

func (p TStmtType) String() string

func (*TStmtType) UnmarshalText

func (p *TStmtType) UnmarshalText(text []byte) error

func (*TStmtType) Value

func (p *TStmtType) Value() (driver.Value, error)

type TStructField

type TStructField struct {
	Name    string  `thrift:"name,1,required" db:"name" json:"name"`
	Comment *string `thrift:"comment,2" db:"comment" json:"comment,omitempty"`
	FieldID *int32  `thrift:"field_id,3" db:"field_id" json:"field_id,omitempty"`
}

Attributes:

  • Name
  • Comment
  • FieldID

func NewTStructField

func NewTStructField() *TStructField

func (*TStructField) Equals added in v0.16.0

func (p *TStructField) Equals(other *TStructField) bool

func (*TStructField) GetComment

func (p *TStructField) GetComment() string

func (*TStructField) GetFieldID

func (p *TStructField) GetFieldID() int32

func (*TStructField) GetName

func (p *TStructField) GetName() string

func (*TStructField) IsSetComment

func (p *TStructField) IsSetComment() bool

func (*TStructField) IsSetFieldID

func (p *TStructField) IsSetFieldID() bool

func (*TStructField) Read

func (p *TStructField) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TStructField) ReadField1

func (p *TStructField) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TStructField) ReadField2

func (p *TStructField) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TStructField) ReadField3

func (p *TStructField) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TStructField) String

func (p *TStructField) String() string

func (*TStructField) Write

func (p *TStructField) Write(ctx context.Context, oprot thrift.TProtocol) error

type TTableId

type TTableId int32

func TTableIdPtr

func TTableIdPtr(v TTableId) *TTableId

type TTimestamp

type TTimestamp int64

func TTimestampPtr

func TTimestampPtr(v TTimestamp) *TTimestamp

type TTupleId

type TTupleId int32

func TTupleIdPtr

func TTupleIdPtr(v TTupleId) *TTupleId

type TTypeNode

type TTypeNode struct {
	Type         TTypeNodeType   `thrift:"type,1,required" db:"type" json:"type"`
	ScalarType   *TScalarType    `thrift:"scalar_type,2" db:"scalar_type" json:"scalar_type,omitempty"`
	StructFields []*TStructField `thrift:"struct_fields,3" db:"struct_fields" json:"struct_fields,omitempty"`
}

Attributes:

  • Type
  • ScalarType
  • StructFields

func NewTTypeNode

func NewTTypeNode() *TTypeNode

func (*TTypeNode) Equals added in v0.16.0

func (p *TTypeNode) Equals(other *TTypeNode) bool

func (*TTypeNode) GetScalarType

func (p *TTypeNode) GetScalarType() *TScalarType

func (*TTypeNode) GetStructFields

func (p *TTypeNode) GetStructFields() []*TStructField

func (*TTypeNode) GetType

func (p *TTypeNode) GetType() TTypeNodeType

func (*TTypeNode) IsSetScalarType

func (p *TTypeNode) IsSetScalarType() bool

func (*TTypeNode) IsSetStructFields

func (p *TTypeNode) IsSetStructFields() bool

func (*TTypeNode) Read

func (p *TTypeNode) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTypeNode) ReadField1

func (p *TTypeNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTypeNode) ReadField2

func (p *TTypeNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTypeNode) ReadField3

func (p *TTypeNode) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TTypeNode) String

func (p *TTypeNode) String() string

func (*TTypeNode) Write

func (p *TTypeNode) Write(ctx context.Context, oprot thrift.TProtocol) error

type TTypeNodeType

type TTypeNodeType int64
const (
	TTypeNodeType_SCALAR TTypeNodeType = 0
	TTypeNodeType_ARRAY  TTypeNodeType = 1
	TTypeNodeType_MAP    TTypeNodeType = 2
	TTypeNodeType_STRUCT TTypeNodeType = 3
)

func TTypeNodeTypeFromString

func TTypeNodeTypeFromString(s string) (TTypeNodeType, error)

func TTypeNodeTypePtr

func TTypeNodeTypePtr(v TTypeNodeType) *TTypeNodeType

func (TTypeNodeType) MarshalText

func (p TTypeNodeType) MarshalText() ([]byte, error)

func (*TTypeNodeType) Scan

func (p *TTypeNodeType) Scan(value interface{}) error

func (TTypeNodeType) String

func (p TTypeNodeType) String() string

func (*TTypeNodeType) UnmarshalText

func (p *TTypeNodeType) UnmarshalText(text []byte) error

func (*TTypeNodeType) Value

func (p *TTypeNodeType) Value() (driver.Value, error)

type TUniqueId

type TUniqueId struct {
	Hi int64 `thrift:"hi,1,required" db:"hi" json:"hi"`
	Lo int64 `thrift:"lo,2,required" db:"lo" json:"lo"`
}

Attributes:

  • Hi
  • Lo

func NewTUniqueId

func NewTUniqueId() *TUniqueId

func (*TUniqueId) Equals added in v0.16.0

func (p *TUniqueId) Equals(other *TUniqueId) bool

func (*TUniqueId) GetHi

func (p *TUniqueId) GetHi() int64

func (*TUniqueId) GetLo

func (p *TUniqueId) GetLo() int64

func (*TUniqueId) Read

func (p *TUniqueId) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TUniqueId) ReadField1

func (p *TUniqueId) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TUniqueId) ReadField2

func (p *TUniqueId) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TUniqueId) String

func (p *TUniqueId) String() string

func (*TUniqueId) Write

func (p *TUniqueId) Write(ctx context.Context, oprot thrift.TProtocol) error

Jump to

Keyboard shortcuts

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