Versions in this module Expand all Collapse all v0 v0.16.0 Sep 22, 2022 Changes in this version type TAggregateFunction + func (p *TAggregateFunction) Equals(other *TAggregateFunction) bool type TColumnType + func (p *TColumnType) Equals(other *TColumnType) bool type TFunction + func (p *TFunction) Equals(other *TFunction) bool type TFunctionName + func (p *TFunctionName) Equals(other *TFunctionName) bool type TNetworkAddress + func (p *TNetworkAddress) Equals(other *TNetworkAddress) bool type TScalarFunction + func (p *TScalarFunction) Equals(other *TScalarFunction) bool type TScalarType + func (p *TScalarType) Equals(other *TScalarType) bool type TStructField + func (p *TStructField) Equals(other *TStructField) bool type TTypeNode + func (p *TTypeNode) Equals(other *TTypeNode) bool type TUniqueId + func (p *TUniqueId) Equals(other *TUniqueId) bool v0.13.1 Sep 22, 2022 Changes in this version + var GoUnusedProtection__ int + var TAggregateFunction_FinalizeFnSymbol_DEFAULT string + var TAggregateFunction_GetValueFnSymbol_DEFAULT string + var TAggregateFunction_IgnoresDistinct_DEFAULT bool + var TAggregateFunction_MergeFnSymbol_DEFAULT string + var TAggregateFunction_RemoveFnSymbol_DEFAULT string + var TAggregateFunction_SerializeFnSymbol_DEFAULT string + var TFunctionName_DbName_DEFAULT string + var TFunction_ArgTypes_DEFAULT []*TColumnType + var TFunction_Comment_DEFAULT string + var TFunction_HasVarArgs__DEFAULT bool + var TFunction_HdfsLocation_DEFAULT string + var TFunction_IsPersistent_DEFAULT bool + var TFunction_LastModifiedTime_DEFAULT int64 + var TFunction_Signature_DEFAULT string + var TNetworkAddress_UdsAddress_DEFAULT string + var TScalarFunction_CloseFnSymbol_DEFAULT string + var TScalarFunction_PrepareFnSymbol_DEFAULT string + var TScalarType_Len_DEFAULT int32 + var TScalarType_Precision_DEFAULT int32 + var TScalarType_Scale_DEFAULT int32 + var TStructField_Comment_DEFAULT string + var TStructField_FieldID_DEFAULT int32 + var TTypeNode_StructFields_DEFAULT []*TStructField + type TAggregateFunction struct + FinalizeFnSymbol *string + GetValueFnSymbol *string + IgnoresDistinct *bool + InitFnSymbol string + IntermediateType *TColumnType + IsAnalyticOnlyFn bool + MergeFnSymbol *string + RemoveFnSymbol *string + SerializeFnSymbol *string + UpdateFnSymbol string + var TFunction_AggregateFn_DEFAULT *TAggregateFunction + func NewTAggregateFunction() *TAggregateFunction + func (p *TAggregateFunction) GetFinalizeFnSymbol() string + func (p *TAggregateFunction) GetGetValueFnSymbol() string + func (p *TAggregateFunction) GetIgnoresDistinct() bool + func (p *TAggregateFunction) GetInitFnSymbol() string + func (p *TAggregateFunction) GetIntermediateType() *TColumnType + func (p *TAggregateFunction) GetIsAnalyticOnlyFn() bool + func (p *TAggregateFunction) GetMergeFnSymbol() string + func (p *TAggregateFunction) GetRemoveFnSymbol() string + func (p *TAggregateFunction) GetSerializeFnSymbol() string + func (p *TAggregateFunction) GetUpdateFnSymbol() string + func (p *TAggregateFunction) IsSetFinalizeFnSymbol() bool + func (p *TAggregateFunction) IsSetGetValueFnSymbol() bool + func (p *TAggregateFunction) IsSetIgnoresDistinct() bool + func (p *TAggregateFunction) IsSetIntermediateType() bool + func (p *TAggregateFunction) IsSetMergeFnSymbol() bool + func (p *TAggregateFunction) IsSetRemoveFnSymbol() bool + func (p *TAggregateFunction) IsSetSerializeFnSymbol() bool + func (p *TAggregateFunction) Read(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField1(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField10(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField2(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField3(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField4(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField5(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField6(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField7(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField8(iprot thrift.TProtocol) error + func (p *TAggregateFunction) ReadField9(iprot thrift.TProtocol) error + func (p *TAggregateFunction) String() string + func (p *TAggregateFunction) Write(oprot thrift.TProtocol) error + type TBackendId *TUniqueId + func TBackendIdPtr(v TBackendId) *TBackendId + type TColumnType struct + Types []*TTypeNode + var TAggregateFunction_IntermediateType_DEFAULT *TColumnType + var TFunction_RetType_DEFAULT *TColumnType + func NewTColumnType() *TColumnType + func (p *TColumnType) GetTypes() []*TTypeNode + func (p *TColumnType) Read(iprot thrift.TProtocol) error + func (p *TColumnType) ReadField1(iprot thrift.TProtocol) error + func (p *TColumnType) String() string + func (p *TColumnType) Write(oprot thrift.TProtocol) error + type TDataSinkId int32 + func TDataSinkIdPtr(v TDataSinkId) *TDataSinkId + type TExplainLevel int64 + const TExplainLevel_EXTENDED + const TExplainLevel_MINIMAL + const TExplainLevel_STANDARD + const TExplainLevel_VERBOSE + func TExplainLevelFromString(s string) (TExplainLevel, error) + func TExplainLevelPtr(v TExplainLevel) *TExplainLevel + func (p *TExplainLevel) Scan(value interface{}) error + func (p *TExplainLevel) UnmarshalText(text []byte) error + func (p *TExplainLevel) Value() (driver.Value, error) + func (p TExplainLevel) MarshalText() ([]byte, error) + func (p TExplainLevel) String() string + type TFragmentIdx int32 + func TFragmentIdxPtr(v TFragmentIdx) *TFragmentIdx + type TFunction struct + AggregateFn *TAggregateFunction + ArgTypes []*TColumnType + BinaryType *TFunctionBinaryType + Comment *string + HasVarArgs_ *bool + HdfsLocation *string + IsPersistent *bool + LastModifiedTime *int64 + Name *TFunctionName + RetType *TColumnType + ScalarFn *TScalarFunction + Signature *string + func NewTFunction() *TFunction + func (p *TFunction) GetAggregateFn() *TAggregateFunction + func (p *TFunction) GetArgTypes() []*TColumnType + func (p *TFunction) GetBinaryType() TFunctionBinaryType + func (p *TFunction) GetComment() string + func (p *TFunction) GetHasVarArgs_() bool + func (p *TFunction) GetHdfsLocation() string + func (p *TFunction) GetIsPersistent() bool + func (p *TFunction) GetLastModifiedTime() int64 + func (p *TFunction) GetName() *TFunctionName + func (p *TFunction) GetRetType() *TColumnType + func (p *TFunction) GetScalarFn() *TScalarFunction + func (p *TFunction) GetSignature() string + func (p *TFunction) IsSetAggregateFn() bool + func (p *TFunction) IsSetArgTypes() bool + func (p *TFunction) IsSetBinaryType() bool + func (p *TFunction) IsSetComment() bool + func (p *TFunction) IsSetHasVarArgs_() bool + func (p *TFunction) IsSetHdfsLocation() bool + func (p *TFunction) IsSetIsPersistent() bool + func (p *TFunction) IsSetLastModifiedTime() bool + func (p *TFunction) IsSetName() bool + func (p *TFunction) IsSetRetType() bool + func (p *TFunction) IsSetScalarFn() bool + func (p *TFunction) IsSetSignature() bool + func (p *TFunction) Read(iprot thrift.TProtocol) error + func (p *TFunction) ReadField1(iprot thrift.TProtocol) error + func (p *TFunction) ReadField10(iprot thrift.TProtocol) error + func (p *TFunction) ReadField11(iprot thrift.TProtocol) error + func (p *TFunction) ReadField12(iprot thrift.TProtocol) error + func (p *TFunction) ReadField2(iprot thrift.TProtocol) error + func (p *TFunction) ReadField3(iprot thrift.TProtocol) error + func (p *TFunction) ReadField4(iprot thrift.TProtocol) error + func (p *TFunction) ReadField5(iprot thrift.TProtocol) error + func (p *TFunction) ReadField6(iprot thrift.TProtocol) error + func (p *TFunction) ReadField7(iprot thrift.TProtocol) error + func (p *TFunction) ReadField8(iprot thrift.TProtocol) error + func (p *TFunction) ReadField9(iprot thrift.TProtocol) error + func (p *TFunction) String() string + func (p *TFunction) Write(oprot thrift.TProtocol) error + type TFunctionBinaryType int64 + const TFunctionBinaryType_BUILTIN + const TFunctionBinaryType_IR + const TFunctionBinaryType_JAVA + const TFunctionBinaryType_NATIVE + var TFunction_BinaryType_DEFAULT TFunctionBinaryType + func TFunctionBinaryTypeFromString(s string) (TFunctionBinaryType, error) + func TFunctionBinaryTypePtr(v TFunctionBinaryType) *TFunctionBinaryType + func (p *TFunctionBinaryType) Scan(value interface{}) error + func (p *TFunctionBinaryType) UnmarshalText(text []byte) error + func (p *TFunctionBinaryType) Value() (driver.Value, error) + func (p TFunctionBinaryType) MarshalText() ([]byte, error) + func (p TFunctionBinaryType) String() string + type TFunctionCategory int64 + const TFunctionCategory_AGGREGATE + const TFunctionCategory_ANALYTIC + const TFunctionCategory_SCALAR + func TFunctionCategoryFromString(s string) (TFunctionCategory, error) + func TFunctionCategoryPtr(v TFunctionCategory) *TFunctionCategory + func (p *TFunctionCategory) Scan(value interface{}) error + func (p *TFunctionCategory) UnmarshalText(text []byte) error + func (p *TFunctionCategory) Value() (driver.Value, error) + func (p TFunctionCategory) MarshalText() ([]byte, error) + func (p TFunctionCategory) String() string + type TFunctionName struct + DbName *string + FunctionName string + var TFunction_Name_DEFAULT *TFunctionName + func NewTFunctionName() *TFunctionName + func (p *TFunctionName) GetDbName() string + func (p *TFunctionName) GetFunctionName() string + func (p *TFunctionName) IsSetDbName() bool + func (p *TFunctionName) Read(iprot thrift.TProtocol) error + func (p *TFunctionName) ReadField1(iprot thrift.TProtocol) error + func (p *TFunctionName) ReadField2(iprot thrift.TProtocol) error + func (p *TFunctionName) String() string + func (p *TFunctionName) Write(oprot thrift.TProtocol) error + type TNetworkAddress struct + Hostname string + Port int32 + UdsAddress *string + func NewTNetworkAddress() *TNetworkAddress + func (p *TNetworkAddress) GetHostname() string + func (p *TNetworkAddress) GetPort() int32 + func (p *TNetworkAddress) GetUdsAddress() string + func (p *TNetworkAddress) IsSetUdsAddress() bool + func (p *TNetworkAddress) Read(iprot thrift.TProtocol) error + func (p *TNetworkAddress) ReadField1(iprot thrift.TProtocol) error + func (p *TNetworkAddress) ReadField2(iprot thrift.TProtocol) error + func (p *TNetworkAddress) ReadField3(iprot thrift.TProtocol) error + func (p *TNetworkAddress) String() string + func (p *TNetworkAddress) Write(oprot thrift.TProtocol) error + type TPlanNodeId int32 + func TPlanNodeIdPtr(v TPlanNodeId) *TPlanNodeId + type TPrefetchMode int64 + const TPrefetchMode_HT_BUCKET + const TPrefetchMode_NONE + func TPrefetchModeFromString(s string) (TPrefetchMode, error) + func TPrefetchModePtr(v TPrefetchMode) *TPrefetchMode + func (p *TPrefetchMode) Scan(value interface{}) error + func (p *TPrefetchMode) UnmarshalText(text []byte) error + func (p *TPrefetchMode) Value() (driver.Value, error) + func (p TPrefetchMode) MarshalText() ([]byte, error) + func (p TPrefetchMode) String() string + type TPrimitiveType int64 + const TPrimitiveType_BIGINT + const TPrimitiveType_BINARY + const TPrimitiveType_BOOLEAN + const TPrimitiveType_CHAR + const TPrimitiveType_DATE + const TPrimitiveType_DATETIME + const TPrimitiveType_DECIMAL + const TPrimitiveType_DOUBLE + const TPrimitiveType_FIXED_UDA_INTERMEDIATE + const TPrimitiveType_FLOAT + const TPrimitiveType_INT + const TPrimitiveType_INVALID_TYPE + const TPrimitiveType_NULL_TYPE + const TPrimitiveType_SMALLINT + const TPrimitiveType_STRING + const TPrimitiveType_TIMESTAMP + const TPrimitiveType_TINYINT + const TPrimitiveType_VARCHAR + func TPrimitiveTypeFromString(s string) (TPrimitiveType, error) + func TPrimitiveTypePtr(v TPrimitiveType) *TPrimitiveType + func (p *TPrimitiveType) Scan(value interface{}) error + func (p *TPrimitiveType) UnmarshalText(text []byte) error + func (p *TPrimitiveType) Value() (driver.Value, error) + func (p TPrimitiveType) MarshalText() ([]byte, error) + func (p TPrimitiveType) String() string + type TRuntimeFilterMode int64 + const TRuntimeFilterMode_GLOBAL + const TRuntimeFilterMode_LOCAL + const TRuntimeFilterMode_OFF + func TRuntimeFilterModeFromString(s string) (TRuntimeFilterMode, error) + func TRuntimeFilterModePtr(v TRuntimeFilterMode) *TRuntimeFilterMode + func (p *TRuntimeFilterMode) Scan(value interface{}) error + func (p *TRuntimeFilterMode) UnmarshalText(text []byte) error + func (p *TRuntimeFilterMode) Value() (driver.Value, error) + func (p TRuntimeFilterMode) MarshalText() ([]byte, error) + func (p TRuntimeFilterMode) String() string + type TScalarFunction struct + CloseFnSymbol *string + PrepareFnSymbol *string + Symbol string + var TFunction_ScalarFn_DEFAULT *TScalarFunction + func NewTScalarFunction() *TScalarFunction + func (p *TScalarFunction) GetCloseFnSymbol() string + func (p *TScalarFunction) GetPrepareFnSymbol() string + func (p *TScalarFunction) GetSymbol() string + func (p *TScalarFunction) IsSetCloseFnSymbol() bool + func (p *TScalarFunction) IsSetPrepareFnSymbol() bool + func (p *TScalarFunction) Read(iprot thrift.TProtocol) error + func (p *TScalarFunction) ReadField1(iprot thrift.TProtocol) error + func (p *TScalarFunction) ReadField2(iprot thrift.TProtocol) error + func (p *TScalarFunction) ReadField3(iprot thrift.TProtocol) error + func (p *TScalarFunction) String() string + func (p *TScalarFunction) Write(oprot thrift.TProtocol) error + type TScalarType struct + Len *int32 + Precision *int32 + Scale *int32 + Type TPrimitiveType + var TTypeNode_ScalarType_DEFAULT *TScalarType + func NewTScalarType() *TScalarType + func (p *TScalarType) GetLen() int32 + func (p *TScalarType) GetPrecision() int32 + func (p *TScalarType) GetScale() int32 + func (p *TScalarType) GetType() TPrimitiveType + func (p *TScalarType) IsSetLen() bool + func (p *TScalarType) IsSetPrecision() bool + func (p *TScalarType) IsSetScale() bool + func (p *TScalarType) Read(iprot thrift.TProtocol) error + func (p *TScalarType) ReadField1(iprot thrift.TProtocol) error + func (p *TScalarType) ReadField2(iprot thrift.TProtocol) error + func (p *TScalarType) ReadField3(iprot thrift.TProtocol) error + func (p *TScalarType) ReadField4(iprot thrift.TProtocol) error + func (p *TScalarType) String() string + func (p *TScalarType) Write(oprot thrift.TProtocol) error + type TSlotId int32 + func TSlotIdPtr(v TSlotId) *TSlotId + type TSortingOrder int64 + const TSortingOrder_LEXICAL + const TSortingOrder_ZORDER + func TSortingOrderFromString(s string) (TSortingOrder, error) + func TSortingOrderPtr(v TSortingOrder) *TSortingOrder + func (p *TSortingOrder) Scan(value interface{}) error + func (p *TSortingOrder) UnmarshalText(text []byte) error + func (p *TSortingOrder) Value() (driver.Value, error) + func (p TSortingOrder) MarshalText() ([]byte, error) + func (p TSortingOrder) String() string + type TStmtType int64 + const TStmtType_ADMIN_FN + const TStmtType_DDL + const TStmtType_DML + const TStmtType_EXPLAIN + const TStmtType_LOAD + const TStmtType_QUERY + const TStmtType_SET + const TStmtType_TESTCASE + func TStmtTypeFromString(s string) (TStmtType, error) + func TStmtTypePtr(v TStmtType) *TStmtType + func (p *TStmtType) Scan(value interface{}) error + func (p *TStmtType) UnmarshalText(text []byte) error + func (p *TStmtType) Value() (driver.Value, error) + func (p TStmtType) MarshalText() ([]byte, error) + func (p TStmtType) String() string + type TStructField struct + Comment *string + FieldID *int32 + Name string + func NewTStructField() *TStructField + func (p *TStructField) GetComment() string + func (p *TStructField) GetFieldID() int32 + func (p *TStructField) GetName() string + func (p *TStructField) IsSetComment() bool + func (p *TStructField) IsSetFieldID() bool + func (p *TStructField) Read(iprot thrift.TProtocol) error + func (p *TStructField) ReadField1(iprot thrift.TProtocol) error + func (p *TStructField) ReadField2(iprot thrift.TProtocol) error + func (p *TStructField) ReadField3(iprot thrift.TProtocol) error + func (p *TStructField) String() string + func (p *TStructField) Write(oprot thrift.TProtocol) error + type TTableId int32 + func TTableIdPtr(v TTableId) *TTableId + type TTimestamp int64 + func TTimestampPtr(v TTimestamp) *TTimestamp + type TTupleId int32 + func TTupleIdPtr(v TTupleId) *TTupleId + type TTypeNode struct + ScalarType *TScalarType + StructFields []*TStructField + Type TTypeNodeType + func NewTTypeNode() *TTypeNode + func (p *TTypeNode) GetScalarType() *TScalarType + func (p *TTypeNode) GetStructFields() []*TStructField + func (p *TTypeNode) GetType() TTypeNodeType + func (p *TTypeNode) IsSetScalarType() bool + func (p *TTypeNode) IsSetStructFields() bool + func (p *TTypeNode) Read(iprot thrift.TProtocol) error + func (p *TTypeNode) ReadField1(iprot thrift.TProtocol) error + func (p *TTypeNode) ReadField2(iprot thrift.TProtocol) error + func (p *TTypeNode) ReadField3(iprot thrift.TProtocol) error + func (p *TTypeNode) String() string + func (p *TTypeNode) Write(oprot thrift.TProtocol) error + type TTypeNodeType int64 + const TTypeNodeType_ARRAY + const TTypeNodeType_MAP + const TTypeNodeType_SCALAR + const TTypeNodeType_STRUCT + func TTypeNodeTypeFromString(s string) (TTypeNodeType, error) + func TTypeNodeTypePtr(v TTypeNodeType) *TTypeNodeType + func (p *TTypeNodeType) Scan(value interface{}) error + func (p *TTypeNodeType) UnmarshalText(text []byte) error + func (p *TTypeNodeType) Value() (driver.Value, error) + func (p TTypeNodeType) MarshalText() ([]byte, error) + func (p TTypeNodeType) String() string + type TUniqueId struct + Hi int64 + Lo int64 + func NewTUniqueId() *TUniqueId + func (p *TUniqueId) GetHi() int64 + func (p *TUniqueId) GetLo() int64 + func (p *TUniqueId) Read(iprot thrift.TProtocol) error + func (p *TUniqueId) ReadField1(iprot thrift.TProtocol) error + func (p *TUniqueId) ReadField2(iprot thrift.TProtocol) error + func (p *TUniqueId) String() string + func (p *TUniqueId) Write(oprot thrift.TProtocol) error