cli_service

package
v1.7.1 Latest Latest
Warning

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

 Go to latest Published: May 30, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const CHARACTER_MAXIMUM_LENGTH = "characterMaximumLength"
View Source 
const PRECISION = "precision"
View Source 
const SCALE = "scale"

Variables

View Source 
var COLLECTION_TYPES []TTypeId
View Source 
var COMPLEX_TYPES []TTypeId
View Source 
var GoUnusedProtection__ int
View Source 
var PRIMITIVE_TYPES []TTypeId
View Source 
var TBoolValue_Value_DEFAULT bool
View Source 
var TByteValue_Value_DEFAULT int8
View Source 
var TColumnDesc_Comment_DEFAULT string
View Source 
var TDoubleValue_Value_DEFAULT float64
View Source 
var TExecuteStatementReq_CanDecompressLZ4Result__DEFAULT bool
View Source 
var TExecuteStatementReq_CanDownloadResult__DEFAULT bool
View Source 
var TExecuteStatementReq_CanReadArrowResult__DEFAULT bool
View Source 
var TExecuteStatementReq_ConfOverlay_DEFAULT map[string]string
View Source 
var TExecuteStatementReq_MaxBytesPerBatch_DEFAULT int64
View Source 
var TExecuteStatementReq_MaxBytesPerFile_DEFAULT int64
View Source 
var TExecuteStatementReq_Parameters_DEFAULT []*TSparkParameter
View Source 
var TExecuteStatementReq_QueryTimeout_DEFAULT int64 = 0
View Source 
var TExecuteStatementReq_ResultRowLimit_DEFAULT int64
View Source 
var TExecuteStatementReq_RunAsync_DEFAULT bool = false
View Source 
var TFetchResultsReq_FetchType_DEFAULT int16 = 0
View Source 
var TFetchResultsReq_IncludeResultSetMetadata_DEFAULT bool
View Source 
var TFetchResultsReq_MaxBytes_DEFAULT int64
View Source 
var TFetchResultsReq_StartRowOffset_DEFAULT int64
View Source 
var TFetchResultsResp_HasMoreRows_DEFAULT bool
View Source 
var TGetCatalogsReq_RunAsync_DEFAULT bool = false
View Source 
var TGetColumnsReq_RunAsync_DEFAULT bool = false
View Source 
var TGetCrossReferenceReq_RunAsync_DEFAULT bool = false
View Source 
var TGetDelegationTokenResp_DelegationToken_DEFAULT string
View Source 
var TGetFunctionsReq_RunAsync_DEFAULT bool = false
View Source 
var TGetInfoValue_BinaryValue_DEFAULT int32
View Source 
var TGetInfoValue_IntegerBitmask_DEFAULT int32
View Source 
var TGetInfoValue_IntegerFlag_DEFAULT int32
View Source 
var TGetInfoValue_LenValue_DEFAULT int64
View Source 
var TGetInfoValue_SmallIntValue_DEFAULT int16
View Source 
var TGetInfoValue_StringValue_DEFAULT string
View Source 
var TGetOperationStatusReq_GetProgressUpdate_DEFAULT bool
View Source 
var TGetOperationStatusResp_DiagnosticInfo_DEFAULT string
View Source 
var TGetOperationStatusResp_DisplayMessage_DEFAULT string
View Source 
var TGetOperationStatusResp_ErrorCode_DEFAULT int32
View Source 
var TGetOperationStatusResp_ErrorDetailsJson_DEFAULT string
View Source 
var TGetOperationStatusResp_ErrorMessage_DEFAULT string
View Source 
var TGetOperationStatusResp_HasResultSet_DEFAULT bool
View Source 
var TGetOperationStatusResp_NumModifiedRows_DEFAULT int64
View Source 
var TGetOperationStatusResp_OperationCompleted_DEFAULT int64
View Source 
var TGetOperationStatusResp_OperationStarted_DEFAULT int64
View Source 
var TGetOperationStatusResp_SqlState_DEFAULT string
View Source 
var TGetOperationStatusResp_TaskStatus_DEFAULT string
View Source 
var TGetPrimaryKeysReq_RunAsync_DEFAULT bool = false
View Source 
var TGetResultSetMetadataResp_ArrowSchema_DEFAULT []byte
View Source 
var TGetResultSetMetadataResp_CompressedBytes_DEFAULT int64
View Source 
var TGetResultSetMetadataResp_IsStagingOperation_DEFAULT bool
View Source 
var TGetResultSetMetadataResp_Lz4Compressed_DEFAULT bool
View Source 
var TGetResultSetMetadataResp_UncompressedBytes_DEFAULT int64
View Source 
var TGetSchemasReq_RunAsync_DEFAULT bool = false
View Source 
var TGetTableTypesReq_RunAsync_DEFAULT bool = false
View Source 
var TGetTablesReq_RunAsync_DEFAULT bool = false
View Source 
var TGetTablesReq_TableTypes_DEFAULT []string
View Source 
var TGetTypeInfoReq_RunAsync_DEFAULT bool = false
View Source 
var TI16Value_Value_DEFAULT int16
View Source 
var TI32Value_Value_DEFAULT int32
View Source 
var TI64Value_Value_DEFAULT int64
View Source 
var TOpenSessionReq_CanUseMultipleCatalogs_DEFAULT bool
View Source 
var TOpenSessionReq_ClientProtocolI64_DEFAULT int64
View Source 
var TOpenSessionReq_Configuration_DEFAULT map[string]string
View Source 
var TOpenSessionReq_ConnectionProperties_DEFAULT map[string]string
View Source 
var TOpenSessionReq_GetInfos_DEFAULT []TGetInfoType
View Source 
var TOpenSessionReq_Password_DEFAULT string
View Source 
var TOpenSessionReq_Username_DEFAULT string
View Source 
var TOpenSessionResp_CanUseMultipleCatalogs_DEFAULT bool
View Source 
var TOpenSessionResp_Configuration_DEFAULT map[string]string
View Source 
var TOpenSessionResp_GetInfos_DEFAULT []*TGetInfoValue
View Source 
var TOperationHandle_ModifiedRowCount_DEFAULT float64
View Source 
var TRowSet_ArrowBatches_DEFAULT []*TSparkArrowBatch
View Source 
var TRowSet_BinaryColumns_DEFAULT []byte
View Source 
var TRowSet_ColumnCount_DEFAULT int32
View Source 
var TRowSet_Columns_DEFAULT []*TColumn
View Source 
var TRowSet_ResultLinks_DEFAULT []*TSparkArrowResultLink
View Source 
var TSparkArrowResultLink_HttpHeaders_DEFAULT map[string]string
View Source 
var TSparkArrowTypes_ComplexTypesAsArrow_DEFAULT bool
View Source 
var TSparkArrowTypes_DecimalAsArrow_DEFAULT bool
View Source 
var TSparkArrowTypes_IntervalTypesAsArrow_DEFAULT bool
View Source 
var TSparkArrowTypes_NullTypeAsArrow_DEFAULT bool
View Source 
var TSparkArrowTypes_TimestampAsArrow_DEFAULT bool
View Source 
var TSparkGetDirectResults_MaxBytes_DEFAULT int64
View Source 
var TSparkParameterValueArg_Arguments_DEFAULT []*TSparkParameterValueArg
View Source 
var TSparkParameterValueArg_Type_DEFAULT string
View Source 
var TSparkParameterValueArg_Value_DEFAULT string
View Source 
var TSparkParameterValue_BooleanValue_DEFAULT bool
View Source 
var TSparkParameterValue_DoubleValue_DEFAULT float64
View Source 
var TSparkParameterValue_StringValue_DEFAULT string
View Source 
var TSparkParameter_Arguments_DEFAULT []*TSparkParameterValueArg
View Source 
var TSparkParameter_Name_DEFAULT string
View Source 
var TSparkParameter_Ordinal_DEFAULT int32
View Source 
var TSparkParameter_Type_DEFAULT string
View Source 
var TStatementConf_ClientProtocolI64_DEFAULT int64
View Source 
var TStatementConf_Sessionless_DEFAULT bool
View Source 
var TStatus_DisplayMessage_DEFAULT string
View Source 
var TStatus_ErrorCode_DEFAULT int32
View Source 
var TStatus_ErrorDetailsJson_DEFAULT string
View Source 
var TStatus_ErrorMessage_DEFAULT string
View Source 
var TStatus_InfoMessages_DEFAULT []string
View Source 
var TStatus_SqlState_DEFAULT string
View Source 
var TStringValue_Value_DEFAULT string
View Source 
var TTypeQualifierValue_I32Value_DEFAULT int32
View Source 
var TTypeQualifierValue_StringValue_DEFAULT string
View Source 
var TYPE_NAMES map[TTypeId]string

Functions

This section is empty.

Types

type TArrayTypeEntry 

type TArrayTypeEntry struct {
	ObjectTypePtr TTypeEntryPtr `thrift:"objectTypePtr,1,required" db:"objectTypePtr" json:"objectTypePtr"`
}

Attributes:

  • ObjectTypePtr
var TTypeEntry_ArrayEntry_DEFAULT *TArrayTypeEntry

func NewTArrayTypeEntry 

func NewTArrayTypeEntry() *TArrayTypeEntry

func (*TArrayTypeEntry) Equals 

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

func (*TArrayTypeEntry) GetObjectTypePtr 

func (p *TArrayTypeEntry) GetObjectTypePtr() TTypeEntryPtr

func (*TArrayTypeEntry) Read 

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

func (*TArrayTypeEntry) ReadField1 

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

func (*TArrayTypeEntry) String 

func (p *TArrayTypeEntry) String() string

func (*TArrayTypeEntry) Validate added in v1.5.0 

func (p *TArrayTypeEntry) Validate() error

func (*TArrayTypeEntry) Write 

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

type TBinaryColumn 

type TBinaryColumn struct {
	Values [][]byte `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte   `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_BinaryVal_DEFAULT *TBinaryColumn

func NewTBinaryColumn 

func NewTBinaryColumn() *TBinaryColumn

func (*TBinaryColumn) Equals 

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

func (*TBinaryColumn) GetNulls 

func (p *TBinaryColumn) GetNulls() []byte

func (*TBinaryColumn) GetValues 

func (p *TBinaryColumn) GetValues() [][]byte

func (*TBinaryColumn) Read 

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

func (*TBinaryColumn) ReadField1 

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

func (*TBinaryColumn) ReadField2 

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

func (*TBinaryColumn) String 

func (p *TBinaryColumn) String() string

func (*TBinaryColumn) Validate added in v1.5.0 

func (p *TBinaryColumn) Validate() error

func (*TBinaryColumn) Write 

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

type TBoolColumn 

type TBoolColumn struct {
	Values []bool `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_BoolVal_DEFAULT *TBoolColumn

func NewTBoolColumn 

func NewTBoolColumn() *TBoolColumn

func (*TBoolColumn) Equals 

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

func (*TBoolColumn) GetNulls 

func (p *TBoolColumn) GetNulls() []byte

func (*TBoolColumn) GetValues 

func (p *TBoolColumn) GetValues() []bool

func (*TBoolColumn) Read 

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

func (*TBoolColumn) ReadField1 

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

func (*TBoolColumn) ReadField2 

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

func (*TBoolColumn) String 

func (p *TBoolColumn) String() string

func (*TBoolColumn) Validate added in v1.5.0 

func (p *TBoolColumn) Validate() error

func (*TBoolColumn) Write 

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

type TBoolValue 

type TBoolValue struct {
	Value *bool `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_BoolVal_DEFAULT *TBoolValue

func NewTBoolValue 

func NewTBoolValue() *TBoolValue

func (*TBoolValue) Equals 

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

func (*TBoolValue) GetValue 

func (p *TBoolValue) GetValue() bool

func (*TBoolValue) IsSetValue 

func (p *TBoolValue) IsSetValue() bool

func (*TBoolValue) Read 

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

func (*TBoolValue) ReadField1 

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

func (*TBoolValue) String 

func (p *TBoolValue) String() string

func (*TBoolValue) Validate added in v1.5.0 

func (p *TBoolValue) Validate() error

func (*TBoolValue) Write 

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

type TByteColumn 

type TByteColumn struct {
	Values []int8 `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_ByteVal_DEFAULT *TByteColumn

func NewTByteColumn 

func NewTByteColumn() *TByteColumn

func (*TByteColumn) Equals 

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

func (*TByteColumn) GetNulls 

func (p *TByteColumn) GetNulls() []byte

func (*TByteColumn) GetValues 

func (p *TByteColumn) GetValues() []int8

func (*TByteColumn) Read 

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

func (*TByteColumn) ReadField1 

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

func (*TByteColumn) ReadField2 

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

func (*TByteColumn) String 

func (p *TByteColumn) String() string

func (*TByteColumn) Validate added in v1.5.0 

func (p *TByteColumn) Validate() error

func (*TByteColumn) Write 

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

type TByteValue 

type TByteValue struct {
	Value *int8 `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_ByteVal_DEFAULT *TByteValue

func NewTByteValue 

func NewTByteValue() *TByteValue

func (*TByteValue) Equals 

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

func (*TByteValue) GetValue 

func (p *TByteValue) GetValue() int8

func (*TByteValue) IsSetValue 

func (p *TByteValue) IsSetValue() bool

func (*TByteValue) Read 

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

func (*TByteValue) ReadField1 

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

func (*TByteValue) String 

func (p *TByteValue) String() string

func (*TByteValue) Validate added in v1.5.0 

func (p *TByteValue) Validate() error

func (*TByteValue) Write 

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

type TCLIService 

type TCLIService interface {
	// Parameters:
	//  - Req
	OpenSession(ctx context.Context, req *TOpenSessionReq) (_r *TOpenSessionResp, _err error)
	// Parameters:
	//  - Req
	CloseSession(ctx context.Context, req *TCloseSessionReq) (_r *TCloseSessionResp, _err error)
	// Parameters:
	//  - Req
	GetInfo(ctx context.Context, req *TGetInfoReq) (_r *TGetInfoResp, _err error)
	// Parameters:
	//  - Req
	ExecuteStatement(ctx context.Context, req *TExecuteStatementReq) (_r *TExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	GetTypeInfo(ctx context.Context, req *TGetTypeInfoReq) (_r *TGetTypeInfoResp, _err error)
	// Parameters:
	//  - Req
	GetCatalogs(ctx context.Context, req *TGetCatalogsReq) (_r *TGetCatalogsResp, _err error)
	// Parameters:
	//  - Req
	GetSchemas(ctx context.Context, req *TGetSchemasReq) (_r *TGetSchemasResp, _err error)
	// Parameters:
	//  - Req
	GetTables(ctx context.Context, req *TGetTablesReq) (_r *TGetTablesResp, _err error)
	// Parameters:
	//  - Req
	GetTableTypes(ctx context.Context, req *TGetTableTypesReq) (_r *TGetTableTypesResp, _err error)
	// Parameters:
	//  - Req
	GetColumns(ctx context.Context, req *TGetColumnsReq) (_r *TGetColumnsResp, _err error)
	// Parameters:
	//  - Req
	GetFunctions(ctx context.Context, req *TGetFunctionsReq) (_r *TGetFunctionsResp, _err error)
	// Parameters:
	//  - Req
	GetPrimaryKeys(ctx context.Context, req *TGetPrimaryKeysReq) (_r *TGetPrimaryKeysResp, _err error)
	// Parameters:
	//  - Req
	GetCrossReference(ctx context.Context, req *TGetCrossReferenceReq) (_r *TGetCrossReferenceResp, _err error)
	// Parameters:
	//  - Req
	GetOperationStatus(ctx context.Context, req *TGetOperationStatusReq) (_r *TGetOperationStatusResp, _err error)
	// Parameters:
	//  - Req
	CancelOperation(ctx context.Context, req *TCancelOperationReq) (_r *TCancelOperationResp, _err error)
	// Parameters:
	//  - Req
	CloseOperation(ctx context.Context, req *TCloseOperationReq) (_r *TCloseOperationResp, _err error)
	// Parameters:
	//  - Req
	GetResultSetMetadata(ctx context.Context, req *TGetResultSetMetadataReq) (_r *TGetResultSetMetadataResp, _err error)
	// Parameters:
	//  - Req
	FetchResults(ctx context.Context, req *TFetchResultsReq) (_r *TFetchResultsResp, _err error)
	// Parameters:
	//  - Req
	GetDelegationToken(ctx context.Context, req *TGetDelegationTokenReq) (_r *TGetDelegationTokenResp, _err error)
	// Parameters:
	//  - Req
	CancelDelegationToken(ctx context.Context, req *TCancelDelegationTokenReq) (_r *TCancelDelegationTokenResp, _err error)
	// Parameters:
	//  - Req
	RenewDelegationToken(ctx context.Context, req *TRenewDelegationTokenReq) (_r *TRenewDelegationTokenResp, _err error)
}

type TCLIServiceCancelDelegationTokenArgs 

type TCLIServiceCancelDelegationTokenArgs struct {
	Req *TCancelDelegationTokenReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceCancelDelegationTokenArgs 

func NewTCLIServiceCancelDelegationTokenArgs() *TCLIServiceCancelDelegationTokenArgs

func (*TCLIServiceCancelDelegationTokenArgs) GetReq 

func (p *TCLIServiceCancelDelegationTokenArgs) GetReq() *TCancelDelegationTokenReq

func (*TCLIServiceCancelDelegationTokenArgs) IsSetReq 

func (p *TCLIServiceCancelDelegationTokenArgs) IsSetReq() bool

func (*TCLIServiceCancelDelegationTokenArgs) Read 

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

func (*TCLIServiceCancelDelegationTokenArgs) ReadField1 

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

func (*TCLIServiceCancelDelegationTokenArgs) String 

func (p *TCLIServiceCancelDelegationTokenArgs) String() string

func (*TCLIServiceCancelDelegationTokenArgs) Write 

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

type TCLIServiceCancelDelegationTokenResult 

type TCLIServiceCancelDelegationTokenResult struct {
	Success *TCancelDelegationTokenResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceCancelDelegationTokenResult 

func NewTCLIServiceCancelDelegationTokenResult() *TCLIServiceCancelDelegationTokenResult

func (*TCLIServiceCancelDelegationTokenResult) GetSuccess 

func (p *TCLIServiceCancelDelegationTokenResult) GetSuccess() *TCancelDelegationTokenResp

func (*TCLIServiceCancelDelegationTokenResult) IsSetSuccess 

func (p *TCLIServiceCancelDelegationTokenResult) IsSetSuccess() bool

func (*TCLIServiceCancelDelegationTokenResult) Read 

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

func (*TCLIServiceCancelDelegationTokenResult) ReadField0 

func (p *TCLIServiceCancelDelegationTokenResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceCancelDelegationTokenResult) String 

func (p *TCLIServiceCancelDelegationTokenResult) String() string

func (*TCLIServiceCancelDelegationTokenResult) Write 

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

type TCLIServiceCancelOperationArgs 

type TCLIServiceCancelOperationArgs struct {
	Req *TCancelOperationReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceCancelOperationArgs 

func NewTCLIServiceCancelOperationArgs() *TCLIServiceCancelOperationArgs

func (*TCLIServiceCancelOperationArgs) GetReq 

func (p *TCLIServiceCancelOperationArgs) GetReq() *TCancelOperationReq

func (*TCLIServiceCancelOperationArgs) IsSetReq 

func (p *TCLIServiceCancelOperationArgs) IsSetReq() bool

func (*TCLIServiceCancelOperationArgs) Read 

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

func (*TCLIServiceCancelOperationArgs) ReadField1 

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

func (*TCLIServiceCancelOperationArgs) String 

func (p *TCLIServiceCancelOperationArgs) String() string

func (*TCLIServiceCancelOperationArgs) Write 

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

type TCLIServiceCancelOperationResult 

type TCLIServiceCancelOperationResult struct {
	Success *TCancelOperationResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceCancelOperationResult 

func NewTCLIServiceCancelOperationResult() *TCLIServiceCancelOperationResult

func (*TCLIServiceCancelOperationResult) GetSuccess 

func (p *TCLIServiceCancelOperationResult) GetSuccess() *TCancelOperationResp

func (*TCLIServiceCancelOperationResult) IsSetSuccess 

func (p *TCLIServiceCancelOperationResult) IsSetSuccess() bool

func (*TCLIServiceCancelOperationResult) Read 

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

func (*TCLIServiceCancelOperationResult) ReadField0 

func (p *TCLIServiceCancelOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceCancelOperationResult) String 

func (p *TCLIServiceCancelOperationResult) String() string

func (*TCLIServiceCancelOperationResult) Write 

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

type TCLIServiceClient 

type TCLIServiceClient struct {
	// contains filtered or unexported fields
}

func NewTCLIServiceClient 

func NewTCLIServiceClient(c thrift.TClient) *TCLIServiceClient

func NewTCLIServiceClientFactory 

func NewTCLIServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TCLIServiceClient

func NewTCLIServiceClientProtocol 

func NewTCLIServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TCLIServiceClient

func (*TCLIServiceClient) CancelDelegationToken 

func (p *TCLIServiceClient) CancelDelegationToken(ctx context.Context, req *TCancelDelegationTokenReq) (_r *TCancelDelegationTokenResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) CancelOperation 

func (p *TCLIServiceClient) CancelOperation(ctx context.Context, req *TCancelOperationReq) (_r *TCancelOperationResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) Client_ 

func (p *TCLIServiceClient) Client_() thrift.TClient

func (*TCLIServiceClient) CloseOperation 

func (p *TCLIServiceClient) CloseOperation(ctx context.Context, req *TCloseOperationReq) (_r *TCloseOperationResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) CloseSession 

func (p *TCLIServiceClient) CloseSession(ctx context.Context, req *TCloseSessionReq) (_r *TCloseSessionResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) ExecuteStatement 

func (p *TCLIServiceClient) ExecuteStatement(ctx context.Context, req *TExecuteStatementReq) (_r *TExecuteStatementResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) FetchResults 

func (p *TCLIServiceClient) FetchResults(ctx context.Context, req *TFetchResultsReq) (_r *TFetchResultsResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetCatalogs 

func (p *TCLIServiceClient) GetCatalogs(ctx context.Context, req *TGetCatalogsReq) (_r *TGetCatalogsResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetColumns 

func (p *TCLIServiceClient) GetColumns(ctx context.Context, req *TGetColumnsReq) (_r *TGetColumnsResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetCrossReference 

func (p *TCLIServiceClient) GetCrossReference(ctx context.Context, req *TGetCrossReferenceReq) (_r *TGetCrossReferenceResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetDelegationToken 

func (p *TCLIServiceClient) GetDelegationToken(ctx context.Context, req *TGetDelegationTokenReq) (_r *TGetDelegationTokenResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetFunctions 

func (p *TCLIServiceClient) GetFunctions(ctx context.Context, req *TGetFunctionsReq) (_r *TGetFunctionsResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetInfo 

func (p *TCLIServiceClient) GetInfo(ctx context.Context, req *TGetInfoReq) (_r *TGetInfoResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetOperationStatus 

func (p *TCLIServiceClient) GetOperationStatus(ctx context.Context, req *TGetOperationStatusReq) (_r *TGetOperationStatusResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetPrimaryKeys 

func (p *TCLIServiceClient) GetPrimaryKeys(ctx context.Context, req *TGetPrimaryKeysReq) (_r *TGetPrimaryKeysResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetResultSetMetadata 

func (p *TCLIServiceClient) GetResultSetMetadata(ctx context.Context, req *TGetResultSetMetadataReq) (_r *TGetResultSetMetadataResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetSchemas 

func (p *TCLIServiceClient) GetSchemas(ctx context.Context, req *TGetSchemasReq) (_r *TGetSchemasResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetTableTypes 

func (p *TCLIServiceClient) GetTableTypes(ctx context.Context, req *TGetTableTypesReq) (_r *TGetTableTypesResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetTables 

func (p *TCLIServiceClient) GetTables(ctx context.Context, req *TGetTablesReq) (_r *TGetTablesResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) GetTypeInfo 

func (p *TCLIServiceClient) GetTypeInfo(ctx context.Context, req *TGetTypeInfoReq) (_r *TGetTypeInfoResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) LastResponseMeta_ 

func (p *TCLIServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*TCLIServiceClient) OpenSession 

func (p *TCLIServiceClient) OpenSession(ctx context.Context, req *TOpenSessionReq) (_r *TOpenSessionResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) RenewDelegationToken 

func (p *TCLIServiceClient) RenewDelegationToken(ctx context.Context, req *TRenewDelegationTokenReq) (_r *TRenewDelegationTokenResp, _err error)

Parameters:

  • Req

func (*TCLIServiceClient) SetLastResponseMeta_ 

func (p *TCLIServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type TCLIServiceCloseOperationArgs 

type TCLIServiceCloseOperationArgs struct {
	Req *TCloseOperationReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceCloseOperationArgs 

func NewTCLIServiceCloseOperationArgs() *TCLIServiceCloseOperationArgs

func (*TCLIServiceCloseOperationArgs) GetReq 

func (p *TCLIServiceCloseOperationArgs) GetReq() *TCloseOperationReq

func (*TCLIServiceCloseOperationArgs) IsSetReq 

func (p *TCLIServiceCloseOperationArgs) IsSetReq() bool

func (*TCLIServiceCloseOperationArgs) Read 

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

func (*TCLIServiceCloseOperationArgs) ReadField1 

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

func (*TCLIServiceCloseOperationArgs) String 

func (p *TCLIServiceCloseOperationArgs) String() string

func (*TCLIServiceCloseOperationArgs) Write 

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

type TCLIServiceCloseOperationResult 

type TCLIServiceCloseOperationResult struct {
	Success *TCloseOperationResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceCloseOperationResult 

func NewTCLIServiceCloseOperationResult() *TCLIServiceCloseOperationResult

func (*TCLIServiceCloseOperationResult) GetSuccess 

func (p *TCLIServiceCloseOperationResult) GetSuccess() *TCloseOperationResp

func (*TCLIServiceCloseOperationResult) IsSetSuccess 

func (p *TCLIServiceCloseOperationResult) IsSetSuccess() bool

func (*TCLIServiceCloseOperationResult) Read 

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

func (*TCLIServiceCloseOperationResult) ReadField0 

func (p *TCLIServiceCloseOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceCloseOperationResult) String 

func (p *TCLIServiceCloseOperationResult) String() string

func (*TCLIServiceCloseOperationResult) Write 

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

type TCLIServiceCloseSessionArgs 

type TCLIServiceCloseSessionArgs struct {
	Req *TCloseSessionReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceCloseSessionArgs 

func NewTCLIServiceCloseSessionArgs() *TCLIServiceCloseSessionArgs

func (*TCLIServiceCloseSessionArgs) GetReq 

func (p *TCLIServiceCloseSessionArgs) GetReq() *TCloseSessionReq

func (*TCLIServiceCloseSessionArgs) IsSetReq 

func (p *TCLIServiceCloseSessionArgs) IsSetReq() bool

func (*TCLIServiceCloseSessionArgs) Read 

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

func (*TCLIServiceCloseSessionArgs) ReadField1 

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

func (*TCLIServiceCloseSessionArgs) String 

func (p *TCLIServiceCloseSessionArgs) String() string

func (*TCLIServiceCloseSessionArgs) Write 

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

type TCLIServiceCloseSessionResult 

type TCLIServiceCloseSessionResult struct {
	Success *TCloseSessionResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceCloseSessionResult 

func NewTCLIServiceCloseSessionResult() *TCLIServiceCloseSessionResult

func (*TCLIServiceCloseSessionResult) GetSuccess 

func (p *TCLIServiceCloseSessionResult) GetSuccess() *TCloseSessionResp

func (*TCLIServiceCloseSessionResult) IsSetSuccess 

func (p *TCLIServiceCloseSessionResult) IsSetSuccess() bool

func (*TCLIServiceCloseSessionResult) Read 

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

func (*TCLIServiceCloseSessionResult) ReadField0 

func (p *TCLIServiceCloseSessionResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceCloseSessionResult) String 

func (p *TCLIServiceCloseSessionResult) String() string

func (*TCLIServiceCloseSessionResult) Write 

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

type TCLIServiceExecuteStatementArgs 

type TCLIServiceExecuteStatementArgs struct {
	Req *TExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceExecuteStatementArgs 

func NewTCLIServiceExecuteStatementArgs() *TCLIServiceExecuteStatementArgs

func (*TCLIServiceExecuteStatementArgs) GetReq 

func (p *TCLIServiceExecuteStatementArgs) GetReq() *TExecuteStatementReq

func (*TCLIServiceExecuteStatementArgs) IsSetReq 

func (p *TCLIServiceExecuteStatementArgs) IsSetReq() bool

func (*TCLIServiceExecuteStatementArgs) Read 

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

func (*TCLIServiceExecuteStatementArgs) ReadField1 

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

func (*TCLIServiceExecuteStatementArgs) String 

func (p *TCLIServiceExecuteStatementArgs) String() string

func (*TCLIServiceExecuteStatementArgs) Write 

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

type TCLIServiceExecuteStatementResult 

type TCLIServiceExecuteStatementResult struct {
	Success *TExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceExecuteStatementResult 

func NewTCLIServiceExecuteStatementResult() *TCLIServiceExecuteStatementResult

func (*TCLIServiceExecuteStatementResult) GetSuccess 

func (p *TCLIServiceExecuteStatementResult) GetSuccess() *TExecuteStatementResp

func (*TCLIServiceExecuteStatementResult) IsSetSuccess 

func (p *TCLIServiceExecuteStatementResult) IsSetSuccess() bool

func (*TCLIServiceExecuteStatementResult) Read 

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

func (*TCLIServiceExecuteStatementResult) ReadField0 

func (p *TCLIServiceExecuteStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceExecuteStatementResult) String 

func (p *TCLIServiceExecuteStatementResult) String() string

func (*TCLIServiceExecuteStatementResult) Write 

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

type TCLIServiceFetchResultsArgs 

type TCLIServiceFetchResultsArgs struct {
	Req *TFetchResultsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceFetchResultsArgs 

func NewTCLIServiceFetchResultsArgs() *TCLIServiceFetchResultsArgs

func (*TCLIServiceFetchResultsArgs) GetReq 

func (p *TCLIServiceFetchResultsArgs) GetReq() *TFetchResultsReq

func (*TCLIServiceFetchResultsArgs) IsSetReq 

func (p *TCLIServiceFetchResultsArgs) IsSetReq() bool

func (*TCLIServiceFetchResultsArgs) Read 

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

func (*TCLIServiceFetchResultsArgs) ReadField1 

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

func (*TCLIServiceFetchResultsArgs) String 

func (p *TCLIServiceFetchResultsArgs) String() string

func (*TCLIServiceFetchResultsArgs) Write 

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

type TCLIServiceFetchResultsResult 

type TCLIServiceFetchResultsResult struct {
	Success *TFetchResultsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceFetchResultsResult 

func NewTCLIServiceFetchResultsResult() *TCLIServiceFetchResultsResult

func (*TCLIServiceFetchResultsResult) GetSuccess 

func (p *TCLIServiceFetchResultsResult) GetSuccess() *TFetchResultsResp

func (*TCLIServiceFetchResultsResult) IsSetSuccess 

func (p *TCLIServiceFetchResultsResult) IsSetSuccess() bool

func (*TCLIServiceFetchResultsResult) Read 

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

func (*TCLIServiceFetchResultsResult) ReadField0 

func (p *TCLIServiceFetchResultsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceFetchResultsResult) String 

func (p *TCLIServiceFetchResultsResult) String() string

func (*TCLIServiceFetchResultsResult) Write 

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

type TCLIServiceGetCatalogsArgs 

type TCLIServiceGetCatalogsArgs struct {
	Req *TGetCatalogsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetCatalogsArgs 

func NewTCLIServiceGetCatalogsArgs() *TCLIServiceGetCatalogsArgs

func (*TCLIServiceGetCatalogsArgs) GetReq 

func (p *TCLIServiceGetCatalogsArgs) GetReq() *TGetCatalogsReq

func (*TCLIServiceGetCatalogsArgs) IsSetReq 

func (p *TCLIServiceGetCatalogsArgs) IsSetReq() bool

func (*TCLIServiceGetCatalogsArgs) Read 

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

func (*TCLIServiceGetCatalogsArgs) ReadField1 

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

func (*TCLIServiceGetCatalogsArgs) String 

func (p *TCLIServiceGetCatalogsArgs) String() string

func (*TCLIServiceGetCatalogsArgs) Write 

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

type TCLIServiceGetCatalogsResult 

type TCLIServiceGetCatalogsResult struct {
	Success *TGetCatalogsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetCatalogsResult 

func NewTCLIServiceGetCatalogsResult() *TCLIServiceGetCatalogsResult

func (*TCLIServiceGetCatalogsResult) GetSuccess 

func (p *TCLIServiceGetCatalogsResult) GetSuccess() *TGetCatalogsResp

func (*TCLIServiceGetCatalogsResult) IsSetSuccess 

func (p *TCLIServiceGetCatalogsResult) IsSetSuccess() bool

func (*TCLIServiceGetCatalogsResult) Read 

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

func (*TCLIServiceGetCatalogsResult) ReadField0 

func (p *TCLIServiceGetCatalogsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetCatalogsResult) String 

func (p *TCLIServiceGetCatalogsResult) String() string

func (*TCLIServiceGetCatalogsResult) Write 

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

type TCLIServiceGetColumnsArgs 

type TCLIServiceGetColumnsArgs struct {
	Req *TGetColumnsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetColumnsArgs 

func NewTCLIServiceGetColumnsArgs() *TCLIServiceGetColumnsArgs

func (*TCLIServiceGetColumnsArgs) GetReq 

func (p *TCLIServiceGetColumnsArgs) GetReq() *TGetColumnsReq

func (*TCLIServiceGetColumnsArgs) IsSetReq 

func (p *TCLIServiceGetColumnsArgs) IsSetReq() bool

func (*TCLIServiceGetColumnsArgs) Read 

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

func (*TCLIServiceGetColumnsArgs) ReadField1 

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

func (*TCLIServiceGetColumnsArgs) String 

func (p *TCLIServiceGetColumnsArgs) String() string

func (*TCLIServiceGetColumnsArgs) Write 

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

type TCLIServiceGetColumnsResult 

type TCLIServiceGetColumnsResult struct {
	Success *TGetColumnsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetColumnsResult 

func NewTCLIServiceGetColumnsResult() *TCLIServiceGetColumnsResult

func (*TCLIServiceGetColumnsResult) GetSuccess 

func (p *TCLIServiceGetColumnsResult) GetSuccess() *TGetColumnsResp

func (*TCLIServiceGetColumnsResult) IsSetSuccess 

func (p *TCLIServiceGetColumnsResult) IsSetSuccess() bool

func (*TCLIServiceGetColumnsResult) Read 

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

func (*TCLIServiceGetColumnsResult) ReadField0 

func (p *TCLIServiceGetColumnsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetColumnsResult) String 

func (p *TCLIServiceGetColumnsResult) String() string

func (*TCLIServiceGetColumnsResult) Write 

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

type TCLIServiceGetCrossReferenceArgs 

type TCLIServiceGetCrossReferenceArgs struct {
	Req *TGetCrossReferenceReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetCrossReferenceArgs 

func NewTCLIServiceGetCrossReferenceArgs() *TCLIServiceGetCrossReferenceArgs

func (*TCLIServiceGetCrossReferenceArgs) GetReq 

func (p *TCLIServiceGetCrossReferenceArgs) GetReq() *TGetCrossReferenceReq

func (*TCLIServiceGetCrossReferenceArgs) IsSetReq 

func (p *TCLIServiceGetCrossReferenceArgs) IsSetReq() bool

func (*TCLIServiceGetCrossReferenceArgs) Read 

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

func (*TCLIServiceGetCrossReferenceArgs) ReadField1 

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

func (*TCLIServiceGetCrossReferenceArgs) String 

func (p *TCLIServiceGetCrossReferenceArgs) String() string

func (*TCLIServiceGetCrossReferenceArgs) Write 

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

type TCLIServiceGetCrossReferenceResult 

type TCLIServiceGetCrossReferenceResult struct {
	Success *TGetCrossReferenceResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetCrossReferenceResult 

func NewTCLIServiceGetCrossReferenceResult() *TCLIServiceGetCrossReferenceResult

func (*TCLIServiceGetCrossReferenceResult) GetSuccess 

func (p *TCLIServiceGetCrossReferenceResult) GetSuccess() *TGetCrossReferenceResp

func (*TCLIServiceGetCrossReferenceResult) IsSetSuccess 

func (p *TCLIServiceGetCrossReferenceResult) IsSetSuccess() bool

func (*TCLIServiceGetCrossReferenceResult) Read 

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

func (*TCLIServiceGetCrossReferenceResult) ReadField0 

func (p *TCLIServiceGetCrossReferenceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetCrossReferenceResult) String 

func (p *TCLIServiceGetCrossReferenceResult) String() string

func (*TCLIServiceGetCrossReferenceResult) Write 

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

type TCLIServiceGetDelegationTokenArgs 

type TCLIServiceGetDelegationTokenArgs struct {
	Req *TGetDelegationTokenReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetDelegationTokenArgs 

func NewTCLIServiceGetDelegationTokenArgs() *TCLIServiceGetDelegationTokenArgs

func (*TCLIServiceGetDelegationTokenArgs) GetReq 

func (p *TCLIServiceGetDelegationTokenArgs) GetReq() *TGetDelegationTokenReq

func (*TCLIServiceGetDelegationTokenArgs) IsSetReq 

func (p *TCLIServiceGetDelegationTokenArgs) IsSetReq() bool

func (*TCLIServiceGetDelegationTokenArgs) Read 

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

func (*TCLIServiceGetDelegationTokenArgs) ReadField1 

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

func (*TCLIServiceGetDelegationTokenArgs) String 

func (p *TCLIServiceGetDelegationTokenArgs) String() string

func (*TCLIServiceGetDelegationTokenArgs) Write 

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

type TCLIServiceGetDelegationTokenResult 

type TCLIServiceGetDelegationTokenResult struct {
	Success *TGetDelegationTokenResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetDelegationTokenResult 

func NewTCLIServiceGetDelegationTokenResult() *TCLIServiceGetDelegationTokenResult

func (*TCLIServiceGetDelegationTokenResult) GetSuccess 

func (p *TCLIServiceGetDelegationTokenResult) GetSuccess() *TGetDelegationTokenResp

func (*TCLIServiceGetDelegationTokenResult) IsSetSuccess 

func (p *TCLIServiceGetDelegationTokenResult) IsSetSuccess() bool

func (*TCLIServiceGetDelegationTokenResult) Read 

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

func (*TCLIServiceGetDelegationTokenResult) ReadField0 

func (p *TCLIServiceGetDelegationTokenResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetDelegationTokenResult) String 

func (p *TCLIServiceGetDelegationTokenResult) String() string

func (*TCLIServiceGetDelegationTokenResult) Write 

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

type TCLIServiceGetFunctionsArgs 

type TCLIServiceGetFunctionsArgs struct {
	Req *TGetFunctionsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetFunctionsArgs 

func NewTCLIServiceGetFunctionsArgs() *TCLIServiceGetFunctionsArgs

func (*TCLIServiceGetFunctionsArgs) GetReq 

func (p *TCLIServiceGetFunctionsArgs) GetReq() *TGetFunctionsReq

func (*TCLIServiceGetFunctionsArgs) IsSetReq 

func (p *TCLIServiceGetFunctionsArgs) IsSetReq() bool

func (*TCLIServiceGetFunctionsArgs) Read 

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

func (*TCLIServiceGetFunctionsArgs) ReadField1 

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

func (*TCLIServiceGetFunctionsArgs) String 

func (p *TCLIServiceGetFunctionsArgs) String() string

func (*TCLIServiceGetFunctionsArgs) Write 

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

type TCLIServiceGetFunctionsResult 

type TCLIServiceGetFunctionsResult struct {
	Success *TGetFunctionsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetFunctionsResult 

func NewTCLIServiceGetFunctionsResult() *TCLIServiceGetFunctionsResult

func (*TCLIServiceGetFunctionsResult) GetSuccess 

func (p *TCLIServiceGetFunctionsResult) GetSuccess() *TGetFunctionsResp

func (*TCLIServiceGetFunctionsResult) IsSetSuccess 

func (p *TCLIServiceGetFunctionsResult) IsSetSuccess() bool

func (*TCLIServiceGetFunctionsResult) Read 

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

func (*TCLIServiceGetFunctionsResult) ReadField0 

func (p *TCLIServiceGetFunctionsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetFunctionsResult) String 

func (p *TCLIServiceGetFunctionsResult) String() string

func (*TCLIServiceGetFunctionsResult) Write 

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

type TCLIServiceGetInfoArgs 

type TCLIServiceGetInfoArgs struct {
	Req *TGetInfoReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetInfoArgs 

func NewTCLIServiceGetInfoArgs() *TCLIServiceGetInfoArgs

func (*TCLIServiceGetInfoArgs) GetReq 

func (p *TCLIServiceGetInfoArgs) GetReq() *TGetInfoReq

func (*TCLIServiceGetInfoArgs) IsSetReq 

func (p *TCLIServiceGetInfoArgs) IsSetReq() bool

func (*TCLIServiceGetInfoArgs) Read 

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

func (*TCLIServiceGetInfoArgs) ReadField1 

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

func (*TCLIServiceGetInfoArgs) String 

func (p *TCLIServiceGetInfoArgs) String() string

func (*TCLIServiceGetInfoArgs) Write 

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

type TCLIServiceGetInfoResult 

type TCLIServiceGetInfoResult struct {
	Success *TGetInfoResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetInfoResult 

func NewTCLIServiceGetInfoResult() *TCLIServiceGetInfoResult

func (*TCLIServiceGetInfoResult) GetSuccess 

func (p *TCLIServiceGetInfoResult) GetSuccess() *TGetInfoResp

func (*TCLIServiceGetInfoResult) IsSetSuccess 

func (p *TCLIServiceGetInfoResult) IsSetSuccess() bool

func (*TCLIServiceGetInfoResult) Read 

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

func (*TCLIServiceGetInfoResult) ReadField0 

func (p *TCLIServiceGetInfoResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetInfoResult) String 

func (p *TCLIServiceGetInfoResult) String() string

func (*TCLIServiceGetInfoResult) Write 

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

type TCLIServiceGetOperationStatusArgs 

type TCLIServiceGetOperationStatusArgs struct {
	Req *TGetOperationStatusReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetOperationStatusArgs 

func NewTCLIServiceGetOperationStatusArgs() *TCLIServiceGetOperationStatusArgs

func (*TCLIServiceGetOperationStatusArgs) GetReq 

func (p *TCLIServiceGetOperationStatusArgs) GetReq() *TGetOperationStatusReq

func (*TCLIServiceGetOperationStatusArgs) IsSetReq 

func (p *TCLIServiceGetOperationStatusArgs) IsSetReq() bool

func (*TCLIServiceGetOperationStatusArgs) Read 

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

func (*TCLIServiceGetOperationStatusArgs) ReadField1 

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

func (*TCLIServiceGetOperationStatusArgs) String 

func (p *TCLIServiceGetOperationStatusArgs) String() string

func (*TCLIServiceGetOperationStatusArgs) Write 

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

type TCLIServiceGetOperationStatusResult 

type TCLIServiceGetOperationStatusResult struct {
	Success *TGetOperationStatusResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetOperationStatusResult 

func NewTCLIServiceGetOperationStatusResult() *TCLIServiceGetOperationStatusResult

func (*TCLIServiceGetOperationStatusResult) GetSuccess 

func (p *TCLIServiceGetOperationStatusResult) GetSuccess() *TGetOperationStatusResp

func (*TCLIServiceGetOperationStatusResult) IsSetSuccess 

func (p *TCLIServiceGetOperationStatusResult) IsSetSuccess() bool

func (*TCLIServiceGetOperationStatusResult) Read 

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

func (*TCLIServiceGetOperationStatusResult) ReadField0 

func (p *TCLIServiceGetOperationStatusResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetOperationStatusResult) String 

func (p *TCLIServiceGetOperationStatusResult) String() string

func (*TCLIServiceGetOperationStatusResult) Write 

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

type TCLIServiceGetPrimaryKeysArgs 

type TCLIServiceGetPrimaryKeysArgs struct {
	Req *TGetPrimaryKeysReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetPrimaryKeysArgs 

func NewTCLIServiceGetPrimaryKeysArgs() *TCLIServiceGetPrimaryKeysArgs

func (*TCLIServiceGetPrimaryKeysArgs) GetReq 

func (p *TCLIServiceGetPrimaryKeysArgs) GetReq() *TGetPrimaryKeysReq

func (*TCLIServiceGetPrimaryKeysArgs) IsSetReq 

func (p *TCLIServiceGetPrimaryKeysArgs) IsSetReq() bool

func (*TCLIServiceGetPrimaryKeysArgs) Read 

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

func (*TCLIServiceGetPrimaryKeysArgs) ReadField1 

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

func (*TCLIServiceGetPrimaryKeysArgs) String 

func (p *TCLIServiceGetPrimaryKeysArgs) String() string

func (*TCLIServiceGetPrimaryKeysArgs) Write 

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

type TCLIServiceGetPrimaryKeysResult 

type TCLIServiceGetPrimaryKeysResult struct {
	Success *TGetPrimaryKeysResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetPrimaryKeysResult 

func NewTCLIServiceGetPrimaryKeysResult() *TCLIServiceGetPrimaryKeysResult

func (*TCLIServiceGetPrimaryKeysResult) GetSuccess 

func (p *TCLIServiceGetPrimaryKeysResult) GetSuccess() *TGetPrimaryKeysResp

func (*TCLIServiceGetPrimaryKeysResult) IsSetSuccess 

func (p *TCLIServiceGetPrimaryKeysResult) IsSetSuccess() bool

func (*TCLIServiceGetPrimaryKeysResult) Read 

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

func (*TCLIServiceGetPrimaryKeysResult) ReadField0 

func (p *TCLIServiceGetPrimaryKeysResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetPrimaryKeysResult) String 

func (p *TCLIServiceGetPrimaryKeysResult) String() string

func (*TCLIServiceGetPrimaryKeysResult) Write 

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

type TCLIServiceGetResultSetMetadataArgs 

type TCLIServiceGetResultSetMetadataArgs struct {
	Req *TGetResultSetMetadataReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetResultSetMetadataArgs 

func NewTCLIServiceGetResultSetMetadataArgs() *TCLIServiceGetResultSetMetadataArgs

func (*TCLIServiceGetResultSetMetadataArgs) GetReq 

func (p *TCLIServiceGetResultSetMetadataArgs) GetReq() *TGetResultSetMetadataReq

func (*TCLIServiceGetResultSetMetadataArgs) IsSetReq 

func (p *TCLIServiceGetResultSetMetadataArgs) IsSetReq() bool

func (*TCLIServiceGetResultSetMetadataArgs) Read 

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

func (*TCLIServiceGetResultSetMetadataArgs) ReadField1 

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

func (*TCLIServiceGetResultSetMetadataArgs) String 

func (p *TCLIServiceGetResultSetMetadataArgs) String() string

func (*TCLIServiceGetResultSetMetadataArgs) Write 

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

type TCLIServiceGetResultSetMetadataResult 

type TCLIServiceGetResultSetMetadataResult struct {
	Success *TGetResultSetMetadataResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetResultSetMetadataResult 

func NewTCLIServiceGetResultSetMetadataResult() *TCLIServiceGetResultSetMetadataResult

func (*TCLIServiceGetResultSetMetadataResult) GetSuccess 

func (p *TCLIServiceGetResultSetMetadataResult) GetSuccess() *TGetResultSetMetadataResp

func (*TCLIServiceGetResultSetMetadataResult) IsSetSuccess 

func (p *TCLIServiceGetResultSetMetadataResult) IsSetSuccess() bool

func (*TCLIServiceGetResultSetMetadataResult) Read 

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

func (*TCLIServiceGetResultSetMetadataResult) ReadField0 

func (p *TCLIServiceGetResultSetMetadataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetResultSetMetadataResult) String 

func (p *TCLIServiceGetResultSetMetadataResult) String() string

func (*TCLIServiceGetResultSetMetadataResult) Write 

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

type TCLIServiceGetSchemasArgs 

type TCLIServiceGetSchemasArgs struct {
	Req *TGetSchemasReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetSchemasArgs 

func NewTCLIServiceGetSchemasArgs() *TCLIServiceGetSchemasArgs

func (*TCLIServiceGetSchemasArgs) GetReq 

func (p *TCLIServiceGetSchemasArgs) GetReq() *TGetSchemasReq

func (*TCLIServiceGetSchemasArgs) IsSetReq 

func (p *TCLIServiceGetSchemasArgs) IsSetReq() bool

func (*TCLIServiceGetSchemasArgs) Read 

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

func (*TCLIServiceGetSchemasArgs) ReadField1 

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

func (*TCLIServiceGetSchemasArgs) String 

func (p *TCLIServiceGetSchemasArgs) String() string

func (*TCLIServiceGetSchemasArgs) Write 

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

type TCLIServiceGetSchemasResult 

type TCLIServiceGetSchemasResult struct {
	Success *TGetSchemasResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetSchemasResult 

func NewTCLIServiceGetSchemasResult() *TCLIServiceGetSchemasResult

func (*TCLIServiceGetSchemasResult) GetSuccess 

func (p *TCLIServiceGetSchemasResult) GetSuccess() *TGetSchemasResp

func (*TCLIServiceGetSchemasResult) IsSetSuccess 

func (p *TCLIServiceGetSchemasResult) IsSetSuccess() bool

func (*TCLIServiceGetSchemasResult) Read 

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

func (*TCLIServiceGetSchemasResult) ReadField0 

func (p *TCLIServiceGetSchemasResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetSchemasResult) String 

func (p *TCLIServiceGetSchemasResult) String() string

func (*TCLIServiceGetSchemasResult) Write 

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

type TCLIServiceGetTableTypesArgs 

type TCLIServiceGetTableTypesArgs struct {
	Req *TGetTableTypesReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetTableTypesArgs 

func NewTCLIServiceGetTableTypesArgs() *TCLIServiceGetTableTypesArgs

func (*TCLIServiceGetTableTypesArgs) GetReq 

func (p *TCLIServiceGetTableTypesArgs) GetReq() *TGetTableTypesReq

func (*TCLIServiceGetTableTypesArgs) IsSetReq 

func (p *TCLIServiceGetTableTypesArgs) IsSetReq() bool

func (*TCLIServiceGetTableTypesArgs) Read 

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

func (*TCLIServiceGetTableTypesArgs) ReadField1 

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

func (*TCLIServiceGetTableTypesArgs) String 

func (p *TCLIServiceGetTableTypesArgs) String() string

func (*TCLIServiceGetTableTypesArgs) Write 

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

type TCLIServiceGetTableTypesResult 

type TCLIServiceGetTableTypesResult struct {
	Success *TGetTableTypesResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetTableTypesResult 

func NewTCLIServiceGetTableTypesResult() *TCLIServiceGetTableTypesResult

func (*TCLIServiceGetTableTypesResult) GetSuccess 

func (p *TCLIServiceGetTableTypesResult) GetSuccess() *TGetTableTypesResp

func (*TCLIServiceGetTableTypesResult) IsSetSuccess 

func (p *TCLIServiceGetTableTypesResult) IsSetSuccess() bool

func (*TCLIServiceGetTableTypesResult) Read 

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

func (*TCLIServiceGetTableTypesResult) ReadField0 

func (p *TCLIServiceGetTableTypesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetTableTypesResult) String 

func (p *TCLIServiceGetTableTypesResult) String() string

func (*TCLIServiceGetTableTypesResult) Write 

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

type TCLIServiceGetTablesArgs 

type TCLIServiceGetTablesArgs struct {
	Req *TGetTablesReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetTablesArgs 

func NewTCLIServiceGetTablesArgs() *TCLIServiceGetTablesArgs

func (*TCLIServiceGetTablesArgs) GetReq 

func (p *TCLIServiceGetTablesArgs) GetReq() *TGetTablesReq

func (*TCLIServiceGetTablesArgs) IsSetReq 

func (p *TCLIServiceGetTablesArgs) IsSetReq() bool

func (*TCLIServiceGetTablesArgs) Read 

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

func (*TCLIServiceGetTablesArgs) ReadField1 

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

func (*TCLIServiceGetTablesArgs) String 

func (p *TCLIServiceGetTablesArgs) String() string

func (*TCLIServiceGetTablesArgs) Write 

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

type TCLIServiceGetTablesResult 

type TCLIServiceGetTablesResult struct {
	Success *TGetTablesResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetTablesResult 

func NewTCLIServiceGetTablesResult() *TCLIServiceGetTablesResult

func (*TCLIServiceGetTablesResult) GetSuccess 

func (p *TCLIServiceGetTablesResult) GetSuccess() *TGetTablesResp

func (*TCLIServiceGetTablesResult) IsSetSuccess 

func (p *TCLIServiceGetTablesResult) IsSetSuccess() bool

func (*TCLIServiceGetTablesResult) Read 

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

func (*TCLIServiceGetTablesResult) ReadField0 

func (p *TCLIServiceGetTablesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetTablesResult) String 

func (p *TCLIServiceGetTablesResult) String() string

func (*TCLIServiceGetTablesResult) Write 

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

type TCLIServiceGetTypeInfoArgs 

type TCLIServiceGetTypeInfoArgs struct {
	Req *TGetTypeInfoReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceGetTypeInfoArgs 

func NewTCLIServiceGetTypeInfoArgs() *TCLIServiceGetTypeInfoArgs

func (*TCLIServiceGetTypeInfoArgs) GetReq 

func (p *TCLIServiceGetTypeInfoArgs) GetReq() *TGetTypeInfoReq

func (*TCLIServiceGetTypeInfoArgs) IsSetReq 

func (p *TCLIServiceGetTypeInfoArgs) IsSetReq() bool

func (*TCLIServiceGetTypeInfoArgs) Read 

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

func (*TCLIServiceGetTypeInfoArgs) ReadField1 

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

func (*TCLIServiceGetTypeInfoArgs) String 

func (p *TCLIServiceGetTypeInfoArgs) String() string

func (*TCLIServiceGetTypeInfoArgs) Write 

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

type TCLIServiceGetTypeInfoResult 

type TCLIServiceGetTypeInfoResult struct {
	Success *TGetTypeInfoResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceGetTypeInfoResult 

func NewTCLIServiceGetTypeInfoResult() *TCLIServiceGetTypeInfoResult

func (*TCLIServiceGetTypeInfoResult) GetSuccess 

func (p *TCLIServiceGetTypeInfoResult) GetSuccess() *TGetTypeInfoResp

func (*TCLIServiceGetTypeInfoResult) IsSetSuccess 

func (p *TCLIServiceGetTypeInfoResult) IsSetSuccess() bool

func (*TCLIServiceGetTypeInfoResult) Read 

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

func (*TCLIServiceGetTypeInfoResult) ReadField0 

func (p *TCLIServiceGetTypeInfoResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceGetTypeInfoResult) String 

func (p *TCLIServiceGetTypeInfoResult) String() string

func (*TCLIServiceGetTypeInfoResult) Write 

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

type TCLIServiceOpenSessionArgs 

type TCLIServiceOpenSessionArgs struct {
	Req *TOpenSessionReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceOpenSessionArgs 

func NewTCLIServiceOpenSessionArgs() *TCLIServiceOpenSessionArgs

func (*TCLIServiceOpenSessionArgs) GetReq 

func (p *TCLIServiceOpenSessionArgs) GetReq() *TOpenSessionReq

func (*TCLIServiceOpenSessionArgs) IsSetReq 

func (p *TCLIServiceOpenSessionArgs) IsSetReq() bool

func (*TCLIServiceOpenSessionArgs) Read 

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

func (*TCLIServiceOpenSessionArgs) ReadField1 

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

func (*TCLIServiceOpenSessionArgs) String 

func (p *TCLIServiceOpenSessionArgs) String() string

func (*TCLIServiceOpenSessionArgs) Write 

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

type TCLIServiceOpenSessionResult 

type TCLIServiceOpenSessionResult struct {
	Success *TOpenSessionResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceOpenSessionResult 

func NewTCLIServiceOpenSessionResult() *TCLIServiceOpenSessionResult

func (*TCLIServiceOpenSessionResult) GetSuccess 

func (p *TCLIServiceOpenSessionResult) GetSuccess() *TOpenSessionResp

func (*TCLIServiceOpenSessionResult) IsSetSuccess 

func (p *TCLIServiceOpenSessionResult) IsSetSuccess() bool

func (*TCLIServiceOpenSessionResult) Read 

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

func (*TCLIServiceOpenSessionResult) ReadField0 

func (p *TCLIServiceOpenSessionResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceOpenSessionResult) String 

func (p *TCLIServiceOpenSessionResult) String() string

func (*TCLIServiceOpenSessionResult) Write 

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

type TCLIServiceProcessor 

type TCLIServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewTCLIServiceProcessor 

func NewTCLIServiceProcessor(handler TCLIService) *TCLIServiceProcessor

func (*TCLIServiceProcessor) AddToProcessorMap 

func (p *TCLIServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TCLIServiceProcessor) GetProcessorFunction 

func (p *TCLIServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TCLIServiceProcessor) Process 

func (p *TCLIServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TCLIServiceProcessor) ProcessorMap 

func (p *TCLIServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type TCLIServiceRenewDelegationTokenArgs 

type TCLIServiceRenewDelegationTokenArgs struct {
	Req *TRenewDelegationTokenReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTCLIServiceRenewDelegationTokenArgs 

func NewTCLIServiceRenewDelegationTokenArgs() *TCLIServiceRenewDelegationTokenArgs

func (*TCLIServiceRenewDelegationTokenArgs) GetReq 

func (p *TCLIServiceRenewDelegationTokenArgs) GetReq() *TRenewDelegationTokenReq

func (*TCLIServiceRenewDelegationTokenArgs) IsSetReq 

func (p *TCLIServiceRenewDelegationTokenArgs) IsSetReq() bool

func (*TCLIServiceRenewDelegationTokenArgs) Read 

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

func (*TCLIServiceRenewDelegationTokenArgs) ReadField1 

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

func (*TCLIServiceRenewDelegationTokenArgs) String 

func (p *TCLIServiceRenewDelegationTokenArgs) String() string

func (*TCLIServiceRenewDelegationTokenArgs) Write 

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

type TCLIServiceRenewDelegationTokenResult 

type TCLIServiceRenewDelegationTokenResult struct {
	Success *TRenewDelegationTokenResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCLIServiceRenewDelegationTokenResult 

func NewTCLIServiceRenewDelegationTokenResult() *TCLIServiceRenewDelegationTokenResult

func (*TCLIServiceRenewDelegationTokenResult) GetSuccess 

func (p *TCLIServiceRenewDelegationTokenResult) GetSuccess() *TRenewDelegationTokenResp

func (*TCLIServiceRenewDelegationTokenResult) IsSetSuccess 

func (p *TCLIServiceRenewDelegationTokenResult) IsSetSuccess() bool

func (*TCLIServiceRenewDelegationTokenResult) Read 

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

func (*TCLIServiceRenewDelegationTokenResult) ReadField0 

func (p *TCLIServiceRenewDelegationTokenResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TCLIServiceRenewDelegationTokenResult) String 

func (p *TCLIServiceRenewDelegationTokenResult) String() string

func (*TCLIServiceRenewDelegationTokenResult) Write 

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

type TCacheLookupResult_ 

type TCacheLookupResult_ int64
const (
	TCacheLookupResult__CACHE_INELIGIBLE TCacheLookupResult_ = 0
	TCacheLookupResult__LOCAL_CACHE_HIT  TCacheLookupResult_ = 1
	TCacheLookupResult__REMOTE_CACHE_HIT TCacheLookupResult_ = 2
	TCacheLookupResult__CACHE_MISS       TCacheLookupResult_ = 3
)
var TGetResultSetMetadataResp_CacheLookupResult__DEFAULT TCacheLookupResult_

func TCacheLookupResult_FromString 

func TCacheLookupResult_FromString(s string) (TCacheLookupResult_, error)

func TCacheLookupResult_Ptr 

func TCacheLookupResult_Ptr(v TCacheLookupResult_) *TCacheLookupResult_

func (TCacheLookupResult_) MarshalText 

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

func (*TCacheLookupResult_) Scan 

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

func (TCacheLookupResult_) String 

func (p TCacheLookupResult_) String() string

func (*TCacheLookupResult_) UnmarshalText 

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

func (*TCacheLookupResult_) Value 

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

type TCancelDelegationTokenReq 

type TCancelDelegationTokenReq struct {
	SessionHandle   *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	DelegationToken string          `thrift:"delegationToken,2,required" db:"delegationToken" json:"delegationToken"`
}

Attributes:

  • SessionHandle
  • DelegationToken
var TCLIServiceCancelDelegationTokenArgs_Req_DEFAULT *TCancelDelegationTokenReq

func NewTCancelDelegationTokenReq 

func NewTCancelDelegationTokenReq() *TCancelDelegationTokenReq

func (*TCancelDelegationTokenReq) Equals 

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

func (*TCancelDelegationTokenReq) GetDelegationToken 

func (p *TCancelDelegationTokenReq) GetDelegationToken() string

func (*TCancelDelegationTokenReq) GetSessionHandle 

func (p *TCancelDelegationTokenReq) GetSessionHandle() *TSessionHandle

func (*TCancelDelegationTokenReq) IsSetSessionHandle 

func (p *TCancelDelegationTokenReq) IsSetSessionHandle() bool

func (*TCancelDelegationTokenReq) Read 

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

func (*TCancelDelegationTokenReq) ReadField1 

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

func (*TCancelDelegationTokenReq) ReadField2 

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

func (*TCancelDelegationTokenReq) String 

func (p *TCancelDelegationTokenReq) String() string

func (*TCancelDelegationTokenReq) Validate added in v1.5.0 

func (p *TCancelDelegationTokenReq) Validate() error

func (*TCancelDelegationTokenReq) Write 

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

type TCancelDelegationTokenResp 

type TCancelDelegationTokenResp struct {
	Status *TStatus `thrift:"status,1,required" db:"status" json:"status"`
}

Attributes:

  • Status
var TCLIServiceCancelDelegationTokenResult_Success_DEFAULT *TCancelDelegationTokenResp

func NewTCancelDelegationTokenResp 

func NewTCancelDelegationTokenResp() *TCancelDelegationTokenResp

func (*TCancelDelegationTokenResp) Equals 

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

func (*TCancelDelegationTokenResp) GetStatus 

func (p *TCancelDelegationTokenResp) GetStatus() *TStatus

func (*TCancelDelegationTokenResp) IsSetStatus 

func (p *TCancelDelegationTokenResp) IsSetStatus() bool

func (*TCancelDelegationTokenResp) Read 

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

func (*TCancelDelegationTokenResp) ReadField1 

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

func (*TCancelDelegationTokenResp) String 

func (p *TCancelDelegationTokenResp) String() string

func (*TCancelDelegationTokenResp) Validate added in v1.5.0 

func (p *TCancelDelegationTokenResp) Validate() error

func (*TCancelDelegationTokenResp) Write 

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

type TCancelOperationReq 

type TCancelOperationReq struct {
	OperationHandle *TOperationHandle `thrift:"operationHandle,1,required" db:"operationHandle" json:"operationHandle"`
}

Attributes:

  • OperationHandle
var TCLIServiceCancelOperationArgs_Req_DEFAULT *TCancelOperationReq

func NewTCancelOperationReq 

func NewTCancelOperationReq() *TCancelOperationReq

func (*TCancelOperationReq) Equals 

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

func (*TCancelOperationReq) GetOperationHandle 

func (p *TCancelOperationReq) GetOperationHandle() *TOperationHandle

func (*TCancelOperationReq) IsSetOperationHandle 

func (p *TCancelOperationReq) IsSetOperationHandle() bool

func (*TCancelOperationReq) Read 

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

func (*TCancelOperationReq) ReadField1 

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

func (*TCancelOperationReq) String 

func (p *TCancelOperationReq) String() string

func (*TCancelOperationReq) Validate added in v1.5.0 

func (p *TCancelOperationReq) Validate() error

func (*TCancelOperationReq) Write 

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

type TCancelOperationResp 

type TCancelOperationResp struct {
	Status *TStatus `thrift:"status,1,required" db:"status" json:"status"`
}

Attributes:

  • Status
var TCLIServiceCancelOperationResult_Success_DEFAULT *TCancelOperationResp

func NewTCancelOperationResp 

func NewTCancelOperationResp() *TCancelOperationResp

func (*TCancelOperationResp) Equals 

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

func (*TCancelOperationResp) GetStatus 

func (p *TCancelOperationResp) GetStatus() *TStatus

func (*TCancelOperationResp) IsSetStatus 

func (p *TCancelOperationResp) IsSetStatus() bool

func (*TCancelOperationResp) Read 

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

func (*TCancelOperationResp) ReadField1 

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

func (*TCancelOperationResp) String 

func (p *TCancelOperationResp) String() string

func (*TCancelOperationResp) Validate added in v1.5.0 

func (p *TCancelOperationResp) Validate() error

func (*TCancelOperationResp) Write 

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

type TCloseOperationReq 

type TCloseOperationReq struct {
	OperationHandle *TOperationHandle `thrift:"operationHandle,1,required" db:"operationHandle" json:"operationHandle"`
}

Attributes:

  • OperationHandle
var TCLIServiceCloseOperationArgs_Req_DEFAULT *TCloseOperationReq

func NewTCloseOperationReq 

func NewTCloseOperationReq() *TCloseOperationReq

func (*TCloseOperationReq) Equals 

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

func (*TCloseOperationReq) GetOperationHandle 

func (p *TCloseOperationReq) GetOperationHandle() *TOperationHandle

func (*TCloseOperationReq) IsSetOperationHandle 

func (p *TCloseOperationReq) IsSetOperationHandle() bool

func (*TCloseOperationReq) Read 

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

func (*TCloseOperationReq) ReadField1 

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

func (*TCloseOperationReq) String 

func (p *TCloseOperationReq) String() string

func (*TCloseOperationReq) Validate added in v1.5.0 

func (p *TCloseOperationReq) Validate() error

func (*TCloseOperationReq) Write 

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

type TCloseOperationResp 

type TCloseOperationResp struct {
	Status *TStatus `thrift:"status,1,required" db:"status" json:"status"`
}

Attributes:

  • Status
var TCLIServiceCloseOperationResult_Success_DEFAULT *TCloseOperationResp
var TSparkDirectResults_CloseOperation_DEFAULT *TCloseOperationResp

func NewTCloseOperationResp 

func NewTCloseOperationResp() *TCloseOperationResp

func (*TCloseOperationResp) Equals 

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

func (*TCloseOperationResp) GetStatus 

func (p *TCloseOperationResp) GetStatus() *TStatus

func (*TCloseOperationResp) IsSetStatus 

func (p *TCloseOperationResp) IsSetStatus() bool

func (*TCloseOperationResp) Read 

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

func (*TCloseOperationResp) ReadField1 

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

func (*TCloseOperationResp) String 

func (p *TCloseOperationResp) String() string

func (*TCloseOperationResp) Validate added in v1.5.0 

func (p *TCloseOperationResp) Validate() error

func (*TCloseOperationResp) Write 

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

type TCloseSessionReq 

type TCloseSessionReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
}

Attributes:

  • SessionHandle
var TCLIServiceCloseSessionArgs_Req_DEFAULT *TCloseSessionReq

func NewTCloseSessionReq 

func NewTCloseSessionReq() *TCloseSessionReq

func (*TCloseSessionReq) Equals 

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

func (*TCloseSessionReq) GetSessionHandle 

func (p *TCloseSessionReq) GetSessionHandle() *TSessionHandle

func (*TCloseSessionReq) IsSetSessionHandle 

func (p *TCloseSessionReq) IsSetSessionHandle() bool

func (*TCloseSessionReq) Read 

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

func (*TCloseSessionReq) ReadField1 

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

func (*TCloseSessionReq) String 

func (p *TCloseSessionReq) String() string

func (*TCloseSessionReq) Validate added in v1.5.0 

func (p *TCloseSessionReq) Validate() error

func (*TCloseSessionReq) Write 

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

type TCloseSessionResp 

type TCloseSessionResp struct {
	Status *TStatus `thrift:"status,1,required" db:"status" json:"status"`
}

Attributes:

  • Status
var TCLIServiceCloseSessionResult_Success_DEFAULT *TCloseSessionResp

func NewTCloseSessionResp 

func NewTCloseSessionResp() *TCloseSessionResp

func (*TCloseSessionResp) Equals 

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

func (*TCloseSessionResp) GetStatus 

func (p *TCloseSessionResp) GetStatus() *TStatus

func (*TCloseSessionResp) IsSetStatus 

func (p *TCloseSessionResp) IsSetStatus() bool

func (*TCloseSessionResp) Read 

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

func (*TCloseSessionResp) ReadField1 

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

func (*TCloseSessionResp) String 

func (p *TCloseSessionResp) String() string

func (*TCloseSessionResp) Validate added in v1.5.0 

func (p *TCloseSessionResp) Validate() error

func (*TCloseSessionResp) Write 

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

type TColumn 

type TColumn struct {
	BoolVal   *TBoolColumn   `thrift:"boolVal,1" db:"boolVal" json:"boolVal,omitempty"`
	ByteVal   *TByteColumn   `thrift:"byteVal,2" db:"byteVal" json:"byteVal,omitempty"`
	I16Val    *TI16Column    `thrift:"i16Val,3" db:"i16Val" json:"i16Val,omitempty"`
	I32Val    *TI32Column    `thrift:"i32Val,4" db:"i32Val" json:"i32Val,omitempty"`
	I64Val    *TI64Column    `thrift:"i64Val,5" db:"i64Val" json:"i64Val,omitempty"`
	DoubleVal *TDoubleColumn `thrift:"doubleVal,6" db:"doubleVal" json:"doubleVal,omitempty"`
	StringVal *TStringColumn `thrift:"stringVal,7" db:"stringVal" json:"stringVal,omitempty"`
	BinaryVal *TBinaryColumn `thrift:"binaryVal,8" db:"binaryVal" json:"binaryVal,omitempty"`
}

Attributes:

  • BoolVal
  • ByteVal
  • I16Val
  • I32Val
  • I64Val
  • DoubleVal
  • StringVal
  • BinaryVal

func NewTColumn 

func NewTColumn() *TColumn

func (*TColumn) CountSetFieldsTColumn 

func (p *TColumn) CountSetFieldsTColumn() int

func (*TColumn) Equals 

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

func (*TColumn) GetBinaryVal 

func (p *TColumn) GetBinaryVal() *TBinaryColumn

func (*TColumn) GetBoolVal 

func (p *TColumn) GetBoolVal() *TBoolColumn

func (*TColumn) GetByteVal 

func (p *TColumn) GetByteVal() *TByteColumn

func (*TColumn) GetDoubleVal 

func (p *TColumn) GetDoubleVal() *TDoubleColumn

func (*TColumn) GetI16Val 

func (p *TColumn) GetI16Val() *TI16Column

func (*TColumn) GetI32Val 

func (p *TColumn) GetI32Val() *TI32Column

func (*TColumn) GetI64Val 

func (p *TColumn) GetI64Val() *TI64Column

func (*TColumn) GetStringVal 

func (p *TColumn) GetStringVal() *TStringColumn

func (*TColumn) IsSetBinaryVal 

func (p *TColumn) IsSetBinaryVal() bool

func (*TColumn) IsSetBoolVal 

func (p *TColumn) IsSetBoolVal() bool

func (*TColumn) IsSetByteVal 

func (p *TColumn) IsSetByteVal() bool

func (*TColumn) IsSetDoubleVal 

func (p *TColumn) IsSetDoubleVal() bool

func (*TColumn) IsSetI16Val 

func (p *TColumn) IsSetI16Val() bool

func (*TColumn) IsSetI32Val 

func (p *TColumn) IsSetI32Val() bool

func (*TColumn) IsSetI64Val 

func (p *TColumn) IsSetI64Val() bool

func (*TColumn) IsSetStringVal 

func (p *TColumn) IsSetStringVal() bool

func (*TColumn) Read 

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

func (*TColumn) ReadField1 

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

func (*TColumn) ReadField2 

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

func (*TColumn) ReadField3 

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

func (*TColumn) ReadField4 

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

func (*TColumn) ReadField5 

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

func (*TColumn) ReadField6 

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

func (*TColumn) ReadField7 

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

func (*TColumn) ReadField8 

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

func (*TColumn) String 

func (p *TColumn) String() string

func (*TColumn) Validate added in v1.5.0 

func (p *TColumn) Validate() error

func (*TColumn) Write 

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

type TColumnDesc 

type TColumnDesc struct {
	ColumnName string     `thrift:"columnName,1,required" db:"columnName" json:"columnName"`
	TypeDesc   *TTypeDesc `thrift:"typeDesc,2,required" db:"typeDesc" json:"typeDesc"`
	Position   int32      `thrift:"position,3,required" db:"position" json:"position"`
	Comment    *string    `thrift:"comment,4" db:"comment" json:"comment,omitempty"`
}

Attributes:

  • ColumnName
  • TypeDesc
  • Position
  • Comment

func NewTColumnDesc 

func NewTColumnDesc() *TColumnDesc

func (*TColumnDesc) Equals 

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

func (*TColumnDesc) GetColumnName 

func (p *TColumnDesc) GetColumnName() string

func (*TColumnDesc) GetComment 

func (p *TColumnDesc) GetComment() string

func (*TColumnDesc) GetPosition 

func (p *TColumnDesc) GetPosition() int32

func (*TColumnDesc) GetTypeDesc 

func (p *TColumnDesc) GetTypeDesc() *TTypeDesc

func (*TColumnDesc) IsSetComment 

func (p *TColumnDesc) IsSetComment() bool

func (*TColumnDesc) IsSetTypeDesc 

func (p *TColumnDesc) IsSetTypeDesc() bool

func (*TColumnDesc) Read 

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

func (*TColumnDesc) ReadField1 

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

func (*TColumnDesc) ReadField2 

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

func (*TColumnDesc) ReadField3 

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

func (*TColumnDesc) ReadField4 

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

func (*TColumnDesc) String 

func (p *TColumnDesc) String() string

func (*TColumnDesc) Validate added in v1.5.0 

func (p *TColumnDesc) Validate() error

func (*TColumnDesc) Write 

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

type TColumnValue 

type TColumnValue struct {
	BoolVal   *TBoolValue   `thrift:"boolVal,1" db:"boolVal" json:"boolVal,omitempty"`
	ByteVal   *TByteValue   `thrift:"byteVal,2" db:"byteVal" json:"byteVal,omitempty"`
	I16Val    *TI16Value    `thrift:"i16Val,3" db:"i16Val" json:"i16Val,omitempty"`
	I32Val    *TI32Value    `thrift:"i32Val,4" db:"i32Val" json:"i32Val,omitempty"`
	I64Val    *TI64Value    `thrift:"i64Val,5" db:"i64Val" json:"i64Val,omitempty"`
	DoubleVal *TDoubleValue `thrift:"doubleVal,6" db:"doubleVal" json:"doubleVal,omitempty"`
	StringVal *TStringValue `thrift:"stringVal,7" db:"stringVal" json:"stringVal,omitempty"`
}

Attributes:

  • BoolVal
  • ByteVal
  • I16Val
  • I32Val
  • I64Val
  • DoubleVal
  • StringVal

func NewTColumnValue 

func NewTColumnValue() *TColumnValue

func (*TColumnValue) CountSetFieldsTColumnValue 

func (p *TColumnValue) CountSetFieldsTColumnValue() int

func (*TColumnValue) Equals 

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

func (*TColumnValue) GetBoolVal 

func (p *TColumnValue) GetBoolVal() *TBoolValue

func (*TColumnValue) GetByteVal 

func (p *TColumnValue) GetByteVal() *TByteValue

func (*TColumnValue) GetDoubleVal 

func (p *TColumnValue) GetDoubleVal() *TDoubleValue

func (*TColumnValue) GetI16Val 

func (p *TColumnValue) GetI16Val() *TI16Value

func (*TColumnValue) GetI32Val 

func (p *TColumnValue) GetI32Val() *TI32Value

func (*TColumnValue) GetI64Val 

func (p *TColumnValue) GetI64Val() *TI64Value

func (*TColumnValue) GetStringVal 

func (p *TColumnValue) GetStringVal() *TStringValue

func (*TColumnValue) IsSetBoolVal 

func (p *TColumnValue) IsSetBoolVal() bool

func (*TColumnValue) IsSetByteVal 

func (p *TColumnValue) IsSetByteVal() bool

func (*TColumnValue) IsSetDoubleVal 

func (p *TColumnValue) IsSetDoubleVal() bool

func (*TColumnValue) IsSetI16Val 

func (p *TColumnValue) IsSetI16Val() bool

func (*TColumnValue) IsSetI32Val 

func (p *TColumnValue) IsSetI32Val() bool

func (*TColumnValue) IsSetI64Val 

func (p *TColumnValue) IsSetI64Val() bool

func (*TColumnValue) IsSetStringVal 

func (p *TColumnValue) IsSetStringVal() bool

func (*TColumnValue) Read 

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

func (*TColumnValue) ReadField1 

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

func (*TColumnValue) ReadField2 

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

func (*TColumnValue) ReadField3 

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

func (*TColumnValue) ReadField4 

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

func (*TColumnValue) ReadField5 

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

func (*TColumnValue) ReadField6 

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

func (*TColumnValue) ReadField7 

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

func (*TColumnValue) String 

func (p *TColumnValue) String() string

func (*TColumnValue) Validate added in v1.5.0 

func (p *TColumnValue) Validate() error

func (*TColumnValue) Write 

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

type TDBSqlArrowFormat added in v1.5.0 

type TDBSqlArrowFormat struct {
	ArrowLayout      *TDBSqlArrowLayout      `thrift:"arrowLayout,1" db:"arrowLayout" json:"arrowLayout,omitempty"`
	CompressionCodec *TDBSqlCompressionCodec `thrift:"compressionCodec,2" db:"compressionCodec" json:"compressionCodec,omitempty"`
}

Attributes:

  • ArrowLayout
  • CompressionCodec
var TDBSqlResultFormat_ArrowFormat_DEFAULT *TDBSqlArrowFormat

func NewTDBSqlArrowFormat added in v1.5.0 

func NewTDBSqlArrowFormat() *TDBSqlArrowFormat

func (*TDBSqlArrowFormat) Equals added in v1.5.0 

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

func (*TDBSqlArrowFormat) GetArrowLayout added in v1.5.0 

func (p *TDBSqlArrowFormat) GetArrowLayout() TDBSqlArrowLayout

func (*TDBSqlArrowFormat) GetCompressionCodec added in v1.5.0 

func (p *TDBSqlArrowFormat) GetCompressionCodec() TDBSqlCompressionCodec

func (*TDBSqlArrowFormat) IsSetArrowLayout added in v1.5.0 

func (p *TDBSqlArrowFormat) IsSetArrowLayout() bool

func (*TDBSqlArrowFormat) IsSetCompressionCodec added in v1.5.0 

func (p *TDBSqlArrowFormat) IsSetCompressionCodec() bool

func (*TDBSqlArrowFormat) Read added in v1.5.0 

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

func (*TDBSqlArrowFormat) ReadField1 added in v1.5.0 

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

func (*TDBSqlArrowFormat) ReadField2 added in v1.5.0 

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

func (*TDBSqlArrowFormat) String added in v1.5.0 

func (p *TDBSqlArrowFormat) String() string

func (*TDBSqlArrowFormat) Validate added in v1.5.0 

func (p *TDBSqlArrowFormat) Validate() error

func (*TDBSqlArrowFormat) Write added in v1.5.0 

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

type TDBSqlArrowLayout added in v1.5.0 

type TDBSqlArrowLayout int64
const (
	TDBSqlArrowLayout_ARROW_BATCH     TDBSqlArrowLayout = 0
	TDBSqlArrowLayout_ARROW_STREAMING TDBSqlArrowLayout = 1
)
var TDBSqlArrowFormat_ArrowLayout_DEFAULT TDBSqlArrowLayout

func TDBSqlArrowLayoutFromString added in v1.5.0 

func TDBSqlArrowLayoutFromString(s string) (TDBSqlArrowLayout, error)

func TDBSqlArrowLayoutPtr added in v1.5.0 

func TDBSqlArrowLayoutPtr(v TDBSqlArrowLayout) *TDBSqlArrowLayout

func (TDBSqlArrowLayout) MarshalText added in v1.5.0 

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

func (*TDBSqlArrowLayout) Scan added in v1.5.0 

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

func (TDBSqlArrowLayout) String added in v1.5.0 

func (p TDBSqlArrowLayout) String() string

func (*TDBSqlArrowLayout) UnmarshalText added in v1.5.0 

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

func (*TDBSqlArrowLayout) Value added in v1.5.0 

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

type TDBSqlCompressionCodec added in v1.5.0 

type TDBSqlCompressionCodec int64
const (
	TDBSqlCompressionCodec_NONE      TDBSqlCompressionCodec = 0
	TDBSqlCompressionCodec_LZ4_FRAME TDBSqlCompressionCodec = 1
	TDBSqlCompressionCodec_LZ4_BLOCK TDBSqlCompressionCodec = 2
)
var TDBSqlArrowFormat_CompressionCodec_DEFAULT TDBSqlCompressionCodec
var TDBSqlCsvFormat_CompressionCodec_DEFAULT TDBSqlCompressionCodec
var TDBSqlJsonArrayFormat_CompressionCodec_DEFAULT TDBSqlCompressionCodec

func TDBSqlCompressionCodecFromString added in v1.5.0 

func TDBSqlCompressionCodecFromString(s string) (TDBSqlCompressionCodec, error)

func TDBSqlCompressionCodecPtr added in v1.5.0 

func TDBSqlCompressionCodecPtr(v TDBSqlCompressionCodec) *TDBSqlCompressionCodec

func (TDBSqlCompressionCodec) MarshalText added in v1.5.0 

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

func (*TDBSqlCompressionCodec) Scan added in v1.5.0 

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

func (TDBSqlCompressionCodec) String added in v1.5.0 

func (p TDBSqlCompressionCodec) String() string

func (*TDBSqlCompressionCodec) UnmarshalText added in v1.5.0 

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

func (*TDBSqlCompressionCodec) Value added in v1.5.0 

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

type TDBSqlCsvFormat added in v1.5.0 

type TDBSqlCsvFormat struct {
	CompressionCodec *TDBSqlCompressionCodec `thrift:"compressionCodec,1" db:"compressionCodec" json:"compressionCodec,omitempty"`
}

Attributes:

  • CompressionCodec
var TDBSqlResultFormat_CsvFormat_DEFAULT *TDBSqlCsvFormat

func NewTDBSqlCsvFormat added in v1.5.0 

func NewTDBSqlCsvFormat() *TDBSqlCsvFormat

func (*TDBSqlCsvFormat) Equals added in v1.5.0 

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

func (*TDBSqlCsvFormat) GetCompressionCodec added in v1.5.0 

func (p *TDBSqlCsvFormat) GetCompressionCodec() TDBSqlCompressionCodec

func (*TDBSqlCsvFormat) IsSetCompressionCodec added in v1.5.0 

func (p *TDBSqlCsvFormat) IsSetCompressionCodec() bool

func (*TDBSqlCsvFormat) Read added in v1.5.0 

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

func (*TDBSqlCsvFormat) ReadField1 added in v1.5.0 

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

func (*TDBSqlCsvFormat) String added in v1.5.0 

func (p *TDBSqlCsvFormat) String() string

func (*TDBSqlCsvFormat) Validate added in v1.5.0 

func (p *TDBSqlCsvFormat) Validate() error

func (*TDBSqlCsvFormat) Write added in v1.5.0 

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

type TDBSqlJsonArrayFormat added in v1.5.0 

type TDBSqlJsonArrayFormat struct {
	CompressionCodec *TDBSqlCompressionCodec `thrift:"compressionCodec,1" db:"compressionCodec" json:"compressionCodec,omitempty"`
}

Attributes:

  • CompressionCodec
var TDBSqlResultFormat_JsonArrayFormat_DEFAULT *TDBSqlJsonArrayFormat

func NewTDBSqlJsonArrayFormat added in v1.5.0 

func NewTDBSqlJsonArrayFormat() *TDBSqlJsonArrayFormat

func (*TDBSqlJsonArrayFormat) Equals added in v1.5.0 

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

func (*TDBSqlJsonArrayFormat) GetCompressionCodec added in v1.5.0 

func (p *TDBSqlJsonArrayFormat) GetCompressionCodec() TDBSqlCompressionCodec

func (*TDBSqlJsonArrayFormat) IsSetCompressionCodec added in v1.5.0 

func (p *TDBSqlJsonArrayFormat) IsSetCompressionCodec() bool

func (*TDBSqlJsonArrayFormat) Read added in v1.5.0 

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

func (*TDBSqlJsonArrayFormat) ReadField1 added in v1.5.0 

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

func (*TDBSqlJsonArrayFormat) String added in v1.5.0 

func (p *TDBSqlJsonArrayFormat) String() string

func (*TDBSqlJsonArrayFormat) Validate added in v1.5.0 

func (p *TDBSqlJsonArrayFormat) Validate() error

func (*TDBSqlJsonArrayFormat) Write added in v1.5.0 

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

type TDBSqlResultFormat added in v1.5.0 

type TDBSqlResultFormat struct {
	ArrowFormat     *TDBSqlArrowFormat     `thrift:"arrowFormat,1" db:"arrowFormat" json:"arrowFormat,omitempty"`
	CsvFormat       *TDBSqlCsvFormat       `thrift:"csvFormat,2" db:"csvFormat" json:"csvFormat,omitempty"`
	JsonArrayFormat *TDBSqlJsonArrayFormat `thrift:"jsonArrayFormat,3" db:"jsonArrayFormat" json:"jsonArrayFormat,omitempty"`
}

Attributes:

  • ArrowFormat
  • CsvFormat
  • JsonArrayFormat

func NewTDBSqlResultFormat added in v1.5.0 

func NewTDBSqlResultFormat() *TDBSqlResultFormat

func (*TDBSqlResultFormat) CountSetFieldsTDBSqlResultFormat added in v1.5.0 

func (p *TDBSqlResultFormat) CountSetFieldsTDBSqlResultFormat() int

func (*TDBSqlResultFormat) Equals added in v1.5.0 

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

func (*TDBSqlResultFormat) GetArrowFormat added in v1.5.0 

func (p *TDBSqlResultFormat) GetArrowFormat() *TDBSqlArrowFormat

func (*TDBSqlResultFormat) GetCsvFormat added in v1.5.0 

func (p *TDBSqlResultFormat) GetCsvFormat() *TDBSqlCsvFormat

func (*TDBSqlResultFormat) GetJsonArrayFormat added in v1.5.0 

func (p *TDBSqlResultFormat) GetJsonArrayFormat() *TDBSqlJsonArrayFormat

func (*TDBSqlResultFormat) IsSetArrowFormat added in v1.5.0 

func (p *TDBSqlResultFormat) IsSetArrowFormat() bool

func (*TDBSqlResultFormat) IsSetCsvFormat added in v1.5.0 

func (p *TDBSqlResultFormat) IsSetCsvFormat() bool

func (*TDBSqlResultFormat) IsSetJsonArrayFormat added in v1.5.0 

func (p *TDBSqlResultFormat) IsSetJsonArrayFormat() bool

func (*TDBSqlResultFormat) Read added in v1.5.0 

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

func (*TDBSqlResultFormat) ReadField1 added in v1.5.0 

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

func (*TDBSqlResultFormat) ReadField2 added in v1.5.0 

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

func (*TDBSqlResultFormat) ReadField3 added in v1.5.0 

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

func (*TDBSqlResultFormat) String added in v1.5.0 

func (p *TDBSqlResultFormat) String() string

func (*TDBSqlResultFormat) Validate added in v1.5.0 

func (p *TDBSqlResultFormat) Validate() error

func (*TDBSqlResultFormat) Write added in v1.5.0 

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

type TDoubleColumn 

type TDoubleColumn struct {
	Values []float64 `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte    `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_DoubleVal_DEFAULT *TDoubleColumn

func NewTDoubleColumn 

func NewTDoubleColumn() *TDoubleColumn

func (*TDoubleColumn) Equals 

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

func (*TDoubleColumn) GetNulls 

func (p *TDoubleColumn) GetNulls() []byte

func (*TDoubleColumn) GetValues 

func (p *TDoubleColumn) GetValues() []float64

func (*TDoubleColumn) Read 

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

func (*TDoubleColumn) ReadField1 

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

func (*TDoubleColumn) ReadField2 

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

func (*TDoubleColumn) String 

func (p *TDoubleColumn) String() string

func (*TDoubleColumn) Validate added in v1.5.0 

func (p *TDoubleColumn) Validate() error

func (*TDoubleColumn) Write 

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

type TDoubleValue 

type TDoubleValue struct {
	Value *float64 `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_DoubleVal_DEFAULT *TDoubleValue

func NewTDoubleValue 

func NewTDoubleValue() *TDoubleValue

func (*TDoubleValue) Equals 

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

func (*TDoubleValue) GetValue 

func (p *TDoubleValue) GetValue() float64

func (*TDoubleValue) IsSetValue 

func (p *TDoubleValue) IsSetValue() bool

func (*TDoubleValue) Read 

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

func (*TDoubleValue) ReadField1 

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

func (*TDoubleValue) String 

func (p *TDoubleValue) String() string

func (*TDoubleValue) Validate added in v1.5.0 

func (p *TDoubleValue) Validate() error

func (*TDoubleValue) Write 

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

type TExecuteStatementReq 

type TExecuteStatementReq struct {
	SessionHandle *TSessionHandle   `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	Statement     string            `thrift:"statement,2,required" db:"statement" json:"statement"`
	ConfOverlay   map[string]string `thrift:"confOverlay,3" db:"confOverlay" json:"confOverlay,omitempty"`
	RunAsync      bool              `thrift:"runAsync,4" db:"runAsync" json:"runAsync"`
	QueryTimeout  int64             `thrift:"queryTimeout,5" db:"queryTimeout" json:"queryTimeout"`
	// unused fields # 6 to 1280
	GetDirectResults        *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	CanReadArrowResult_     *bool                   `thrift:"canReadArrowResult,1282" db:"canReadArrowResult" json:"canReadArrowResult,omitempty"`
	CanDownloadResult_      *bool                   `thrift:"canDownloadResult,1283" db:"canDownloadResult" json:"canDownloadResult,omitempty"`
	CanDecompressLZ4Result_ *bool                   `thrift:"canDecompressLZ4Result,1284" db:"canDecompressLZ4Result" json:"canDecompressLZ4Result,omitempty"`
	MaxBytesPerFile         *int64                  `thrift:"maxBytesPerFile,1285" db:"maxBytesPerFile" json:"maxBytesPerFile,omitempty"`
	UseArrowNativeTypes     *TSparkArrowTypes       `thrift:"useArrowNativeTypes,1286" db:"useArrowNativeTypes" json:"useArrowNativeTypes,omitempty"`
	ResultRowLimit          *int64                  `thrift:"resultRowLimit,1287" db:"resultRowLimit" json:"resultRowLimit,omitempty"`
	Parameters              []*TSparkParameter      `thrift:"parameters,1288" db:"parameters" json:"parameters,omitempty"`
	MaxBytesPerBatch        *int64                  `thrift:"maxBytesPerBatch,1289" db:"maxBytesPerBatch" json:"maxBytesPerBatch,omitempty"`
	// unused fields # 1290 to 1295
	StatementConf *TStatementConf `thrift:"statementConf,1296" db:"statementConf" json:"statementConf,omitempty"`
}

Attributes:

  • SessionHandle
  • Statement
  • ConfOverlay
  • RunAsync
  • GetDirectResults
  • QueryTimeout
  • CanReadArrowResult_
  • CanDownloadResult_
  • CanDecompressLZ4Result_
  • MaxBytesPerFile
  • UseArrowNativeTypes
  • ResultRowLimit
  • Parameters
  • MaxBytesPerBatch
  • StatementConf
var TCLIServiceExecuteStatementArgs_Req_DEFAULT *TExecuteStatementReq

func NewTExecuteStatementReq 

func NewTExecuteStatementReq() *TExecuteStatementReq

func (*TExecuteStatementReq) Equals 

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

func (*TExecuteStatementReq) GetCanDecompressLZ4Result_ 

func (p *TExecuteStatementReq) GetCanDecompressLZ4Result_() bool

func (*TExecuteStatementReq) GetCanDownloadResult_ 

func (p *TExecuteStatementReq) GetCanDownloadResult_() bool

func (*TExecuteStatementReq) GetCanReadArrowResult_ 

func (p *TExecuteStatementReq) GetCanReadArrowResult_() bool

func (*TExecuteStatementReq) GetConfOverlay 

func (p *TExecuteStatementReq) GetConfOverlay() map[string]string

func (*TExecuteStatementReq) GetGetDirectResults 

func (p *TExecuteStatementReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TExecuteStatementReq) GetMaxBytesPerBatch added in v1.5.0 

func (p *TExecuteStatementReq) GetMaxBytesPerBatch() int64

func (*TExecuteStatementReq) GetMaxBytesPerFile 

func (p *TExecuteStatementReq) GetMaxBytesPerFile() int64

func (*TExecuteStatementReq) GetParameters added in v1.5.0 

func (p *TExecuteStatementReq) GetParameters() []*TSparkParameter

func (*TExecuteStatementReq) GetQueryTimeout 

func (p *TExecuteStatementReq) GetQueryTimeout() int64

func (*TExecuteStatementReq) GetResultRowLimit added in v1.5.0 

func (p *TExecuteStatementReq) GetResultRowLimit() int64

func (*TExecuteStatementReq) GetRunAsync 

func (p *TExecuteStatementReq) GetRunAsync() bool

func (*TExecuteStatementReq) GetSessionHandle 

func (p *TExecuteStatementReq) GetSessionHandle() *TSessionHandle

func (*TExecuteStatementReq) GetStatement 

func (p *TExecuteStatementReq) GetStatement() string

func (*TExecuteStatementReq) GetStatementConf added in v1.5.0 

func (p *TExecuteStatementReq) GetStatementConf() *TStatementConf

func (*TExecuteStatementReq) GetUseArrowNativeTypes 

func (p *TExecuteStatementReq) GetUseArrowNativeTypes() *TSparkArrowTypes

func (*TExecuteStatementReq) IsSetCanDecompressLZ4Result_ 

func (p *TExecuteStatementReq) IsSetCanDecompressLZ4Result_() bool

func (*TExecuteStatementReq) IsSetCanDownloadResult_ 

func (p *TExecuteStatementReq) IsSetCanDownloadResult_() bool

func (*TExecuteStatementReq) IsSetCanReadArrowResult_ 

func (p *TExecuteStatementReq) IsSetCanReadArrowResult_() bool

func (*TExecuteStatementReq) IsSetConfOverlay 

func (p *TExecuteStatementReq) IsSetConfOverlay() bool

func (*TExecuteStatementReq) IsSetGetDirectResults 

func (p *TExecuteStatementReq) IsSetGetDirectResults() bool

func (*TExecuteStatementReq) IsSetMaxBytesPerBatch added in v1.5.0 

func (p *TExecuteStatementReq) IsSetMaxBytesPerBatch() bool

func (*TExecuteStatementReq) IsSetMaxBytesPerFile 

func (p *TExecuteStatementReq) IsSetMaxBytesPerFile() bool

func (*TExecuteStatementReq) IsSetParameters added in v1.5.0 

func (p *TExecuteStatementReq) IsSetParameters() bool

func (*TExecuteStatementReq) IsSetQueryTimeout 

func (p *TExecuteStatementReq) IsSetQueryTimeout() bool

func (*TExecuteStatementReq) IsSetResultRowLimit added in v1.5.0 

func (p *TExecuteStatementReq) IsSetResultRowLimit() bool

func (*TExecuteStatementReq) IsSetRunAsync 

func (p *TExecuteStatementReq) IsSetRunAsync() bool

func (*TExecuteStatementReq) IsSetSessionHandle 

func (p *TExecuteStatementReq) IsSetSessionHandle() bool

func (*TExecuteStatementReq) IsSetStatementConf added in v1.5.0 

func (p *TExecuteStatementReq) IsSetStatementConf() bool

func (*TExecuteStatementReq) IsSetUseArrowNativeTypes 

func (p *TExecuteStatementReq) IsSetUseArrowNativeTypes() bool

func (*TExecuteStatementReq) Read 

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

func (*TExecuteStatementReq) ReadField1 

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

func (*TExecuteStatementReq) ReadField1281 

func (p *TExecuteStatementReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1282 

func (p *TExecuteStatementReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1283 

func (p *TExecuteStatementReq) ReadField1283(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1284 

func (p *TExecuteStatementReq) ReadField1284(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1285 

func (p *TExecuteStatementReq) ReadField1285(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1286 

func (p *TExecuteStatementReq) ReadField1286(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1287 added in v1.5.0 

func (p *TExecuteStatementReq) ReadField1287(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1288 added in v1.5.0 

func (p *TExecuteStatementReq) ReadField1288(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1289 added in v1.5.0 

func (p *TExecuteStatementReq) ReadField1289(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField1296 added in v1.5.0 

func (p *TExecuteStatementReq) ReadField1296(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementReq) ReadField2 

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

func (*TExecuteStatementReq) ReadField3 

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

func (*TExecuteStatementReq) ReadField4 

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

func (*TExecuteStatementReq) ReadField5 

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

func (*TExecuteStatementReq) String 

func (p *TExecuteStatementReq) String() string

func (*TExecuteStatementReq) Validate added in v1.5.0 

func (p *TExecuteStatementReq) Validate() error

func (*TExecuteStatementReq) Write 

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

type TExecuteStatementResp 

type TExecuteStatementResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceExecuteStatementResult_Success_DEFAULT *TExecuteStatementResp

func NewTExecuteStatementResp 

func NewTExecuteStatementResp() *TExecuteStatementResp

func (*TExecuteStatementResp) Equals 

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

func (*TExecuteStatementResp) GetDirectResults 

func (p *TExecuteStatementResp) GetDirectResults() *TSparkDirectResults

func (*TExecuteStatementResp) GetOperationHandle 

func (p *TExecuteStatementResp) GetOperationHandle() *TOperationHandle

func (*TExecuteStatementResp) GetStatus 

func (p *TExecuteStatementResp) GetStatus() *TStatus

func (*TExecuteStatementResp) IsSetDirectResults 

func (p *TExecuteStatementResp) IsSetDirectResults() bool

func (*TExecuteStatementResp) IsSetOperationHandle 

func (p *TExecuteStatementResp) IsSetOperationHandle() bool

func (*TExecuteStatementResp) IsSetStatus 

func (p *TExecuteStatementResp) IsSetStatus() bool

func (*TExecuteStatementResp) Read 

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

func (*TExecuteStatementResp) ReadField1 

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

func (*TExecuteStatementResp) ReadField1281 

func (p *TExecuteStatementResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecuteStatementResp) ReadField2 

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

func (*TExecuteStatementResp) String 

func (p *TExecuteStatementResp) String() string

func (*TExecuteStatementResp) Validate added in v1.5.0 

func (p *TExecuteStatementResp) Validate() error

func (*TExecuteStatementResp) Write 

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

type TFetchOrientation 

type TFetchOrientation int64
const (
	TFetchOrientation_FETCH_NEXT     TFetchOrientation = 0
	TFetchOrientation_FETCH_PRIOR    TFetchOrientation = 1
	TFetchOrientation_FETCH_RELATIVE TFetchOrientation = 2
	TFetchOrientation_FETCH_ABSOLUTE TFetchOrientation = 3
	TFetchOrientation_FETCH_FIRST    TFetchOrientation = 4
	TFetchOrientation_FETCH_LAST     TFetchOrientation = 5
)

func TFetchOrientationFromString 

func TFetchOrientationFromString(s string) (TFetchOrientation, error)

func TFetchOrientationPtr 

func TFetchOrientationPtr(v TFetchOrientation) *TFetchOrientation

func (TFetchOrientation) MarshalText 

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

func (*TFetchOrientation) Scan 

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

func (TFetchOrientation) String 

func (p TFetchOrientation) String() string

func (*TFetchOrientation) UnmarshalText 

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

func (*TFetchOrientation) Value 

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

type TFetchResultsReq 

type TFetchResultsReq struct {
	OperationHandle *TOperationHandle `thrift:"operationHandle,1,required" db:"operationHandle" json:"operationHandle"`
	Orientation     TFetchOrientation `thrift:"orientation,2,required" db:"orientation" json:"orientation"`
	MaxRows         int64             `thrift:"maxRows,3,required" db:"maxRows" json:"maxRows"`
	FetchType       int16             `thrift:"fetchType,4" db:"fetchType" json:"fetchType"`
	// unused fields # 5 to 1280
	MaxBytes                 *int64 `thrift:"maxBytes,1281" db:"maxBytes" json:"maxBytes,omitempty"`
	StartRowOffset           *int64 `thrift:"startRowOffset,1282" db:"startRowOffset" json:"startRowOffset,omitempty"`
	IncludeResultSetMetadata *bool  `thrift:"includeResultSetMetadata,1283" db:"includeResultSetMetadata" json:"includeResultSetMetadata,omitempty"`
}

Attributes:

  • OperationHandle
  • Orientation
  • MaxRows
  • FetchType
  • MaxBytes
  • StartRowOffset
  • IncludeResultSetMetadata
var TCLIServiceFetchResultsArgs_Req_DEFAULT *TFetchResultsReq

func NewTFetchResultsReq 

func NewTFetchResultsReq() *TFetchResultsReq

func (*TFetchResultsReq) Equals 

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

func (*TFetchResultsReq) GetFetchType 

func (p *TFetchResultsReq) GetFetchType() int16

func (*TFetchResultsReq) GetIncludeResultSetMetadata 

func (p *TFetchResultsReq) GetIncludeResultSetMetadata() bool

func (*TFetchResultsReq) GetMaxBytes 

func (p *TFetchResultsReq) GetMaxBytes() int64

func (*TFetchResultsReq) GetMaxRows 

func (p *TFetchResultsReq) GetMaxRows() int64

func (*TFetchResultsReq) GetOperationHandle 

func (p *TFetchResultsReq) GetOperationHandle() *TOperationHandle

func (*TFetchResultsReq) GetOrientation 

func (p *TFetchResultsReq) GetOrientation() TFetchOrientation

func (*TFetchResultsReq) GetStartRowOffset 

func (p *TFetchResultsReq) GetStartRowOffset() int64

func (*TFetchResultsReq) IsSetFetchType 

func (p *TFetchResultsReq) IsSetFetchType() bool

func (*TFetchResultsReq) IsSetIncludeResultSetMetadata 

func (p *TFetchResultsReq) IsSetIncludeResultSetMetadata() bool

func (*TFetchResultsReq) IsSetMaxBytes 

func (p *TFetchResultsReq) IsSetMaxBytes() bool

func (*TFetchResultsReq) IsSetOperationHandle 

func (p *TFetchResultsReq) IsSetOperationHandle() bool

func (*TFetchResultsReq) IsSetStartRowOffset 

func (p *TFetchResultsReq) IsSetStartRowOffset() bool

func (*TFetchResultsReq) Read 

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

func (*TFetchResultsReq) ReadField1 

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

func (*TFetchResultsReq) ReadField1281 

func (p *TFetchResultsReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TFetchResultsReq) ReadField1282 

func (p *TFetchResultsReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TFetchResultsReq) ReadField1283 

func (p *TFetchResultsReq) ReadField1283(ctx context.Context, iprot thrift.TProtocol) error

func (*TFetchResultsReq) ReadField2 

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

func (*TFetchResultsReq) ReadField3 

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

func (*TFetchResultsReq) ReadField4 

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

func (*TFetchResultsReq) String 

func (p *TFetchResultsReq) String() string

func (*TFetchResultsReq) Validate added in v1.5.0 

func (p *TFetchResultsReq) Validate() error

func (*TFetchResultsReq) Write 

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

type TFetchResultsResp 

type TFetchResultsResp struct {
	Status      *TStatus `thrift:"status,1,required" db:"status" json:"status"`
	HasMoreRows *bool    `thrift:"hasMoreRows,2" db:"hasMoreRows" json:"hasMoreRows,omitempty"`
	Results     *TRowSet `thrift:"results,3" db:"results" json:"results,omitempty"`
	// unused fields # 4 to 1280
	ResultSetMetadata *TGetResultSetMetadataResp `thrift:"resultSetMetadata,1281" db:"resultSetMetadata" json:"resultSetMetadata,omitempty"`
}

Attributes:

  • Status
  • HasMoreRows
  • Results
  • ResultSetMetadata
var TCLIServiceFetchResultsResult_Success_DEFAULT *TFetchResultsResp
var TSparkDirectResults_ResultSet_DEFAULT *TFetchResultsResp

func NewTFetchResultsResp 

func NewTFetchResultsResp() *TFetchResultsResp

func (*TFetchResultsResp) Equals 

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

func (*TFetchResultsResp) GetHasMoreRows 

func (p *TFetchResultsResp) GetHasMoreRows() bool

func (*TFetchResultsResp) GetResultSetMetadata 

func (p *TFetchResultsResp) GetResultSetMetadata() *TGetResultSetMetadataResp

func (*TFetchResultsResp) GetResults 

func (p *TFetchResultsResp) GetResults() *TRowSet

func (*TFetchResultsResp) GetStatus 

func (p *TFetchResultsResp) GetStatus() *TStatus

func (*TFetchResultsResp) IsSetHasMoreRows 

func (p *TFetchResultsResp) IsSetHasMoreRows() bool

func (*TFetchResultsResp) IsSetResultSetMetadata 

func (p *TFetchResultsResp) IsSetResultSetMetadata() bool

func (*TFetchResultsResp) IsSetResults 

func (p *TFetchResultsResp) IsSetResults() bool

func (*TFetchResultsResp) IsSetStatus 

func (p *TFetchResultsResp) IsSetStatus() bool

func (*TFetchResultsResp) Read 

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

func (*TFetchResultsResp) ReadField1 

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

func (*TFetchResultsResp) ReadField1281 

func (p *TFetchResultsResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TFetchResultsResp) ReadField2 

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

func (*TFetchResultsResp) ReadField3 

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

func (*TFetchResultsResp) String 

func (p *TFetchResultsResp) String() string

func (*TFetchResultsResp) Validate added in v1.5.0 

func (p *TFetchResultsResp) Validate() error

func (*TFetchResultsResp) Write 

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

type TGetCatalogsReq 

type TGetCatalogsReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	// unused fields # 2 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • GetDirectResults
  • RunAsync
var TCLIServiceGetCatalogsArgs_Req_DEFAULT *TGetCatalogsReq

func NewTGetCatalogsReq 

func NewTGetCatalogsReq() *TGetCatalogsReq

func (*TGetCatalogsReq) Equals 

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

func (*TGetCatalogsReq) GetGetDirectResults 

func (p *TGetCatalogsReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetCatalogsReq) GetRunAsync 

func (p *TGetCatalogsReq) GetRunAsync() bool

func (*TGetCatalogsReq) GetSessionHandle 

func (p *TGetCatalogsReq) GetSessionHandle() *TSessionHandle

func (*TGetCatalogsReq) IsSetGetDirectResults 

func (p *TGetCatalogsReq) IsSetGetDirectResults() bool

func (*TGetCatalogsReq) IsSetRunAsync 

func (p *TGetCatalogsReq) IsSetRunAsync() bool

func (*TGetCatalogsReq) IsSetSessionHandle 

func (p *TGetCatalogsReq) IsSetSessionHandle() bool

func (*TGetCatalogsReq) Read 

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

func (*TGetCatalogsReq) ReadField1 

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

func (*TGetCatalogsReq) ReadField1281 

func (p *TGetCatalogsReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetCatalogsReq) ReadField1282 

func (p *TGetCatalogsReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetCatalogsReq) String 

func (p *TGetCatalogsReq) String() string

func (*TGetCatalogsReq) Validate added in v1.5.0 

func (p *TGetCatalogsReq) Validate() error

func (*TGetCatalogsReq) Write 

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

type TGetCatalogsResp 

type TGetCatalogsResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetCatalogsResult_Success_DEFAULT *TGetCatalogsResp

func NewTGetCatalogsResp 

func NewTGetCatalogsResp() *TGetCatalogsResp

func (*TGetCatalogsResp) Equals 

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

func (*TGetCatalogsResp) GetDirectResults 

func (p *TGetCatalogsResp) GetDirectResults() *TSparkDirectResults

func (*TGetCatalogsResp) GetOperationHandle 

func (p *TGetCatalogsResp) GetOperationHandle() *TOperationHandle

func (*TGetCatalogsResp) GetStatus 

func (p *TGetCatalogsResp) GetStatus() *TStatus

func (*TGetCatalogsResp) IsSetDirectResults 

func (p *TGetCatalogsResp) IsSetDirectResults() bool

func (*TGetCatalogsResp) IsSetOperationHandle 

func (p *TGetCatalogsResp) IsSetOperationHandle() bool

func (*TGetCatalogsResp) IsSetStatus 

func (p *TGetCatalogsResp) IsSetStatus() bool

func (*TGetCatalogsResp) Read 

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

func (*TGetCatalogsResp) ReadField1 

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

func (*TGetCatalogsResp) ReadField1281 

func (p *TGetCatalogsResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetCatalogsResp) ReadField2 

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

func (*TGetCatalogsResp) String 

func (p *TGetCatalogsResp) String() string

func (*TGetCatalogsResp) Validate added in v1.5.0 

func (p *TGetCatalogsResp) Validate() error

func (*TGetCatalogsResp) Write 

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

type TGetColumnsReq 

type TGetColumnsReq struct {
	SessionHandle *TSessionHandle       `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	CatalogName   *TIdentifier          `thrift:"catalogName,2" db:"catalogName" json:"catalogName,omitempty"`
	SchemaName    *TPatternOrIdentifier `thrift:"schemaName,3" db:"schemaName" json:"schemaName,omitempty"`
	TableName     *TPatternOrIdentifier `thrift:"tableName,4" db:"tableName" json:"tableName,omitempty"`
	ColumnName    *TPatternOrIdentifier `thrift:"columnName,5" db:"columnName" json:"columnName,omitempty"`
	// unused fields # 6 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • CatalogName
  • SchemaName
  • TableName
  • ColumnName
  • GetDirectResults
  • RunAsync
var TCLIServiceGetColumnsArgs_Req_DEFAULT *TGetColumnsReq

func NewTGetColumnsReq 

func NewTGetColumnsReq() *TGetColumnsReq

func (*TGetColumnsReq) Equals 

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

func (*TGetColumnsReq) GetCatalogName 

func (p *TGetColumnsReq) GetCatalogName() TIdentifier

func (*TGetColumnsReq) GetColumnName 

func (p *TGetColumnsReq) GetColumnName() TPatternOrIdentifier

func (*TGetColumnsReq) GetGetDirectResults 

func (p *TGetColumnsReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetColumnsReq) GetRunAsync 

func (p *TGetColumnsReq) GetRunAsync() bool

func (*TGetColumnsReq) GetSchemaName 

func (p *TGetColumnsReq) GetSchemaName() TPatternOrIdentifier

func (*TGetColumnsReq) GetSessionHandle 

func (p *TGetColumnsReq) GetSessionHandle() *TSessionHandle

func (*TGetColumnsReq) GetTableName 

func (p *TGetColumnsReq) GetTableName() TPatternOrIdentifier

func (*TGetColumnsReq) IsSetCatalogName 

func (p *TGetColumnsReq) IsSetCatalogName() bool

func (*TGetColumnsReq) IsSetColumnName 

func (p *TGetColumnsReq) IsSetColumnName() bool

func (*TGetColumnsReq) IsSetGetDirectResults 

func (p *TGetColumnsReq) IsSetGetDirectResults() bool

func (*TGetColumnsReq) IsSetRunAsync 

func (p *TGetColumnsReq) IsSetRunAsync() bool

func (*TGetColumnsReq) IsSetSchemaName 

func (p *TGetColumnsReq) IsSetSchemaName() bool

func (*TGetColumnsReq) IsSetSessionHandle 

func (p *TGetColumnsReq) IsSetSessionHandle() bool

func (*TGetColumnsReq) IsSetTableName 

func (p *TGetColumnsReq) IsSetTableName() bool

func (*TGetColumnsReq) Read 

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

func (*TGetColumnsReq) ReadField1 

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

func (*TGetColumnsReq) ReadField1281 

func (p *TGetColumnsReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetColumnsReq) ReadField1282 

func (p *TGetColumnsReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetColumnsReq) ReadField2 

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

func (*TGetColumnsReq) ReadField3 

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

func (*TGetColumnsReq) ReadField4 

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

func (*TGetColumnsReq) ReadField5 

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

func (*TGetColumnsReq) String 

func (p *TGetColumnsReq) String() string

func (*TGetColumnsReq) Validate added in v1.5.0 

func (p *TGetColumnsReq) Validate() error

func (*TGetColumnsReq) Write 

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

type TGetColumnsResp 

type TGetColumnsResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetColumnsResult_Success_DEFAULT *TGetColumnsResp

func NewTGetColumnsResp 

func NewTGetColumnsResp() *TGetColumnsResp

func (*TGetColumnsResp) Equals 

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

func (*TGetColumnsResp) GetDirectResults 

func (p *TGetColumnsResp) GetDirectResults() *TSparkDirectResults

func (*TGetColumnsResp) GetOperationHandle 

func (p *TGetColumnsResp) GetOperationHandle() *TOperationHandle

func (*TGetColumnsResp) GetStatus 

func (p *TGetColumnsResp) GetStatus() *TStatus

func (*TGetColumnsResp) IsSetDirectResults 

func (p *TGetColumnsResp) IsSetDirectResults() bool

func (*TGetColumnsResp) IsSetOperationHandle 

func (p *TGetColumnsResp) IsSetOperationHandle() bool

func (*TGetColumnsResp) IsSetStatus 

func (p *TGetColumnsResp) IsSetStatus() bool

func (*TGetColumnsResp) Read 

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

func (*TGetColumnsResp) ReadField1 

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

func (*TGetColumnsResp) ReadField1281 

func (p *TGetColumnsResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetColumnsResp) ReadField2 

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

func (*TGetColumnsResp) String 

func (p *TGetColumnsResp) String() string

func (*TGetColumnsResp) Validate added in v1.5.0 

func (p *TGetColumnsResp) Validate() error

func (*TGetColumnsResp) Write 

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

type TGetCrossReferenceReq 

type TGetCrossReferenceReq struct {
	SessionHandle      *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	ParentCatalogName  *TIdentifier    `thrift:"parentCatalogName,2" db:"parentCatalogName" json:"parentCatalogName,omitempty"`
	ParentSchemaName   *TIdentifier    `thrift:"parentSchemaName,3" db:"parentSchemaName" json:"parentSchemaName,omitempty"`
	ParentTableName    *TIdentifier    `thrift:"parentTableName,4" db:"parentTableName" json:"parentTableName,omitempty"`
	ForeignCatalogName *TIdentifier    `thrift:"foreignCatalogName,5" db:"foreignCatalogName" json:"foreignCatalogName,omitempty"`
	ForeignSchemaName  *TIdentifier    `thrift:"foreignSchemaName,6" db:"foreignSchemaName" json:"foreignSchemaName,omitempty"`
	ForeignTableName   *TIdentifier    `thrift:"foreignTableName,7" db:"foreignTableName" json:"foreignTableName,omitempty"`
	// unused fields # 8 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • ParentCatalogName
  • ParentSchemaName
  • ParentTableName
  • ForeignCatalogName
  • ForeignSchemaName
  • ForeignTableName
  • GetDirectResults
  • RunAsync
var TCLIServiceGetCrossReferenceArgs_Req_DEFAULT *TGetCrossReferenceReq

func NewTGetCrossReferenceReq 

func NewTGetCrossReferenceReq() *TGetCrossReferenceReq

func (*TGetCrossReferenceReq) Equals 

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

func (*TGetCrossReferenceReq) GetForeignCatalogName 

func (p *TGetCrossReferenceReq) GetForeignCatalogName() TIdentifier

func (*TGetCrossReferenceReq) GetForeignSchemaName 

func (p *TGetCrossReferenceReq) GetForeignSchemaName() TIdentifier

func (*TGetCrossReferenceReq) GetForeignTableName 

func (p *TGetCrossReferenceReq) GetForeignTableName() TIdentifier

func (*TGetCrossReferenceReq) GetGetDirectResults 

func (p *TGetCrossReferenceReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetCrossReferenceReq) GetParentCatalogName 

func (p *TGetCrossReferenceReq) GetParentCatalogName() TIdentifier

func (*TGetCrossReferenceReq) GetParentSchemaName 

func (p *TGetCrossReferenceReq) GetParentSchemaName() TIdentifier

func (*TGetCrossReferenceReq) GetParentTableName 

func (p *TGetCrossReferenceReq) GetParentTableName() TIdentifier

func (*TGetCrossReferenceReq) GetRunAsync 

func (p *TGetCrossReferenceReq) GetRunAsync() bool

func (*TGetCrossReferenceReq) GetSessionHandle 

func (p *TGetCrossReferenceReq) GetSessionHandle() *TSessionHandle

func (*TGetCrossReferenceReq) IsSetForeignCatalogName 

func (p *TGetCrossReferenceReq) IsSetForeignCatalogName() bool

func (*TGetCrossReferenceReq) IsSetForeignSchemaName 

func (p *TGetCrossReferenceReq) IsSetForeignSchemaName() bool

func (*TGetCrossReferenceReq) IsSetForeignTableName 

func (p *TGetCrossReferenceReq) IsSetForeignTableName() bool

func (*TGetCrossReferenceReq) IsSetGetDirectResults 

func (p *TGetCrossReferenceReq) IsSetGetDirectResults() bool

func (*TGetCrossReferenceReq) IsSetParentCatalogName 

func (p *TGetCrossReferenceReq) IsSetParentCatalogName() bool

func (*TGetCrossReferenceReq) IsSetParentSchemaName 

func (p *TGetCrossReferenceReq) IsSetParentSchemaName() bool

func (*TGetCrossReferenceReq) IsSetParentTableName 

func (p *TGetCrossReferenceReq) IsSetParentTableName() bool

func (*TGetCrossReferenceReq) IsSetRunAsync 

func (p *TGetCrossReferenceReq) IsSetRunAsync() bool

func (*TGetCrossReferenceReq) IsSetSessionHandle 

func (p *TGetCrossReferenceReq) IsSetSessionHandle() bool

func (*TGetCrossReferenceReq) Read 

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

func (*TGetCrossReferenceReq) ReadField1 

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

func (*TGetCrossReferenceReq) ReadField1281 

func (p *TGetCrossReferenceReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetCrossReferenceReq) ReadField1282 

func (p *TGetCrossReferenceReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetCrossReferenceReq) ReadField2 

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

func (*TGetCrossReferenceReq) ReadField3 

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

func (*TGetCrossReferenceReq) ReadField4 

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

func (*TGetCrossReferenceReq) ReadField5 

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

func (*TGetCrossReferenceReq) ReadField6 

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

func (*TGetCrossReferenceReq) ReadField7 

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

func (*TGetCrossReferenceReq) String 

func (p *TGetCrossReferenceReq) String() string

func (*TGetCrossReferenceReq) Validate added in v1.5.0 

func (p *TGetCrossReferenceReq) Validate() error

func (*TGetCrossReferenceReq) Write 

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

type TGetCrossReferenceResp 

type TGetCrossReferenceResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetCrossReferenceResult_Success_DEFAULT *TGetCrossReferenceResp

func NewTGetCrossReferenceResp 

func NewTGetCrossReferenceResp() *TGetCrossReferenceResp

func (*TGetCrossReferenceResp) Equals 

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

func (*TGetCrossReferenceResp) GetDirectResults 

func (p *TGetCrossReferenceResp) GetDirectResults() *TSparkDirectResults

func (*TGetCrossReferenceResp) GetOperationHandle 

func (p *TGetCrossReferenceResp) GetOperationHandle() *TOperationHandle

func (*TGetCrossReferenceResp) GetStatus 

func (p *TGetCrossReferenceResp) GetStatus() *TStatus

func (*TGetCrossReferenceResp) IsSetDirectResults 

func (p *TGetCrossReferenceResp) IsSetDirectResults() bool

func (*TGetCrossReferenceResp) IsSetOperationHandle 

func (p *TGetCrossReferenceResp) IsSetOperationHandle() bool

func (*TGetCrossReferenceResp) IsSetStatus 

func (p *TGetCrossReferenceResp) IsSetStatus() bool

func (*TGetCrossReferenceResp) Read 

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

func (*TGetCrossReferenceResp) ReadField1 

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

func (*TGetCrossReferenceResp) ReadField1281 

func (p *TGetCrossReferenceResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetCrossReferenceResp) ReadField2 

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

func (*TGetCrossReferenceResp) String 

func (p *TGetCrossReferenceResp) String() string

func (*TGetCrossReferenceResp) Validate added in v1.5.0 

func (p *TGetCrossReferenceResp) Validate() error

func (*TGetCrossReferenceResp) Write 

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

type TGetDelegationTokenReq 

type TGetDelegationTokenReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	Owner         string          `thrift:"owner,2,required" db:"owner" json:"owner"`
	Renewer       string          `thrift:"renewer,3,required" db:"renewer" json:"renewer"`
}

Attributes:

  • SessionHandle
  • Owner
  • Renewer
var TCLIServiceGetDelegationTokenArgs_Req_DEFAULT *TGetDelegationTokenReq

func NewTGetDelegationTokenReq 

func NewTGetDelegationTokenReq() *TGetDelegationTokenReq

func (*TGetDelegationTokenReq) Equals 

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

func (*TGetDelegationTokenReq) GetOwner 

func (p *TGetDelegationTokenReq) GetOwner() string

func (*TGetDelegationTokenReq) GetRenewer 

func (p *TGetDelegationTokenReq) GetRenewer() string

func (*TGetDelegationTokenReq) GetSessionHandle 

func (p *TGetDelegationTokenReq) GetSessionHandle() *TSessionHandle

func (*TGetDelegationTokenReq) IsSetSessionHandle 

func (p *TGetDelegationTokenReq) IsSetSessionHandle() bool

func (*TGetDelegationTokenReq) Read 

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

func (*TGetDelegationTokenReq) ReadField1 

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

func (*TGetDelegationTokenReq) ReadField2 

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

func (*TGetDelegationTokenReq) ReadField3 

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

func (*TGetDelegationTokenReq) String 

func (p *TGetDelegationTokenReq) String() string

func (*TGetDelegationTokenReq) Validate added in v1.5.0 

func (p *TGetDelegationTokenReq) Validate() error

func (*TGetDelegationTokenReq) Write 

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

type TGetDelegationTokenResp 

type TGetDelegationTokenResp struct {
	Status          *TStatus `thrift:"status,1,required" db:"status" json:"status"`
	DelegationToken *string  `thrift:"delegationToken,2" db:"delegationToken" json:"delegationToken,omitempty"`
}

Attributes:

  • Status
  • DelegationToken
var TCLIServiceGetDelegationTokenResult_Success_DEFAULT *TGetDelegationTokenResp

func NewTGetDelegationTokenResp 

func NewTGetDelegationTokenResp() *TGetDelegationTokenResp

func (*TGetDelegationTokenResp) Equals 

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

func (*TGetDelegationTokenResp) GetDelegationToken 

func (p *TGetDelegationTokenResp) GetDelegationToken() string

func (*TGetDelegationTokenResp) GetStatus 

func (p *TGetDelegationTokenResp) GetStatus() *TStatus

func (*TGetDelegationTokenResp) IsSetDelegationToken 

func (p *TGetDelegationTokenResp) IsSetDelegationToken() bool

func (*TGetDelegationTokenResp) IsSetStatus 

func (p *TGetDelegationTokenResp) IsSetStatus() bool

func (*TGetDelegationTokenResp) Read 

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

func (*TGetDelegationTokenResp) ReadField1 

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

func (*TGetDelegationTokenResp) ReadField2 

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

func (*TGetDelegationTokenResp) String 

func (p *TGetDelegationTokenResp) String() string

func (*TGetDelegationTokenResp) Validate added in v1.5.0 

func (p *TGetDelegationTokenResp) Validate() error

func (*TGetDelegationTokenResp) Write 

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

type TGetFunctionsReq 

type TGetFunctionsReq struct {
	SessionHandle *TSessionHandle       `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	CatalogName   *TIdentifier          `thrift:"catalogName,2" db:"catalogName" json:"catalogName,omitempty"`
	SchemaName    *TPatternOrIdentifier `thrift:"schemaName,3" db:"schemaName" json:"schemaName,omitempty"`
	FunctionName  TPatternOrIdentifier  `thrift:"functionName,4,required" db:"functionName" json:"functionName"`
	// unused fields # 5 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • CatalogName
  • SchemaName
  • FunctionName
  • GetDirectResults
  • RunAsync
var TCLIServiceGetFunctionsArgs_Req_DEFAULT *TGetFunctionsReq

func NewTGetFunctionsReq 

func NewTGetFunctionsReq() *TGetFunctionsReq

func (*TGetFunctionsReq) Equals 

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

func (*TGetFunctionsReq) GetCatalogName 

func (p *TGetFunctionsReq) GetCatalogName() TIdentifier

func (*TGetFunctionsReq) GetFunctionName 

func (p *TGetFunctionsReq) GetFunctionName() TPatternOrIdentifier

func (*TGetFunctionsReq) GetGetDirectResults 

func (p *TGetFunctionsReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetFunctionsReq) GetRunAsync 

func (p *TGetFunctionsReq) GetRunAsync() bool

func (*TGetFunctionsReq) GetSchemaName 

func (p *TGetFunctionsReq) GetSchemaName() TPatternOrIdentifier

func (*TGetFunctionsReq) GetSessionHandle 

func (p *TGetFunctionsReq) GetSessionHandle() *TSessionHandle

func (*TGetFunctionsReq) IsSetCatalogName 

func (p *TGetFunctionsReq) IsSetCatalogName() bool

func (*TGetFunctionsReq) IsSetGetDirectResults 

func (p *TGetFunctionsReq) IsSetGetDirectResults() bool

func (*TGetFunctionsReq) IsSetRunAsync 

func (p *TGetFunctionsReq) IsSetRunAsync() bool

func (*TGetFunctionsReq) IsSetSchemaName 

func (p *TGetFunctionsReq) IsSetSchemaName() bool

func (*TGetFunctionsReq) IsSetSessionHandle 

func (p *TGetFunctionsReq) IsSetSessionHandle() bool

func (*TGetFunctionsReq) Read 

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

func (*TGetFunctionsReq) ReadField1 

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

func (*TGetFunctionsReq) ReadField1281 

func (p *TGetFunctionsReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetFunctionsReq) ReadField1282 

func (p *TGetFunctionsReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetFunctionsReq) ReadField2 

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

func (*TGetFunctionsReq) ReadField3 

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

func (*TGetFunctionsReq) ReadField4 

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

func (*TGetFunctionsReq) String 

func (p *TGetFunctionsReq) String() string

func (*TGetFunctionsReq) Validate added in v1.5.0 

func (p *TGetFunctionsReq) Validate() error

func (*TGetFunctionsReq) Write 

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

type TGetFunctionsResp 

type TGetFunctionsResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetFunctionsResult_Success_DEFAULT *TGetFunctionsResp

func NewTGetFunctionsResp 

func NewTGetFunctionsResp() *TGetFunctionsResp

func (*TGetFunctionsResp) Equals 

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

func (*TGetFunctionsResp) GetDirectResults 

func (p *TGetFunctionsResp) GetDirectResults() *TSparkDirectResults

func (*TGetFunctionsResp) GetOperationHandle 

func (p *TGetFunctionsResp) GetOperationHandle() *TOperationHandle

func (*TGetFunctionsResp) GetStatus 

func (p *TGetFunctionsResp) GetStatus() *TStatus

func (*TGetFunctionsResp) IsSetDirectResults 

func (p *TGetFunctionsResp) IsSetDirectResults() bool

func (*TGetFunctionsResp) IsSetOperationHandle 

func (p *TGetFunctionsResp) IsSetOperationHandle() bool

func (*TGetFunctionsResp) IsSetStatus 

func (p *TGetFunctionsResp) IsSetStatus() bool

func (*TGetFunctionsResp) Read 

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

func (*TGetFunctionsResp) ReadField1 

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

func (*TGetFunctionsResp) ReadField1281 

func (p *TGetFunctionsResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetFunctionsResp) ReadField2 

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

func (*TGetFunctionsResp) String 

func (p *TGetFunctionsResp) String() string

func (*TGetFunctionsResp) Validate added in v1.5.0 

func (p *TGetFunctionsResp) Validate() error

func (*TGetFunctionsResp) Write 

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

type TGetInfoReq 

type TGetInfoReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	InfoType      TGetInfoType    `thrift:"infoType,2,required" db:"infoType" json:"infoType"`
}

Attributes:

  • SessionHandle
  • InfoType
var TCLIServiceGetInfoArgs_Req_DEFAULT *TGetInfoReq

func NewTGetInfoReq 

func NewTGetInfoReq() *TGetInfoReq

func (*TGetInfoReq) Equals 

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

func (*TGetInfoReq) GetInfoType 

func (p *TGetInfoReq) GetInfoType() TGetInfoType

func (*TGetInfoReq) GetSessionHandle 

func (p *TGetInfoReq) GetSessionHandle() *TSessionHandle

func (*TGetInfoReq) IsSetSessionHandle 

func (p *TGetInfoReq) IsSetSessionHandle() bool

func (*TGetInfoReq) Read 

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

func (*TGetInfoReq) ReadField1 

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

func (*TGetInfoReq) ReadField2 

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

func (*TGetInfoReq) String 

func (p *TGetInfoReq) String() string

func (*TGetInfoReq) Validate added in v1.5.0 

func (p *TGetInfoReq) Validate() error

func (*TGetInfoReq) Write 

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

type TGetInfoResp 

type TGetInfoResp struct {
	Status    *TStatus       `thrift:"status,1,required" db:"status" json:"status"`
	InfoValue *TGetInfoValue `thrift:"infoValue,2,required" db:"infoValue" json:"infoValue"`
}

Attributes:

  • Status
  • InfoValue
var TCLIServiceGetInfoResult_Success_DEFAULT *TGetInfoResp

func NewTGetInfoResp 

func NewTGetInfoResp() *TGetInfoResp

func (*TGetInfoResp) Equals 

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

func (*TGetInfoResp) GetInfoValue 

func (p *TGetInfoResp) GetInfoValue() *TGetInfoValue

func (*TGetInfoResp) GetStatus 

func (p *TGetInfoResp) GetStatus() *TStatus

func (*TGetInfoResp) IsSetInfoValue 

func (p *TGetInfoResp) IsSetInfoValue() bool

func (*TGetInfoResp) IsSetStatus 

func (p *TGetInfoResp) IsSetStatus() bool

func (*TGetInfoResp) Read 

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

func (*TGetInfoResp) ReadField1 

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

func (*TGetInfoResp) ReadField2 

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

func (*TGetInfoResp) String 

func (p *TGetInfoResp) String() string

func (*TGetInfoResp) Validate added in v1.5.0 

func (p *TGetInfoResp) Validate() error

func (*TGetInfoResp) Write 

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

type TGetInfoType 

type TGetInfoType int64
const (
	TGetInfoType_CLI_MAX_DRIVER_CONNECTIONS     TGetInfoType = 0
	TGetInfoType_CLI_MAX_CONCURRENT_ACTIVITIES  TGetInfoType = 1
	TGetInfoType_CLI_DATA_SOURCE_NAME           TGetInfoType = 2
	TGetInfoType_CLI_FETCH_DIRECTION            TGetInfoType = 8
	TGetInfoType_CLI_SERVER_NAME                TGetInfoType = 13
	TGetInfoType_CLI_SEARCH_PATTERN_ESCAPE      TGetInfoType = 14
	TGetInfoType_CLI_DBMS_NAME                  TGetInfoType = 17
	TGetInfoType_CLI_DBMS_VER                   TGetInfoType = 18
	TGetInfoType_CLI_ACCESSIBLE_TABLES          TGetInfoType = 19
	TGetInfoType_CLI_ACCESSIBLE_PROCEDURES      TGetInfoType = 20
	TGetInfoType_CLI_CURSOR_COMMIT_BEHAVIOR     TGetInfoType = 23
	TGetInfoType_CLI_DATA_SOURCE_READ_ONLY      TGetInfoType = 25
	TGetInfoType_CLI_DEFAULT_TXN_ISOLATION      TGetInfoType = 26
	TGetInfoType_CLI_IDENTIFIER_CASE            TGetInfoType = 28
	TGetInfoType_CLI_IDENTIFIER_QUOTE_CHAR      TGetInfoType = 29
	TGetInfoType_CLI_MAX_COLUMN_NAME_LEN        TGetInfoType = 30
	TGetInfoType_CLI_MAX_CURSOR_NAME_LEN        TGetInfoType = 31
	TGetInfoType_CLI_MAX_SCHEMA_NAME_LEN        TGetInfoType = 32
	TGetInfoType_CLI_MAX_CATALOG_NAME_LEN       TGetInfoType = 34
	TGetInfoType_CLI_MAX_TABLE_NAME_LEN         TGetInfoType = 35
	TGetInfoType_CLI_SCROLL_CONCURRENCY         TGetInfoType = 43
	TGetInfoType_CLI_TXN_CAPABLE                TGetInfoType = 46
	TGetInfoType_CLI_USER_NAME                  TGetInfoType = 47
	TGetInfoType_CLI_TXN_ISOLATION_OPTION       TGetInfoType = 72
	TGetInfoType_CLI_INTEGRITY                  TGetInfoType = 73
	TGetInfoType_CLI_GETDATA_EXTENSIONS         TGetInfoType = 81
	TGetInfoType_CLI_NULL_COLLATION             TGetInfoType = 85
	TGetInfoType_CLI_ALTER_TABLE                TGetInfoType = 86
	TGetInfoType_CLI_ORDER_BY_COLUMNS_IN_SELECT TGetInfoType = 90
	TGetInfoType_CLI_SPECIAL_CHARACTERS         TGetInfoType = 94
	TGetInfoType_CLI_MAX_COLUMNS_IN_GROUP_BY    TGetInfoType = 97
	TGetInfoType_CLI_MAX_COLUMNS_IN_INDEX       TGetInfoType = 98
	TGetInfoType_CLI_MAX_COLUMNS_IN_ORDER_BY    TGetInfoType = 99
	TGetInfoType_CLI_MAX_COLUMNS_IN_SELECT      TGetInfoType = 100
	TGetInfoType_CLI_MAX_COLUMNS_IN_TABLE       TGetInfoType = 101
	TGetInfoType_CLI_MAX_INDEX_SIZE             TGetInfoType = 102
	TGetInfoType_CLI_MAX_ROW_SIZE               TGetInfoType = 104
	TGetInfoType_CLI_MAX_STATEMENT_LEN          TGetInfoType = 105
	TGetInfoType_CLI_MAX_TABLES_IN_SELECT       TGetInfoType = 106
	TGetInfoType_CLI_MAX_USER_NAME_LEN          TGetInfoType = 107
	TGetInfoType_CLI_OJ_CAPABILITIES            TGetInfoType = 115
	TGetInfoType_CLI_XOPEN_CLI_YEAR             TGetInfoType = 10000
	TGetInfoType_CLI_CURSOR_SENSITIVITY         TGetInfoType = 10001
	TGetInfoType_CLI_DESCRIBE_PARAMETER         TGetInfoType = 10002
	TGetInfoType_CLI_CATALOG_NAME               TGetInfoType = 10003
	TGetInfoType_CLI_COLLATION_SEQ              TGetInfoType = 10004
	TGetInfoType_CLI_MAX_IDENTIFIER_LEN         TGetInfoType = 10005
)

func TGetInfoTypeFromString 

func TGetInfoTypeFromString(s string) (TGetInfoType, error)

func TGetInfoTypePtr 

func TGetInfoTypePtr(v TGetInfoType) *TGetInfoType

func (TGetInfoType) MarshalText 

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

func (*TGetInfoType) Scan 

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

func (TGetInfoType) String 

func (p TGetInfoType) String() string

func (*TGetInfoType) UnmarshalText 

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

func (*TGetInfoType) Value 

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

type TGetInfoValue 

type TGetInfoValue struct {
	StringValue    *string `thrift:"stringValue,1" db:"stringValue" json:"stringValue,omitempty"`
	SmallIntValue  *int16  `thrift:"smallIntValue,2" db:"smallIntValue" json:"smallIntValue,omitempty"`
	IntegerBitmask *int32  `thrift:"integerBitmask,3" db:"integerBitmask" json:"integerBitmask,omitempty"`
	IntegerFlag    *int32  `thrift:"integerFlag,4" db:"integerFlag" json:"integerFlag,omitempty"`
	BinaryValue    *int32  `thrift:"binaryValue,5" db:"binaryValue" json:"binaryValue,omitempty"`
	LenValue       *int64  `thrift:"lenValue,6" db:"lenValue" json:"lenValue,omitempty"`
}

Attributes:

  • StringValue
  • SmallIntValue
  • IntegerBitmask
  • IntegerFlag
  • BinaryValue
  • LenValue
var TGetInfoResp_InfoValue_DEFAULT *TGetInfoValue

func NewTGetInfoValue 

func NewTGetInfoValue() *TGetInfoValue

func (*TGetInfoValue) CountSetFieldsTGetInfoValue 

func (p *TGetInfoValue) CountSetFieldsTGetInfoValue() int

func (*TGetInfoValue) Equals 

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

func (*TGetInfoValue) GetBinaryValue 

func (p *TGetInfoValue) GetBinaryValue() int32

func (*TGetInfoValue) GetIntegerBitmask 

func (p *TGetInfoValue) GetIntegerBitmask() int32

func (*TGetInfoValue) GetIntegerFlag 

func (p *TGetInfoValue) GetIntegerFlag() int32

func (*TGetInfoValue) GetLenValue 

func (p *TGetInfoValue) GetLenValue() int64

func (*TGetInfoValue) GetSmallIntValue 

func (p *TGetInfoValue) GetSmallIntValue() int16

func (*TGetInfoValue) GetStringValue 

func (p *TGetInfoValue) GetStringValue() string

func (*TGetInfoValue) IsSetBinaryValue 

func (p *TGetInfoValue) IsSetBinaryValue() bool

func (*TGetInfoValue) IsSetIntegerBitmask 

func (p *TGetInfoValue) IsSetIntegerBitmask() bool

func (*TGetInfoValue) IsSetIntegerFlag 

func (p *TGetInfoValue) IsSetIntegerFlag() bool

func (*TGetInfoValue) IsSetLenValue 

func (p *TGetInfoValue) IsSetLenValue() bool

func (*TGetInfoValue) IsSetSmallIntValue 

func (p *TGetInfoValue) IsSetSmallIntValue() bool

func (*TGetInfoValue) IsSetStringValue 

func (p *TGetInfoValue) IsSetStringValue() bool

func (*TGetInfoValue) Read 

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

func (*TGetInfoValue) ReadField1 

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

func (*TGetInfoValue) ReadField2 

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

func (*TGetInfoValue) ReadField3 

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

func (*TGetInfoValue) ReadField4 

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

func (*TGetInfoValue) ReadField5 

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

func (*TGetInfoValue) ReadField6 

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

func (*TGetInfoValue) String 

func (p *TGetInfoValue) String() string

func (*TGetInfoValue) Validate added in v1.5.0 

func (p *TGetInfoValue) Validate() error

func (*TGetInfoValue) Write 

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

type TGetOperationStatusReq 

type TGetOperationStatusReq struct {
	OperationHandle   *TOperationHandle `thrift:"operationHandle,1,required" db:"operationHandle" json:"operationHandle"`
	GetProgressUpdate *bool             `thrift:"getProgressUpdate,2" db:"getProgressUpdate" json:"getProgressUpdate,omitempty"`
}

Attributes:

  • OperationHandle
  • GetProgressUpdate
var TCLIServiceGetOperationStatusArgs_Req_DEFAULT *TGetOperationStatusReq

func NewTGetOperationStatusReq 

func NewTGetOperationStatusReq() *TGetOperationStatusReq

func (*TGetOperationStatusReq) Equals 

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

func (*TGetOperationStatusReq) GetGetProgressUpdate 

func (p *TGetOperationStatusReq) GetGetProgressUpdate() bool

func (*TGetOperationStatusReq) GetOperationHandle 

func (p *TGetOperationStatusReq) GetOperationHandle() *TOperationHandle

func (*TGetOperationStatusReq) IsSetGetProgressUpdate 

func (p *TGetOperationStatusReq) IsSetGetProgressUpdate() bool

func (*TGetOperationStatusReq) IsSetOperationHandle 

func (p *TGetOperationStatusReq) IsSetOperationHandle() bool

func (*TGetOperationStatusReq) Read 

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

func (*TGetOperationStatusReq) ReadField1 

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

func (*TGetOperationStatusReq) ReadField2 

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

func (*TGetOperationStatusReq) String 

func (p *TGetOperationStatusReq) String() string

func (*TGetOperationStatusReq) Validate added in v1.5.0 

func (p *TGetOperationStatusReq) Validate() error

func (*TGetOperationStatusReq) Write 

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

type TGetOperationStatusResp 

type TGetOperationStatusResp struct {
	Status                 *TStatus             `thrift:"status,1,required" db:"status" json:"status"`
	OperationState         *TOperationState     `thrift:"operationState,2" db:"operationState" json:"operationState,omitempty"`
	SqlState               *string              `thrift:"sqlState,3" db:"sqlState" json:"sqlState,omitempty"`
	ErrorCode              *int32               `thrift:"errorCode,4" db:"errorCode" json:"errorCode,omitempty"`
	ErrorMessage           *string              `thrift:"errorMessage,5" db:"errorMessage" json:"errorMessage,omitempty"`
	TaskStatus             *string              `thrift:"taskStatus,6" db:"taskStatus" json:"taskStatus,omitempty"`
	OperationStarted       *int64               `thrift:"operationStarted,7" db:"operationStarted" json:"operationStarted,omitempty"`
	OperationCompleted     *int64               `thrift:"operationCompleted,8" db:"operationCompleted" json:"operationCompleted,omitempty"`
	HasResultSet           *bool                `thrift:"hasResultSet,9" db:"hasResultSet" json:"hasResultSet,omitempty"`
	ProgressUpdateResponse *TProgressUpdateResp `thrift:"progressUpdateResponse,10" db:"progressUpdateResponse" json:"progressUpdateResponse,omitempty"`
	NumModifiedRows        *int64               `thrift:"numModifiedRows,11" db:"numModifiedRows" json:"numModifiedRows,omitempty"`
	// unused fields # 12 to 1280
	DisplayMessage   *string `thrift:"displayMessage,1281" db:"displayMessage" json:"displayMessage,omitempty"`
	DiagnosticInfo   *string `thrift:"diagnosticInfo,1282" db:"diagnosticInfo" json:"diagnosticInfo,omitempty"`
	ErrorDetailsJson *string `thrift:"errorDetailsJson,1283" db:"errorDetailsJson" json:"errorDetailsJson,omitempty"`
}

Attributes:

  • Status
  • OperationState
  • SqlState
  • ErrorCode
  • ErrorMessage
  • TaskStatus
  • OperationStarted
  • OperationCompleted
  • HasResultSet
  • ProgressUpdateResponse
  • NumModifiedRows
  • DisplayMessage
  • DiagnosticInfo
  • ErrorDetailsJson
var TCLIServiceGetOperationStatusResult_Success_DEFAULT *TGetOperationStatusResp
var TSparkDirectResults_OperationStatus_DEFAULT *TGetOperationStatusResp

func NewTGetOperationStatusResp 

func NewTGetOperationStatusResp() *TGetOperationStatusResp

func (*TGetOperationStatusResp) Equals 

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

func (*TGetOperationStatusResp) GetDiagnosticInfo 

func (p *TGetOperationStatusResp) GetDiagnosticInfo() string

func (*TGetOperationStatusResp) GetDisplayMessage 

func (p *TGetOperationStatusResp) GetDisplayMessage() string

func (*TGetOperationStatusResp) GetErrorCode 

func (p *TGetOperationStatusResp) GetErrorCode() int32

func (*TGetOperationStatusResp) GetErrorDetailsJson added in v1.5.0 

func (p *TGetOperationStatusResp) GetErrorDetailsJson() string

func (*TGetOperationStatusResp) GetErrorMessage 

func (p *TGetOperationStatusResp) GetErrorMessage() string

func (*TGetOperationStatusResp) GetHasResultSet 

func (p *TGetOperationStatusResp) GetHasResultSet() bool

func (*TGetOperationStatusResp) GetNumModifiedRows 

func (p *TGetOperationStatusResp) GetNumModifiedRows() int64

func (*TGetOperationStatusResp) GetOperationCompleted 

func (p *TGetOperationStatusResp) GetOperationCompleted() int64

func (*TGetOperationStatusResp) GetOperationStarted 

func (p *TGetOperationStatusResp) GetOperationStarted() int64

func (*TGetOperationStatusResp) GetOperationState 

func (p *TGetOperationStatusResp) GetOperationState() TOperationState

func (*TGetOperationStatusResp) GetProgressUpdateResponse 

func (p *TGetOperationStatusResp) GetProgressUpdateResponse() *TProgressUpdateResp

func (*TGetOperationStatusResp) GetSqlState 

func (p *TGetOperationStatusResp) GetSqlState() string

func (*TGetOperationStatusResp) GetStatus 

func (p *TGetOperationStatusResp) GetStatus() *TStatus

func (*TGetOperationStatusResp) GetTaskStatus 

func (p *TGetOperationStatusResp) GetTaskStatus() string

func (*TGetOperationStatusResp) IsSetDiagnosticInfo 

func (p *TGetOperationStatusResp) IsSetDiagnosticInfo() bool

func (*TGetOperationStatusResp) IsSetDisplayMessage 

func (p *TGetOperationStatusResp) IsSetDisplayMessage() bool

func (*TGetOperationStatusResp) IsSetErrorCode 

func (p *TGetOperationStatusResp) IsSetErrorCode() bool

func (*TGetOperationStatusResp) IsSetErrorDetailsJson added in v1.5.0 

func (p *TGetOperationStatusResp) IsSetErrorDetailsJson() bool

func (*TGetOperationStatusResp) IsSetErrorMessage 

func (p *TGetOperationStatusResp) IsSetErrorMessage() bool

func (*TGetOperationStatusResp) IsSetHasResultSet 

func (p *TGetOperationStatusResp) IsSetHasResultSet() bool

func (*TGetOperationStatusResp) IsSetNumModifiedRows 

func (p *TGetOperationStatusResp) IsSetNumModifiedRows() bool

func (*TGetOperationStatusResp) IsSetOperationCompleted 

func (p *TGetOperationStatusResp) IsSetOperationCompleted() bool

func (*TGetOperationStatusResp) IsSetOperationStarted 

func (p *TGetOperationStatusResp) IsSetOperationStarted() bool

func (*TGetOperationStatusResp) IsSetOperationState 

func (p *TGetOperationStatusResp) IsSetOperationState() bool

func (*TGetOperationStatusResp) IsSetProgressUpdateResponse 

func (p *TGetOperationStatusResp) IsSetProgressUpdateResponse() bool

func (*TGetOperationStatusResp) IsSetSqlState 

func (p *TGetOperationStatusResp) IsSetSqlState() bool

func (*TGetOperationStatusResp) IsSetStatus 

func (p *TGetOperationStatusResp) IsSetStatus() bool

func (*TGetOperationStatusResp) IsSetTaskStatus 

func (p *TGetOperationStatusResp) IsSetTaskStatus() bool

func (*TGetOperationStatusResp) Read 

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

func (*TGetOperationStatusResp) ReadField1 

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

func (*TGetOperationStatusResp) ReadField10 

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

func (*TGetOperationStatusResp) ReadField11 

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

func (*TGetOperationStatusResp) ReadField1281 

func (p *TGetOperationStatusResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetOperationStatusResp) ReadField1282 

func (p *TGetOperationStatusResp) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetOperationStatusResp) ReadField1283 added in v1.5.0 

func (p *TGetOperationStatusResp) ReadField1283(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetOperationStatusResp) ReadField2 

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

func (*TGetOperationStatusResp) ReadField3 

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

func (*TGetOperationStatusResp) ReadField4 

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

func (*TGetOperationStatusResp) ReadField5 

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

func (*TGetOperationStatusResp) ReadField6 

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

func (*TGetOperationStatusResp) ReadField7 

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

func (*TGetOperationStatusResp) ReadField8 

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

func (*TGetOperationStatusResp) ReadField9 

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

func (*TGetOperationStatusResp) String 

func (p *TGetOperationStatusResp) String() string

func (*TGetOperationStatusResp) Validate added in v1.5.0 

func (p *TGetOperationStatusResp) Validate() error

func (*TGetOperationStatusResp) Write 

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

type TGetPrimaryKeysReq 

type TGetPrimaryKeysReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	CatalogName   *TIdentifier    `thrift:"catalogName,2" db:"catalogName" json:"catalogName,omitempty"`
	SchemaName    *TIdentifier    `thrift:"schemaName,3" db:"schemaName" json:"schemaName,omitempty"`
	TableName     *TIdentifier    `thrift:"tableName,4" db:"tableName" json:"tableName,omitempty"`
	// unused fields # 5 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • CatalogName
  • SchemaName
  • TableName
  • GetDirectResults
  • RunAsync
var TCLIServiceGetPrimaryKeysArgs_Req_DEFAULT *TGetPrimaryKeysReq

func NewTGetPrimaryKeysReq 

func NewTGetPrimaryKeysReq() *TGetPrimaryKeysReq

func (*TGetPrimaryKeysReq) Equals 

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

func (*TGetPrimaryKeysReq) GetCatalogName 

func (p *TGetPrimaryKeysReq) GetCatalogName() TIdentifier

func (*TGetPrimaryKeysReq) GetGetDirectResults 

func (p *TGetPrimaryKeysReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetPrimaryKeysReq) GetRunAsync 

func (p *TGetPrimaryKeysReq) GetRunAsync() bool

func (*TGetPrimaryKeysReq) GetSchemaName 

func (p *TGetPrimaryKeysReq) GetSchemaName() TIdentifier

func (*TGetPrimaryKeysReq) GetSessionHandle 

func (p *TGetPrimaryKeysReq) GetSessionHandle() *TSessionHandle

func (*TGetPrimaryKeysReq) GetTableName 

func (p *TGetPrimaryKeysReq) GetTableName() TIdentifier

func (*TGetPrimaryKeysReq) IsSetCatalogName 

func (p *TGetPrimaryKeysReq) IsSetCatalogName() bool

func (*TGetPrimaryKeysReq) IsSetGetDirectResults 

func (p *TGetPrimaryKeysReq) IsSetGetDirectResults() bool

func (*TGetPrimaryKeysReq) IsSetRunAsync 

func (p *TGetPrimaryKeysReq) IsSetRunAsync() bool

func (*TGetPrimaryKeysReq) IsSetSchemaName 

func (p *TGetPrimaryKeysReq) IsSetSchemaName() bool

func (*TGetPrimaryKeysReq) IsSetSessionHandle 

func (p *TGetPrimaryKeysReq) IsSetSessionHandle() bool

func (*TGetPrimaryKeysReq) IsSetTableName 

func (p *TGetPrimaryKeysReq) IsSetTableName() bool

func (*TGetPrimaryKeysReq) Read 

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

func (*TGetPrimaryKeysReq) ReadField1 

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

func (*TGetPrimaryKeysReq) ReadField1281 

func (p *TGetPrimaryKeysReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetPrimaryKeysReq) ReadField1282 

func (p *TGetPrimaryKeysReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetPrimaryKeysReq) ReadField2 

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

func (*TGetPrimaryKeysReq) ReadField3 

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

func (*TGetPrimaryKeysReq) ReadField4 

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

func (*TGetPrimaryKeysReq) String 

func (p *TGetPrimaryKeysReq) String() string

func (*TGetPrimaryKeysReq) Validate added in v1.5.0 

func (p *TGetPrimaryKeysReq) Validate() error

func (*TGetPrimaryKeysReq) Write 

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

type TGetPrimaryKeysResp 

type TGetPrimaryKeysResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetPrimaryKeysResult_Success_DEFAULT *TGetPrimaryKeysResp

func NewTGetPrimaryKeysResp 

func NewTGetPrimaryKeysResp() *TGetPrimaryKeysResp

func (*TGetPrimaryKeysResp) Equals 

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

func (*TGetPrimaryKeysResp) GetDirectResults 

func (p *TGetPrimaryKeysResp) GetDirectResults() *TSparkDirectResults

func (*TGetPrimaryKeysResp) GetOperationHandle 

func (p *TGetPrimaryKeysResp) GetOperationHandle() *TOperationHandle

func (*TGetPrimaryKeysResp) GetStatus 

func (p *TGetPrimaryKeysResp) GetStatus() *TStatus

func (*TGetPrimaryKeysResp) IsSetDirectResults 

func (p *TGetPrimaryKeysResp) IsSetDirectResults() bool

func (*TGetPrimaryKeysResp) IsSetOperationHandle 

func (p *TGetPrimaryKeysResp) IsSetOperationHandle() bool

func (*TGetPrimaryKeysResp) IsSetStatus 

func (p *TGetPrimaryKeysResp) IsSetStatus() bool

func (*TGetPrimaryKeysResp) Read 

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

func (*TGetPrimaryKeysResp) ReadField1 

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

func (*TGetPrimaryKeysResp) ReadField1281 

func (p *TGetPrimaryKeysResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetPrimaryKeysResp) ReadField2 

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

func (*TGetPrimaryKeysResp) String 

func (p *TGetPrimaryKeysResp) String() string

func (*TGetPrimaryKeysResp) Validate added in v1.5.0 

func (p *TGetPrimaryKeysResp) Validate() error

func (*TGetPrimaryKeysResp) Write 

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

type TGetResultSetMetadataReq 

type TGetResultSetMetadataReq struct {
	OperationHandle *TOperationHandle `thrift:"operationHandle,1,required" db:"operationHandle" json:"operationHandle"`
}

Attributes:

  • OperationHandle
var TCLIServiceGetResultSetMetadataArgs_Req_DEFAULT *TGetResultSetMetadataReq

func NewTGetResultSetMetadataReq 

func NewTGetResultSetMetadataReq() *TGetResultSetMetadataReq

func (*TGetResultSetMetadataReq) Equals 

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

func (*TGetResultSetMetadataReq) GetOperationHandle 

func (p *TGetResultSetMetadataReq) GetOperationHandle() *TOperationHandle

func (*TGetResultSetMetadataReq) IsSetOperationHandle 

func (p *TGetResultSetMetadataReq) IsSetOperationHandle() bool

func (*TGetResultSetMetadataReq) Read 

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

func (*TGetResultSetMetadataReq) ReadField1 

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

func (*TGetResultSetMetadataReq) String 

func (p *TGetResultSetMetadataReq) String() string

func (*TGetResultSetMetadataReq) Validate added in v1.5.0 

func (p *TGetResultSetMetadataReq) Validate() error

func (*TGetResultSetMetadataReq) Write 

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

type TGetResultSetMetadataResp 

type TGetResultSetMetadataResp struct {
	Status *TStatus      `thrift:"status,1,required" db:"status" json:"status"`
	Schema *TTableSchema `thrift:"schema,2" db:"schema" json:"schema,omitempty"`
	// unused fields # 3 to 1280
	ResultFormat       *TSparkRowSetType    `thrift:"resultFormat,1281" db:"resultFormat" json:"resultFormat,omitempty"`
	Lz4Compressed      *bool                `thrift:"lz4Compressed,1282" db:"lz4Compressed" json:"lz4Compressed,omitempty"`
	ArrowSchema        []byte               `thrift:"arrowSchema,1283" db:"arrowSchema" json:"arrowSchema,omitempty"`
	CacheLookupResult_ *TCacheLookupResult_ `thrift:"cacheLookupResult,1284" db:"cacheLookupResult" json:"cacheLookupResult,omitempty"`
	UncompressedBytes  *int64               `thrift:"uncompressedBytes,1285" db:"uncompressedBytes" json:"uncompressedBytes,omitempty"`
	CompressedBytes    *int64               `thrift:"compressedBytes,1286" db:"compressedBytes" json:"compressedBytes,omitempty"`
	IsStagingOperation *bool                `thrift:"isStagingOperation,1287" db:"isStagingOperation" json:"isStagingOperation,omitempty"`
}

Attributes:

  • Status
  • Schema
  • ResultFormat
  • Lz4Compressed
  • ArrowSchema
  • CacheLookupResult_
  • UncompressedBytes
  • CompressedBytes
  • IsStagingOperation
var TCLIServiceGetResultSetMetadataResult_Success_DEFAULT *TGetResultSetMetadataResp
var TFetchResultsResp_ResultSetMetadata_DEFAULT *TGetResultSetMetadataResp
var TSparkDirectResults_ResultSetMetadata_DEFAULT *TGetResultSetMetadataResp

func NewTGetResultSetMetadataResp 

func NewTGetResultSetMetadataResp() *TGetResultSetMetadataResp

func (*TGetResultSetMetadataResp) Equals 

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

func (*TGetResultSetMetadataResp) GetArrowSchema 

func (p *TGetResultSetMetadataResp) GetArrowSchema() []byte

func (*TGetResultSetMetadataResp) GetCacheLookupResult_ 

func (p *TGetResultSetMetadataResp) GetCacheLookupResult_() TCacheLookupResult_

func (*TGetResultSetMetadataResp) GetCompressedBytes 

func (p *TGetResultSetMetadataResp) GetCompressedBytes() int64

func (*TGetResultSetMetadataResp) GetIsStagingOperation added in v1.5.0 

func (p *TGetResultSetMetadataResp) GetIsStagingOperation() bool

func (*TGetResultSetMetadataResp) GetLz4Compressed 

func (p *TGetResultSetMetadataResp) GetLz4Compressed() bool

func (*TGetResultSetMetadataResp) GetResultFormat 

func (p *TGetResultSetMetadataResp) GetResultFormat() TSparkRowSetType

func (*TGetResultSetMetadataResp) GetSchema 

func (p *TGetResultSetMetadataResp) GetSchema() *TTableSchema

func (*TGetResultSetMetadataResp) GetStatus 

func (p *TGetResultSetMetadataResp) GetStatus() *TStatus

func (*TGetResultSetMetadataResp) GetUncompressedBytes 

func (p *TGetResultSetMetadataResp) GetUncompressedBytes() int64

func (*TGetResultSetMetadataResp) IsSetArrowSchema 

func (p *TGetResultSetMetadataResp) IsSetArrowSchema() bool

func (*TGetResultSetMetadataResp) IsSetCacheLookupResult_ 

func (p *TGetResultSetMetadataResp) IsSetCacheLookupResult_() bool

func (*TGetResultSetMetadataResp) IsSetCompressedBytes 

func (p *TGetResultSetMetadataResp) IsSetCompressedBytes() bool

func (*TGetResultSetMetadataResp) IsSetIsStagingOperation added in v1.5.0 

func (p *TGetResultSetMetadataResp) IsSetIsStagingOperation() bool

func (*TGetResultSetMetadataResp) IsSetLz4Compressed 

func (p *TGetResultSetMetadataResp) IsSetLz4Compressed() bool

func (*TGetResultSetMetadataResp) IsSetResultFormat 

func (p *TGetResultSetMetadataResp) IsSetResultFormat() bool

func (*TGetResultSetMetadataResp) IsSetSchema 

func (p *TGetResultSetMetadataResp) IsSetSchema() bool

func (*TGetResultSetMetadataResp) IsSetStatus 

func (p *TGetResultSetMetadataResp) IsSetStatus() bool

func (*TGetResultSetMetadataResp) IsSetUncompressedBytes 

func (p *TGetResultSetMetadataResp) IsSetUncompressedBytes() bool

func (*TGetResultSetMetadataResp) Read 

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

func (*TGetResultSetMetadataResp) ReadField1 

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

func (*TGetResultSetMetadataResp) ReadField1281 

func (p *TGetResultSetMetadataResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField1282 

func (p *TGetResultSetMetadataResp) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField1283 

func (p *TGetResultSetMetadataResp) ReadField1283(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField1284 

func (p *TGetResultSetMetadataResp) ReadField1284(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField1285 

func (p *TGetResultSetMetadataResp) ReadField1285(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField1286 

func (p *TGetResultSetMetadataResp) ReadField1286(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField1287 added in v1.5.0 

func (p *TGetResultSetMetadataResp) ReadField1287(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetResultSetMetadataResp) ReadField2 

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

func (*TGetResultSetMetadataResp) String 

func (p *TGetResultSetMetadataResp) String() string

func (*TGetResultSetMetadataResp) Validate added in v1.5.0 

func (p *TGetResultSetMetadataResp) Validate() error

func (*TGetResultSetMetadataResp) Write 

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

type TGetSchemasReq 

type TGetSchemasReq struct {
	SessionHandle *TSessionHandle       `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	CatalogName   *TIdentifier          `thrift:"catalogName,2" db:"catalogName" json:"catalogName,omitempty"`
	SchemaName    *TPatternOrIdentifier `thrift:"schemaName,3" db:"schemaName" json:"schemaName,omitempty"`
	// unused fields # 4 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • CatalogName
  • SchemaName
  • GetDirectResults
  • RunAsync
var TCLIServiceGetSchemasArgs_Req_DEFAULT *TGetSchemasReq

func NewTGetSchemasReq 

func NewTGetSchemasReq() *TGetSchemasReq

func (*TGetSchemasReq) Equals 

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

func (*TGetSchemasReq) GetCatalogName 

func (p *TGetSchemasReq) GetCatalogName() TIdentifier

func (*TGetSchemasReq) GetGetDirectResults 

func (p *TGetSchemasReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetSchemasReq) GetRunAsync 

func (p *TGetSchemasReq) GetRunAsync() bool

func (*TGetSchemasReq) GetSchemaName 

func (p *TGetSchemasReq) GetSchemaName() TPatternOrIdentifier

func (*TGetSchemasReq) GetSessionHandle 

func (p *TGetSchemasReq) GetSessionHandle() *TSessionHandle

func (*TGetSchemasReq) IsSetCatalogName 

func (p *TGetSchemasReq) IsSetCatalogName() bool

func (*TGetSchemasReq) IsSetGetDirectResults 

func (p *TGetSchemasReq) IsSetGetDirectResults() bool

func (*TGetSchemasReq) IsSetRunAsync 

func (p *TGetSchemasReq) IsSetRunAsync() bool

func (*TGetSchemasReq) IsSetSchemaName 

func (p *TGetSchemasReq) IsSetSchemaName() bool

func (*TGetSchemasReq) IsSetSessionHandle 

func (p *TGetSchemasReq) IsSetSessionHandle() bool

func (*TGetSchemasReq) Read 

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

func (*TGetSchemasReq) ReadField1 

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

func (*TGetSchemasReq) ReadField1281 

func (p *TGetSchemasReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetSchemasReq) ReadField1282 

func (p *TGetSchemasReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetSchemasReq) ReadField2 

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

func (*TGetSchemasReq) ReadField3 

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

func (*TGetSchemasReq) String 

func (p *TGetSchemasReq) String() string

func (*TGetSchemasReq) Validate added in v1.5.0 

func (p *TGetSchemasReq) Validate() error

func (*TGetSchemasReq) Write 

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

type TGetSchemasResp 

type TGetSchemasResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetSchemasResult_Success_DEFAULT *TGetSchemasResp

func NewTGetSchemasResp 

func NewTGetSchemasResp() *TGetSchemasResp

func (*TGetSchemasResp) Equals 

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

func (*TGetSchemasResp) GetDirectResults 

func (p *TGetSchemasResp) GetDirectResults() *TSparkDirectResults

func (*TGetSchemasResp) GetOperationHandle 

func (p *TGetSchemasResp) GetOperationHandle() *TOperationHandle

func (*TGetSchemasResp) GetStatus 

func (p *TGetSchemasResp) GetStatus() *TStatus

func (*TGetSchemasResp) IsSetDirectResults 

func (p *TGetSchemasResp) IsSetDirectResults() bool

func (*TGetSchemasResp) IsSetOperationHandle 

func (p *TGetSchemasResp) IsSetOperationHandle() bool

func (*TGetSchemasResp) IsSetStatus 

func (p *TGetSchemasResp) IsSetStatus() bool

func (*TGetSchemasResp) Read 

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

func (*TGetSchemasResp) ReadField1 

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

func (*TGetSchemasResp) ReadField1281 

func (p *TGetSchemasResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetSchemasResp) ReadField2 

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

func (*TGetSchemasResp) String 

func (p *TGetSchemasResp) String() string

func (*TGetSchemasResp) Validate added in v1.5.0 

func (p *TGetSchemasResp) Validate() error

func (*TGetSchemasResp) Write 

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

type TGetTableTypesReq 

type TGetTableTypesReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	// unused fields # 2 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • GetDirectResults
  • RunAsync
var TCLIServiceGetTableTypesArgs_Req_DEFAULT *TGetTableTypesReq

func NewTGetTableTypesReq 

func NewTGetTableTypesReq() *TGetTableTypesReq

func (*TGetTableTypesReq) Equals 

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

func (*TGetTableTypesReq) GetGetDirectResults 

func (p *TGetTableTypesReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetTableTypesReq) GetRunAsync 

func (p *TGetTableTypesReq) GetRunAsync() bool

func (*TGetTableTypesReq) GetSessionHandle 

func (p *TGetTableTypesReq) GetSessionHandle() *TSessionHandle

func (*TGetTableTypesReq) IsSetGetDirectResults 

func (p *TGetTableTypesReq) IsSetGetDirectResults() bool

func (*TGetTableTypesReq) IsSetRunAsync 

func (p *TGetTableTypesReq) IsSetRunAsync() bool

func (*TGetTableTypesReq) IsSetSessionHandle 

func (p *TGetTableTypesReq) IsSetSessionHandle() bool

func (*TGetTableTypesReq) Read 

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

func (*TGetTableTypesReq) ReadField1 

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

func (*TGetTableTypesReq) ReadField1281 

func (p *TGetTableTypesReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTableTypesReq) ReadField1282 

func (p *TGetTableTypesReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTableTypesReq) String 

func (p *TGetTableTypesReq) String() string

func (*TGetTableTypesReq) Validate added in v1.5.0 

func (p *TGetTableTypesReq) Validate() error

func (*TGetTableTypesReq) Write 

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

type TGetTableTypesResp 

type TGetTableTypesResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetTableTypesResult_Success_DEFAULT *TGetTableTypesResp

func NewTGetTableTypesResp 

func NewTGetTableTypesResp() *TGetTableTypesResp

func (*TGetTableTypesResp) Equals 

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

func (*TGetTableTypesResp) GetDirectResults 

func (p *TGetTableTypesResp) GetDirectResults() *TSparkDirectResults

func (*TGetTableTypesResp) GetOperationHandle 

func (p *TGetTableTypesResp) GetOperationHandle() *TOperationHandle

func (*TGetTableTypesResp) GetStatus 

func (p *TGetTableTypesResp) GetStatus() *TStatus

func (*TGetTableTypesResp) IsSetDirectResults 

func (p *TGetTableTypesResp) IsSetDirectResults() bool

func (*TGetTableTypesResp) IsSetOperationHandle 

func (p *TGetTableTypesResp) IsSetOperationHandle() bool

func (*TGetTableTypesResp) IsSetStatus 

func (p *TGetTableTypesResp) IsSetStatus() bool

func (*TGetTableTypesResp) Read 

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

func (*TGetTableTypesResp) ReadField1 

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

func (*TGetTableTypesResp) ReadField1281 

func (p *TGetTableTypesResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTableTypesResp) ReadField2 

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

func (*TGetTableTypesResp) String 

func (p *TGetTableTypesResp) String() string

func (*TGetTableTypesResp) Validate added in v1.5.0 

func (p *TGetTableTypesResp) Validate() error

func (*TGetTableTypesResp) Write 

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

type TGetTablesReq 

type TGetTablesReq struct {
	SessionHandle *TSessionHandle       `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	CatalogName   *TPatternOrIdentifier `thrift:"catalogName,2" db:"catalogName" json:"catalogName,omitempty"`
	SchemaName    *TPatternOrIdentifier `thrift:"schemaName,3" db:"schemaName" json:"schemaName,omitempty"`
	TableName     *TPatternOrIdentifier `thrift:"tableName,4" db:"tableName" json:"tableName,omitempty"`
	TableTypes    []string              `thrift:"tableTypes,5" db:"tableTypes" json:"tableTypes,omitempty"`
	// unused fields # 6 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • CatalogName
  • SchemaName
  • TableName
  • TableTypes
  • GetDirectResults
  • RunAsync
var TCLIServiceGetTablesArgs_Req_DEFAULT *TGetTablesReq

func NewTGetTablesReq 

func NewTGetTablesReq() *TGetTablesReq

func (*TGetTablesReq) Equals 

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

func (*TGetTablesReq) GetCatalogName 

func (p *TGetTablesReq) GetCatalogName() TPatternOrIdentifier

func (*TGetTablesReq) GetGetDirectResults 

func (p *TGetTablesReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetTablesReq) GetRunAsync 

func (p *TGetTablesReq) GetRunAsync() bool

func (*TGetTablesReq) GetSchemaName 

func (p *TGetTablesReq) GetSchemaName() TPatternOrIdentifier

func (*TGetTablesReq) GetSessionHandle 

func (p *TGetTablesReq) GetSessionHandle() *TSessionHandle

func (*TGetTablesReq) GetTableName 

func (p *TGetTablesReq) GetTableName() TPatternOrIdentifier

func (*TGetTablesReq) GetTableTypes 

func (p *TGetTablesReq) GetTableTypes() []string

func (*TGetTablesReq) IsSetCatalogName 

func (p *TGetTablesReq) IsSetCatalogName() bool

func (*TGetTablesReq) IsSetGetDirectResults 

func (p *TGetTablesReq) IsSetGetDirectResults() bool

func (*TGetTablesReq) IsSetRunAsync 

func (p *TGetTablesReq) IsSetRunAsync() bool

func (*TGetTablesReq) IsSetSchemaName 

func (p *TGetTablesReq) IsSetSchemaName() bool

func (*TGetTablesReq) IsSetSessionHandle 

func (p *TGetTablesReq) IsSetSessionHandle() bool

func (*TGetTablesReq) IsSetTableName 

func (p *TGetTablesReq) IsSetTableName() bool

func (*TGetTablesReq) IsSetTableTypes 

func (p *TGetTablesReq) IsSetTableTypes() bool

func (*TGetTablesReq) Read 

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

func (*TGetTablesReq) ReadField1 

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

func (*TGetTablesReq) ReadField1281 

func (p *TGetTablesReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTablesReq) ReadField1282 

func (p *TGetTablesReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTablesReq) ReadField2 

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

func (*TGetTablesReq) ReadField3 

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

func (*TGetTablesReq) ReadField4 

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

func (*TGetTablesReq) ReadField5 

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

func (*TGetTablesReq) String 

func (p *TGetTablesReq) String() string

func (*TGetTablesReq) Validate added in v1.5.0 

func (p *TGetTablesReq) Validate() error

func (*TGetTablesReq) Write 

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

type TGetTablesResp 

type TGetTablesResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetTablesResult_Success_DEFAULT *TGetTablesResp

func NewTGetTablesResp 

func NewTGetTablesResp() *TGetTablesResp

func (*TGetTablesResp) Equals 

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

func (*TGetTablesResp) GetDirectResults 

func (p *TGetTablesResp) GetDirectResults() *TSparkDirectResults

func (*TGetTablesResp) GetOperationHandle 

func (p *TGetTablesResp) GetOperationHandle() *TOperationHandle

func (*TGetTablesResp) GetStatus 

func (p *TGetTablesResp) GetStatus() *TStatus

func (*TGetTablesResp) IsSetDirectResults 

func (p *TGetTablesResp) IsSetDirectResults() bool

func (*TGetTablesResp) IsSetOperationHandle 

func (p *TGetTablesResp) IsSetOperationHandle() bool

func (*TGetTablesResp) IsSetStatus 

func (p *TGetTablesResp) IsSetStatus() bool

func (*TGetTablesResp) Read 

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

func (*TGetTablesResp) ReadField1 

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

func (*TGetTablesResp) ReadField1281 

func (p *TGetTablesResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTablesResp) ReadField2 

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

func (*TGetTablesResp) String 

func (p *TGetTablesResp) String() string

func (*TGetTablesResp) Validate added in v1.5.0 

func (p *TGetTablesResp) Validate() error

func (*TGetTablesResp) Write 

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

type TGetTypeInfoReq 

type TGetTypeInfoReq struct {
	SessionHandle *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	// unused fields # 2 to 1280
	GetDirectResults *TSparkGetDirectResults `thrift:"getDirectResults,1281" db:"getDirectResults" json:"getDirectResults,omitempty"`
	RunAsync         bool                    `thrift:"runAsync,1282" db:"runAsync" json:"runAsync"`
}

Attributes:

  • SessionHandle
  • GetDirectResults
  • RunAsync
var TCLIServiceGetTypeInfoArgs_Req_DEFAULT *TGetTypeInfoReq

func NewTGetTypeInfoReq 

func NewTGetTypeInfoReq() *TGetTypeInfoReq

func (*TGetTypeInfoReq) Equals 

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

func (*TGetTypeInfoReq) GetGetDirectResults 

func (p *TGetTypeInfoReq) GetGetDirectResults() *TSparkGetDirectResults

func (*TGetTypeInfoReq) GetRunAsync 

func (p *TGetTypeInfoReq) GetRunAsync() bool

func (*TGetTypeInfoReq) GetSessionHandle 

func (p *TGetTypeInfoReq) GetSessionHandle() *TSessionHandle

func (*TGetTypeInfoReq) IsSetGetDirectResults 

func (p *TGetTypeInfoReq) IsSetGetDirectResults() bool

func (*TGetTypeInfoReq) IsSetRunAsync 

func (p *TGetTypeInfoReq) IsSetRunAsync() bool

func (*TGetTypeInfoReq) IsSetSessionHandle 

func (p *TGetTypeInfoReq) IsSetSessionHandle() bool

func (*TGetTypeInfoReq) Read 

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

func (*TGetTypeInfoReq) ReadField1 

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

func (*TGetTypeInfoReq) ReadField1281 

func (p *TGetTypeInfoReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTypeInfoReq) ReadField1282 

func (p *TGetTypeInfoReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTypeInfoReq) String 

func (p *TGetTypeInfoReq) String() string

func (*TGetTypeInfoReq) Validate added in v1.5.0 

func (p *TGetTypeInfoReq) Validate() error

func (*TGetTypeInfoReq) Write 

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

type TGetTypeInfoResp 

type TGetTypeInfoResp struct {
	Status          *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	OperationHandle *TOperationHandle `thrift:"operationHandle,2" db:"operationHandle" json:"operationHandle,omitempty"`
	// unused fields # 3 to 1280
	DirectResults *TSparkDirectResults `thrift:"directResults,1281" db:"directResults" json:"directResults,omitempty"`
}

Attributes:

  • Status
  • OperationHandle
  • DirectResults
var TCLIServiceGetTypeInfoResult_Success_DEFAULT *TGetTypeInfoResp

func NewTGetTypeInfoResp 

func NewTGetTypeInfoResp() *TGetTypeInfoResp

func (*TGetTypeInfoResp) Equals 

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

func (*TGetTypeInfoResp) GetDirectResults 

func (p *TGetTypeInfoResp) GetDirectResults() *TSparkDirectResults

func (*TGetTypeInfoResp) GetOperationHandle 

func (p *TGetTypeInfoResp) GetOperationHandle() *TOperationHandle

func (*TGetTypeInfoResp) GetStatus 

func (p *TGetTypeInfoResp) GetStatus() *TStatus

func (*TGetTypeInfoResp) IsSetDirectResults 

func (p *TGetTypeInfoResp) IsSetDirectResults() bool

func (*TGetTypeInfoResp) IsSetOperationHandle 

func (p *TGetTypeInfoResp) IsSetOperationHandle() bool

func (*TGetTypeInfoResp) IsSetStatus 

func (p *TGetTypeInfoResp) IsSetStatus() bool

func (*TGetTypeInfoResp) Read 

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

func (*TGetTypeInfoResp) ReadField1 

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

func (*TGetTypeInfoResp) ReadField1281 

func (p *TGetTypeInfoResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetTypeInfoResp) ReadField2 

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

func (*TGetTypeInfoResp) String 

func (p *TGetTypeInfoResp) String() string

func (*TGetTypeInfoResp) Validate added in v1.5.0 

func (p *TGetTypeInfoResp) Validate() error

func (*TGetTypeInfoResp) Write 

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

type THandleIdentifier 

type THandleIdentifier struct {
	GUID   []byte `thrift:"guid,1,required" db:"guid" json:"guid"`
	Secret []byte `thrift:"secret,2,required" db:"secret" json:"secret"`
}

Attributes:

  • GUID
  • Secret
var TOperationHandle_OperationId_DEFAULT *THandleIdentifier
var TSessionHandle_SessionId_DEFAULT *THandleIdentifier

func NewTHandleIdentifier 

func NewTHandleIdentifier() *THandleIdentifier

func (*THandleIdentifier) Equals 

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

func (*THandleIdentifier) GetGUID 

func (p *THandleIdentifier) GetGUID() []byte

func (*THandleIdentifier) GetSecret 

func (p *THandleIdentifier) GetSecret() []byte

func (*THandleIdentifier) Read 

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

func (*THandleIdentifier) ReadField1 

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

func (*THandleIdentifier) ReadField2 

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

func (*THandleIdentifier) String 

func (p *THandleIdentifier) String() string

func (*THandleIdentifier) Validate added in v1.5.0 

func (p *THandleIdentifier) Validate() error

func (*THandleIdentifier) Write 

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

type TI16Column 

type TI16Column struct {
	Values []int16 `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte  `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_I16Val_DEFAULT *TI16Column

func NewTI16Column 

func NewTI16Column() *TI16Column

func (*TI16Column) Equals 

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

func (*TI16Column) GetNulls 

func (p *TI16Column) GetNulls() []byte

func (*TI16Column) GetValues 

func (p *TI16Column) GetValues() []int16

func (*TI16Column) Read 

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

func (*TI16Column) ReadField1 

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

func (*TI16Column) ReadField2 

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

func (*TI16Column) String 

func (p *TI16Column) String() string

func (*TI16Column) Validate added in v1.5.0 

func (p *TI16Column) Validate() error

func (*TI16Column) Write 

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

type TI16Value 

type TI16Value struct {
	Value *int16 `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_I16Val_DEFAULT *TI16Value

func NewTI16Value 

func NewTI16Value() *TI16Value

func (*TI16Value) Equals 

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

func (*TI16Value) GetValue 

func (p *TI16Value) GetValue() int16

func (*TI16Value) IsSetValue 

func (p *TI16Value) IsSetValue() bool

func (*TI16Value) Read 

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

func (*TI16Value) ReadField1 

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

func (*TI16Value) String 

func (p *TI16Value) String() string

func (*TI16Value) Validate added in v1.5.0 

func (p *TI16Value) Validate() error

func (*TI16Value) Write 

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

type TI32Column 

type TI32Column struct {
	Values []int32 `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte  `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_I32Val_DEFAULT *TI32Column

func NewTI32Column 

func NewTI32Column() *TI32Column

func (*TI32Column) Equals 

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

func (*TI32Column) GetNulls 

func (p *TI32Column) GetNulls() []byte

func (*TI32Column) GetValues 

func (p *TI32Column) GetValues() []int32

func (*TI32Column) Read 

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

func (*TI32Column) ReadField1 

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

func (*TI32Column) ReadField2 

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

func (*TI32Column) String 

func (p *TI32Column) String() string

func (*TI32Column) Validate added in v1.5.0 

func (p *TI32Column) Validate() error

func (*TI32Column) Write 

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

type TI32Value 

type TI32Value struct {
	Value *int32 `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_I32Val_DEFAULT *TI32Value

func NewTI32Value 

func NewTI32Value() *TI32Value

func (*TI32Value) Equals 

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

func (*TI32Value) GetValue 

func (p *TI32Value) GetValue() int32

func (*TI32Value) IsSetValue 

func (p *TI32Value) IsSetValue() bool

func (*TI32Value) Read 

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

func (*TI32Value) ReadField1 

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

func (*TI32Value) String 

func (p *TI32Value) String() string

func (*TI32Value) Validate added in v1.5.0 

func (p *TI32Value) Validate() error

func (*TI32Value) Write 

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

type TI64Column 

type TI64Column struct {
	Values []int64 `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte  `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_I64Val_DEFAULT *TI64Column

func NewTI64Column 

func NewTI64Column() *TI64Column

func (*TI64Column) Equals 

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

func (*TI64Column) GetNulls 

func (p *TI64Column) GetNulls() []byte

func (*TI64Column) GetValues 

func (p *TI64Column) GetValues() []int64

func (*TI64Column) Read 

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

func (*TI64Column) ReadField1 

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

func (*TI64Column) ReadField2 

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

func (*TI64Column) String 

func (p *TI64Column) String() string

func (*TI64Column) Validate added in v1.5.0 

func (p *TI64Column) Validate() error

func (*TI64Column) Write 

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

type TI64Value 

type TI64Value struct {
	Value *int64 `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_I64Val_DEFAULT *TI64Value

func NewTI64Value 

func NewTI64Value() *TI64Value

func (*TI64Value) Equals 

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

func (*TI64Value) GetValue 

func (p *TI64Value) GetValue() int64

func (*TI64Value) IsSetValue 

func (p *TI64Value) IsSetValue() bool

func (*TI64Value) Read 

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

func (*TI64Value) ReadField1 

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

func (*TI64Value) String 

func (p *TI64Value) String() string

func (*TI64Value) Validate added in v1.5.0 

func (p *TI64Value) Validate() error

func (*TI64Value) Write 

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

type TIdentifier 

type TIdentifier string
var TGetColumnsReq_CatalogName_DEFAULT TIdentifier
var TGetCrossReferenceReq_ForeignCatalogName_DEFAULT TIdentifier
var TGetCrossReferenceReq_ForeignSchemaName_DEFAULT TIdentifier
var TGetCrossReferenceReq_ForeignTableName_DEFAULT TIdentifier
var TGetCrossReferenceReq_ParentCatalogName_DEFAULT TIdentifier
var TGetCrossReferenceReq_ParentSchemaName_DEFAULT TIdentifier
var TGetCrossReferenceReq_ParentTableName_DEFAULT TIdentifier
var TGetFunctionsReq_CatalogName_DEFAULT TIdentifier
var TGetPrimaryKeysReq_CatalogName_DEFAULT TIdentifier
var TGetPrimaryKeysReq_SchemaName_DEFAULT TIdentifier
var TGetPrimaryKeysReq_TableName_DEFAULT TIdentifier
var TGetSchemasReq_CatalogName_DEFAULT TIdentifier
var TNamespace_CatalogName_DEFAULT TIdentifier
var TNamespace_SchemaName_DEFAULT TIdentifier

func TIdentifierPtr 

func TIdentifierPtr(v TIdentifier) *TIdentifier

type TJobExecutionStatus 

type TJobExecutionStatus int64
const (
	TJobExecutionStatus_IN_PROGRESS   TJobExecutionStatus = 0
	TJobExecutionStatus_COMPLETE      TJobExecutionStatus = 1
	TJobExecutionStatus_NOT_AVAILABLE TJobExecutionStatus = 2
)

func TJobExecutionStatusFromString 

func TJobExecutionStatusFromString(s string) (TJobExecutionStatus, error)

func TJobExecutionStatusPtr 

func TJobExecutionStatusPtr(v TJobExecutionStatus) *TJobExecutionStatus

func (TJobExecutionStatus) MarshalText 

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

func (*TJobExecutionStatus) Scan 

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

func (TJobExecutionStatus) String 

func (p TJobExecutionStatus) String() string

func (*TJobExecutionStatus) UnmarshalText 

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

func (*TJobExecutionStatus) Value 

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

type TMapTypeEntry 

type TMapTypeEntry struct {
	KeyTypePtr   TTypeEntryPtr `thrift:"keyTypePtr,1,required" db:"keyTypePtr" json:"keyTypePtr"`
	ValueTypePtr TTypeEntryPtr `thrift:"valueTypePtr,2,required" db:"valueTypePtr" json:"valueTypePtr"`
}

Attributes:

  • KeyTypePtr
  • ValueTypePtr
var TTypeEntry_MapEntry_DEFAULT *TMapTypeEntry

func NewTMapTypeEntry 

func NewTMapTypeEntry() *TMapTypeEntry

func (*TMapTypeEntry) Equals 

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

func (*TMapTypeEntry) GetKeyTypePtr 

func (p *TMapTypeEntry) GetKeyTypePtr() TTypeEntryPtr

func (*TMapTypeEntry) GetValueTypePtr 

func (p *TMapTypeEntry) GetValueTypePtr() TTypeEntryPtr

func (*TMapTypeEntry) Read 

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

func (*TMapTypeEntry) ReadField1 

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

func (*TMapTypeEntry) ReadField2 

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

func (*TMapTypeEntry) String 

func (p *TMapTypeEntry) String() string

func (*TMapTypeEntry) Validate added in v1.5.0 

func (p *TMapTypeEntry) Validate() error

func (*TMapTypeEntry) Write 

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

type TNamespace 

type TNamespace struct {
	CatalogName *TIdentifier `thrift:"catalogName,1" db:"catalogName" json:"catalogName,omitempty"`
	SchemaName  *TIdentifier `thrift:"schemaName,2" db:"schemaName" json:"schemaName,omitempty"`
}

Attributes:

  • CatalogName
  • SchemaName
var TOpenSessionReq_InitialNamespace_DEFAULT *TNamespace
var TOpenSessionResp_InitialNamespace_DEFAULT *TNamespace
var TStatementConf_InitialNamespace_DEFAULT *TNamespace

func NewTNamespace 

func NewTNamespace() *TNamespace

func (*TNamespace) Equals 

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

func (*TNamespace) GetCatalogName 

func (p *TNamespace) GetCatalogName() TIdentifier

func (*TNamespace) GetSchemaName 

func (p *TNamespace) GetSchemaName() TIdentifier

func (*TNamespace) IsSetCatalogName 

func (p *TNamespace) IsSetCatalogName() bool

func (*TNamespace) IsSetSchemaName 

func (p *TNamespace) IsSetSchemaName() bool

func (*TNamespace) Read 

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

func (*TNamespace) ReadField1 

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

func (*TNamespace) ReadField2 

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

func (*TNamespace) String 

func (p *TNamespace) String() string

func (*TNamespace) Validate added in v1.5.0 

func (p *TNamespace) Validate() error

func (*TNamespace) Write 

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

type TOpenSessionReq 

type TOpenSessionReq struct {
	ClientProtocol TProtocolVersion  `thrift:"client_protocol,1" db:"client_protocol" json:"client_protocol"`
	Username       *string           `thrift:"username,2" db:"username" json:"username,omitempty"`
	Password       *string           `thrift:"password,3" db:"password" json:"password,omitempty"`
	Configuration  map[string]string `thrift:"configuration,4" db:"configuration" json:"configuration,omitempty"`
	// unused fields # 5 to 1280
	GetInfos               []TGetInfoType    `thrift:"getInfos,1281" db:"getInfos" json:"getInfos,omitempty"`
	ClientProtocolI64      *int64            `thrift:"client_protocol_i64,1282" db:"client_protocol_i64" json:"client_protocol_i64,omitempty"`
	ConnectionProperties   map[string]string `thrift:"connectionProperties,1283" db:"connectionProperties" json:"connectionProperties,omitempty"`
	InitialNamespace       *TNamespace       `thrift:"initialNamespace,1284" db:"initialNamespace" json:"initialNamespace,omitempty"`
	CanUseMultipleCatalogs *bool             `thrift:"canUseMultipleCatalogs,1285" db:"canUseMultipleCatalogs" json:"canUseMultipleCatalogs,omitempty"`
}

Attributes:

  • ClientProtocol
  • Username
  • Password
  • Configuration
  • GetInfos
  • ClientProtocolI64
  • ConnectionProperties
  • InitialNamespace
  • CanUseMultipleCatalogs
var TCLIServiceOpenSessionArgs_Req_DEFAULT *TOpenSessionReq

func NewTOpenSessionReq 

func NewTOpenSessionReq() *TOpenSessionReq

func (*TOpenSessionReq) Equals 

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

func (*TOpenSessionReq) GetCanUseMultipleCatalogs 

func (p *TOpenSessionReq) GetCanUseMultipleCatalogs() bool

func (*TOpenSessionReq) GetClientProtocol 

func (p *TOpenSessionReq) GetClientProtocol() TProtocolVersion

func (*TOpenSessionReq) GetClientProtocolI64 

func (p *TOpenSessionReq) GetClientProtocolI64() int64

func (*TOpenSessionReq) GetConfiguration 

func (p *TOpenSessionReq) GetConfiguration() map[string]string

func (*TOpenSessionReq) GetConnectionProperties 

func (p *TOpenSessionReq) GetConnectionProperties() map[string]string

func (*TOpenSessionReq) GetGetInfos 

func (p *TOpenSessionReq) GetGetInfos() []TGetInfoType

func (*TOpenSessionReq) GetInitialNamespace 

func (p *TOpenSessionReq) GetInitialNamespace() *TNamespace

func (*TOpenSessionReq) GetPassword 

func (p *TOpenSessionReq) GetPassword() string

func (*TOpenSessionReq) GetUsername 

func (p *TOpenSessionReq) GetUsername() string

func (*TOpenSessionReq) IsSetCanUseMultipleCatalogs 

func (p *TOpenSessionReq) IsSetCanUseMultipleCatalogs() bool

func (*TOpenSessionReq) IsSetClientProtocol 

func (p *TOpenSessionReq) IsSetClientProtocol() bool

func (*TOpenSessionReq) IsSetClientProtocolI64 

func (p *TOpenSessionReq) IsSetClientProtocolI64() bool

func (*TOpenSessionReq) IsSetConfiguration 

func (p *TOpenSessionReq) IsSetConfiguration() bool

func (*TOpenSessionReq) IsSetConnectionProperties 

func (p *TOpenSessionReq) IsSetConnectionProperties() bool

func (*TOpenSessionReq) IsSetGetInfos 

func (p *TOpenSessionReq) IsSetGetInfos() bool

func (*TOpenSessionReq) IsSetInitialNamespace 

func (p *TOpenSessionReq) IsSetInitialNamespace() bool

func (*TOpenSessionReq) IsSetPassword 

func (p *TOpenSessionReq) IsSetPassword() bool

func (*TOpenSessionReq) IsSetUsername 

func (p *TOpenSessionReq) IsSetUsername() bool

func (*TOpenSessionReq) Read 

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

func (*TOpenSessionReq) ReadField1 

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

func (*TOpenSessionReq) ReadField1281 

func (p *TOpenSessionReq) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionReq) ReadField1282 

func (p *TOpenSessionReq) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionReq) ReadField1283 

func (p *TOpenSessionReq) ReadField1283(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionReq) ReadField1284 

func (p *TOpenSessionReq) ReadField1284(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionReq) ReadField1285 

func (p *TOpenSessionReq) ReadField1285(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionReq) ReadField2 

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

func (*TOpenSessionReq) ReadField3 

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

func (*TOpenSessionReq) ReadField4 

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

func (*TOpenSessionReq) String 

func (p *TOpenSessionReq) String() string

func (*TOpenSessionReq) Validate added in v1.5.0 

func (p *TOpenSessionReq) Validate() error

func (*TOpenSessionReq) Write 

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

type TOpenSessionResp 

type TOpenSessionResp struct {
	Status                *TStatus          `thrift:"status,1,required" db:"status" json:"status"`
	ServerProtocolVersion TProtocolVersion  `thrift:"serverProtocolVersion,2,required" db:"serverProtocolVersion" json:"serverProtocolVersion"`
	SessionHandle         *TSessionHandle   `thrift:"sessionHandle,3" db:"sessionHandle" json:"sessionHandle,omitempty"`
	Configuration         map[string]string `thrift:"configuration,4" db:"configuration" json:"configuration,omitempty"`
	// unused fields # 5 to 1280
	GetInfos []*TGetInfoValue `thrift:"getInfos,1281" db:"getInfos" json:"getInfos,omitempty"`
	// unused fields # 1282 to 1283
	InitialNamespace       *TNamespace `thrift:"initialNamespace,1284" db:"initialNamespace" json:"initialNamespace,omitempty"`
	CanUseMultipleCatalogs *bool       `thrift:"canUseMultipleCatalogs,1285" db:"canUseMultipleCatalogs" json:"canUseMultipleCatalogs,omitempty"`
}

Attributes:

  • Status
  • ServerProtocolVersion
  • SessionHandle
  • Configuration
  • InitialNamespace
  • CanUseMultipleCatalogs
  • GetInfos
var TCLIServiceOpenSessionResult_Success_DEFAULT *TOpenSessionResp

func NewTOpenSessionResp 

func NewTOpenSessionResp() *TOpenSessionResp

func (*TOpenSessionResp) Equals 

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

func (*TOpenSessionResp) GetCanUseMultipleCatalogs 

func (p *TOpenSessionResp) GetCanUseMultipleCatalogs() bool

func (*TOpenSessionResp) GetConfiguration 

func (p *TOpenSessionResp) GetConfiguration() map[string]string

func (*TOpenSessionResp) GetGetInfos 

func (p *TOpenSessionResp) GetGetInfos() []*TGetInfoValue

func (*TOpenSessionResp) GetInitialNamespace 

func (p *TOpenSessionResp) GetInitialNamespace() *TNamespace

func (*TOpenSessionResp) GetServerProtocolVersion 

func (p *TOpenSessionResp) GetServerProtocolVersion() TProtocolVersion

func (*TOpenSessionResp) GetSessionHandle 

func (p *TOpenSessionResp) GetSessionHandle() *TSessionHandle

func (*TOpenSessionResp) GetStatus 

func (p *TOpenSessionResp) GetStatus() *TStatus

func (*TOpenSessionResp) IsSetCanUseMultipleCatalogs 

func (p *TOpenSessionResp) IsSetCanUseMultipleCatalogs() bool

func (*TOpenSessionResp) IsSetConfiguration 

func (p *TOpenSessionResp) IsSetConfiguration() bool

func (*TOpenSessionResp) IsSetGetInfos 

func (p *TOpenSessionResp) IsSetGetInfos() bool

func (*TOpenSessionResp) IsSetInitialNamespace 

func (p *TOpenSessionResp) IsSetInitialNamespace() bool

func (*TOpenSessionResp) IsSetSessionHandle 

func (p *TOpenSessionResp) IsSetSessionHandle() bool

func (*TOpenSessionResp) IsSetStatus 

func (p *TOpenSessionResp) IsSetStatus() bool

func (*TOpenSessionResp) Read 

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

func (*TOpenSessionResp) ReadField1 

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

func (*TOpenSessionResp) ReadField1281 

func (p *TOpenSessionResp) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionResp) ReadField1284 

func (p *TOpenSessionResp) ReadField1284(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionResp) ReadField1285 

func (p *TOpenSessionResp) ReadField1285(ctx context.Context, iprot thrift.TProtocol) error

func (*TOpenSessionResp) ReadField2 

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

func (*TOpenSessionResp) ReadField3 

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

func (*TOpenSessionResp) ReadField4 

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

func (*TOpenSessionResp) String 

func (p *TOpenSessionResp) String() string

func (*TOpenSessionResp) Validate added in v1.5.0 

func (p *TOpenSessionResp) Validate() error

func (*TOpenSessionResp) Write 

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

type TOperationHandle 

type TOperationHandle struct {
	OperationId      *THandleIdentifier `thrift:"operationId,1,required" db:"operationId" json:"operationId"`
	OperationType    TOperationType     `thrift:"operationType,2,required" db:"operationType" json:"operationType"`
	HasResultSet     bool               `thrift:"hasResultSet,3,required" db:"hasResultSet" json:"hasResultSet"`
	ModifiedRowCount *float64           `thrift:"modifiedRowCount,4" db:"modifiedRowCount" json:"modifiedRowCount,omitempty"`
}

Attributes:

  • OperationId
  • OperationType
  • HasResultSet
  • ModifiedRowCount
var TCancelOperationReq_OperationHandle_DEFAULT *TOperationHandle
var TCloseOperationReq_OperationHandle_DEFAULT *TOperationHandle
var TExecuteStatementResp_OperationHandle_DEFAULT *TOperationHandle
var TFetchResultsReq_OperationHandle_DEFAULT *TOperationHandle
var TGetCatalogsResp_OperationHandle_DEFAULT *TOperationHandle
var TGetColumnsResp_OperationHandle_DEFAULT *TOperationHandle
var TGetCrossReferenceResp_OperationHandle_DEFAULT *TOperationHandle
var TGetFunctionsResp_OperationHandle_DEFAULT *TOperationHandle
var TGetOperationStatusReq_OperationHandle_DEFAULT *TOperationHandle
var TGetPrimaryKeysResp_OperationHandle_DEFAULT *TOperationHandle
var TGetResultSetMetadataReq_OperationHandle_DEFAULT *TOperationHandle
var TGetSchemasResp_OperationHandle_DEFAULT *TOperationHandle
var TGetTableTypesResp_OperationHandle_DEFAULT *TOperationHandle
var TGetTablesResp_OperationHandle_DEFAULT *TOperationHandle
var TGetTypeInfoResp_OperationHandle_DEFAULT *TOperationHandle

func NewTOperationHandle 

func NewTOperationHandle() *TOperationHandle

func (*TOperationHandle) Equals 

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

func (*TOperationHandle) GetHasResultSet 

func (p *TOperationHandle) GetHasResultSet() bool

func (*TOperationHandle) GetModifiedRowCount 

func (p *TOperationHandle) GetModifiedRowCount() float64

func (*TOperationHandle) GetOperationId 

func (p *TOperationHandle) GetOperationId() *THandleIdentifier

func (*TOperationHandle) GetOperationType 

func (p *TOperationHandle) GetOperationType() TOperationType

func (*TOperationHandle) IsSetModifiedRowCount 

func (p *TOperationHandle) IsSetModifiedRowCount() bool

func (*TOperationHandle) IsSetOperationId 

func (p *TOperationHandle) IsSetOperationId() bool

func (*TOperationHandle) Read 

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

func (*TOperationHandle) ReadField1 

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

func (*TOperationHandle) ReadField2 

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

func (*TOperationHandle) ReadField3 

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

func (*TOperationHandle) ReadField4 

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

func (*TOperationHandle) String 

func (p *TOperationHandle) String() string

func (*TOperationHandle) Validate added in v1.5.0 

func (p *TOperationHandle) Validate() error

func (*TOperationHandle) Write 

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

type TOperationState 

type TOperationState int64
const (
	TOperationState_INITIALIZED_STATE TOperationState = 0
	TOperationState_RUNNING_STATE     TOperationState = 1
	TOperationState_FINISHED_STATE    TOperationState = 2
	TOperationState_CANCELED_STATE    TOperationState = 3
	TOperationState_CLOSED_STATE      TOperationState = 4
	TOperationState_ERROR_STATE       TOperationState = 5
	TOperationState_UKNOWN_STATE      TOperationState = 6
	TOperationState_PENDING_STATE     TOperationState = 7
	TOperationState_TIMEDOUT_STATE    TOperationState = 8
)
var TGetOperationStatusResp_OperationState_DEFAULT TOperationState

func TOperationStateFromString 

func TOperationStateFromString(s string) (TOperationState, error)

func TOperationStatePtr 

func TOperationStatePtr(v TOperationState) *TOperationState

func (TOperationState) MarshalText 

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

func (*TOperationState) Scan 

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

func (TOperationState) String 

func (p TOperationState) String() string

func (*TOperationState) UnmarshalText 

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

func (*TOperationState) Value 

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

type TOperationType 

type TOperationType int64
const (
	TOperationType_EXECUTE_STATEMENT TOperationType = 0
	TOperationType_GET_TYPE_INFO     TOperationType = 1
	TOperationType_GET_CATALOGS      TOperationType = 2
	TOperationType_GET_SCHEMAS       TOperationType = 3
	TOperationType_GET_TABLES        TOperationType = 4
	TOperationType_GET_TABLE_TYPES   TOperationType = 5
	TOperationType_GET_COLUMNS       TOperationType = 6
	TOperationType_GET_FUNCTIONS     TOperationType = 7
	TOperationType_UNKNOWN           TOperationType = 8
)

func TOperationTypeFromString 

func TOperationTypeFromString(s string) (TOperationType, error)

func TOperationTypePtr 

func TOperationTypePtr(v TOperationType) *TOperationType

func (TOperationType) MarshalText 

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

func (*TOperationType) Scan 

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

func (TOperationType) String 

func (p TOperationType) String() string

func (*TOperationType) UnmarshalText 

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

func (*TOperationType) Value 

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

type TPattern 

type TPattern string

func TPatternPtr 

func TPatternPtr(v TPattern) *TPattern

type TPatternOrIdentifier 

type TPatternOrIdentifier string
var TGetColumnsReq_ColumnName_DEFAULT TPatternOrIdentifier
var TGetColumnsReq_SchemaName_DEFAULT TPatternOrIdentifier
var TGetColumnsReq_TableName_DEFAULT TPatternOrIdentifier
var TGetFunctionsReq_SchemaName_DEFAULT TPatternOrIdentifier
var TGetSchemasReq_SchemaName_DEFAULT TPatternOrIdentifier
var TGetTablesReq_CatalogName_DEFAULT TPatternOrIdentifier
var TGetTablesReq_SchemaName_DEFAULT TPatternOrIdentifier
var TGetTablesReq_TableName_DEFAULT TPatternOrIdentifier

func TPatternOrIdentifierPtr 

func TPatternOrIdentifierPtr(v TPatternOrIdentifier) *TPatternOrIdentifier

type TPrimitiveTypeEntry 

type TPrimitiveTypeEntry struct {
	Type           TTypeId          `thrift:"type,1,required" db:"type" json:"type"`
	TypeQualifiers *TTypeQualifiers `thrift:"typeQualifiers,2" db:"typeQualifiers" json:"typeQualifiers,omitempty"`
}

Attributes:

  • Type
  • TypeQualifiers
var TTypeEntry_PrimitiveEntry_DEFAULT *TPrimitiveTypeEntry

func NewTPrimitiveTypeEntry 

func NewTPrimitiveTypeEntry() *TPrimitiveTypeEntry

func (*TPrimitiveTypeEntry) Equals 

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

func (*TPrimitiveTypeEntry) GetType 

func (p *TPrimitiveTypeEntry) GetType() TTypeId

func (*TPrimitiveTypeEntry) GetTypeQualifiers 

func (p *TPrimitiveTypeEntry) GetTypeQualifiers() *TTypeQualifiers

func (*TPrimitiveTypeEntry) IsSetTypeQualifiers 

func (p *TPrimitiveTypeEntry) IsSetTypeQualifiers() bool

func (*TPrimitiveTypeEntry) Read 

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

func (*TPrimitiveTypeEntry) ReadField1 

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

func (*TPrimitiveTypeEntry) ReadField2 

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

func (*TPrimitiveTypeEntry) String 

func (p *TPrimitiveTypeEntry) String() string

func (*TPrimitiveTypeEntry) Validate added in v1.5.0 

func (p *TPrimitiveTypeEntry) Validate() error

func (*TPrimitiveTypeEntry) Write 

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

type TProgressUpdateResp 

type TProgressUpdateResp struct {
	HeaderNames          []string            `thrift:"headerNames,1,required" db:"headerNames" json:"headerNames"`
	Rows                 [][]string          `thrift:"rows,2,required" db:"rows" json:"rows"`
	ProgressedPercentage float64             `thrift:"progressedPercentage,3,required" db:"progressedPercentage" json:"progressedPercentage"`
	Status               TJobExecutionStatus `thrift:"status,4,required" db:"status" json:"status"`
	FooterSummary        string              `thrift:"footerSummary,5,required" db:"footerSummary" json:"footerSummary"`
	StartTime            int64               `thrift:"startTime,6,required" db:"startTime" json:"startTime"`
}

Attributes:

  • HeaderNames
  • Rows
  • ProgressedPercentage
  • Status
  • FooterSummary
  • StartTime
var TGetOperationStatusResp_ProgressUpdateResponse_DEFAULT *TProgressUpdateResp

func NewTProgressUpdateResp 

func NewTProgressUpdateResp() *TProgressUpdateResp

func (*TProgressUpdateResp) Equals 

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

func (*TProgressUpdateResp) GetFooterSummary 

func (p *TProgressUpdateResp) GetFooterSummary() string

func (*TProgressUpdateResp) GetHeaderNames 

func (p *TProgressUpdateResp) GetHeaderNames() []string

func (*TProgressUpdateResp) GetProgressedPercentage 

func (p *TProgressUpdateResp) GetProgressedPercentage() float64

func (*TProgressUpdateResp) GetRows 

func (p *TProgressUpdateResp) GetRows() [][]string

func (*TProgressUpdateResp) GetStartTime 

func (p *TProgressUpdateResp) GetStartTime() int64

func (*TProgressUpdateResp) GetStatus 

func (p *TProgressUpdateResp) GetStatus() TJobExecutionStatus

func (*TProgressUpdateResp) Read 

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

func (*TProgressUpdateResp) ReadField1 

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

func (*TProgressUpdateResp) ReadField2 

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

func (*TProgressUpdateResp) ReadField3 

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

func (*TProgressUpdateResp) ReadField4 

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

func (*TProgressUpdateResp) ReadField5 

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

func (*TProgressUpdateResp) ReadField6 

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

func (*TProgressUpdateResp) String 

func (p *TProgressUpdateResp) String() string

func (*TProgressUpdateResp) Validate added in v1.5.0 

func (p *TProgressUpdateResp) Validate() error

func (*TProgressUpdateResp) Write 

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

type TProtocolVersion 

type TProtocolVersion int64
const (
	TProtocolVersion___HIVE_JDBC_WORKAROUND        TProtocolVersion = -7
	TProtocolVersion___TEST_PROTOCOL_VERSION       TProtocolVersion = 65281
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V1  TProtocolVersion = 0
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V2  TProtocolVersion = 1
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V3  TProtocolVersion = 2
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V4  TProtocolVersion = 3
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V5  TProtocolVersion = 4
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V6  TProtocolVersion = 5
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V7  TProtocolVersion = 6
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V8  TProtocolVersion = 7
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V9  TProtocolVersion = 8
	TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V10 TProtocolVersion = 9
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V1 TProtocolVersion = 42241
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V2 TProtocolVersion = 42242
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V3 TProtocolVersion = 42243
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V4 TProtocolVersion = 42244
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V5 TProtocolVersion = 42245
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V6 TProtocolVersion = 42246
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V7 TProtocolVersion = 42247
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V8 TProtocolVersion = 42248
	TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V9 TProtocolVersion = 42249
)
var TOpenSessionReq_ClientProtocol_DEFAULT TProtocolVersion = -7
var TStatementConf_ClientProtocol_DEFAULT TProtocolVersion

func TProtocolVersionFromString 

func TProtocolVersionFromString(s string) (TProtocolVersion, error)

func TProtocolVersionPtr 

func TProtocolVersionPtr(v TProtocolVersion) *TProtocolVersion

func (TProtocolVersion) MarshalText 

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

func (*TProtocolVersion) Scan 

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

func (TProtocolVersion) String 

func (p TProtocolVersion) String() string

func (*TProtocolVersion) UnmarshalText 

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

func (*TProtocolVersion) Value 

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

type TRenewDelegationTokenReq 

type TRenewDelegationTokenReq struct {
	SessionHandle   *TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
	DelegationToken string          `thrift:"delegationToken,2,required" db:"delegationToken" json:"delegationToken"`
}

Attributes:

  • SessionHandle
  • DelegationToken
var TCLIServiceRenewDelegationTokenArgs_Req_DEFAULT *TRenewDelegationTokenReq

func NewTRenewDelegationTokenReq 

func NewTRenewDelegationTokenReq() *TRenewDelegationTokenReq

func (*TRenewDelegationTokenReq) Equals 

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

func (*TRenewDelegationTokenReq) GetDelegationToken 

func (p *TRenewDelegationTokenReq) GetDelegationToken() string

func (*TRenewDelegationTokenReq) GetSessionHandle 

func (p *TRenewDelegationTokenReq) GetSessionHandle() *TSessionHandle

func (*TRenewDelegationTokenReq) IsSetSessionHandle 

func (p *TRenewDelegationTokenReq) IsSetSessionHandle() bool

func (*TRenewDelegationTokenReq) Read 

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

func (*TRenewDelegationTokenReq) ReadField1 

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

func (*TRenewDelegationTokenReq) ReadField2 

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

func (*TRenewDelegationTokenReq) String 

func (p *TRenewDelegationTokenReq) String() string

func (*TRenewDelegationTokenReq) Validate added in v1.5.0 

func (p *TRenewDelegationTokenReq) Validate() error

func (*TRenewDelegationTokenReq) Write 

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

type TRenewDelegationTokenResp 

type TRenewDelegationTokenResp struct {
	Status *TStatus `thrift:"status,1,required" db:"status" json:"status"`
}

Attributes:

  • Status
var TCLIServiceRenewDelegationTokenResult_Success_DEFAULT *TRenewDelegationTokenResp

func NewTRenewDelegationTokenResp 

func NewTRenewDelegationTokenResp() *TRenewDelegationTokenResp

func (*TRenewDelegationTokenResp) Equals 

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

func (*TRenewDelegationTokenResp) GetStatus 

func (p *TRenewDelegationTokenResp) GetStatus() *TStatus

func (*TRenewDelegationTokenResp) IsSetStatus 

func (p *TRenewDelegationTokenResp) IsSetStatus() bool

func (*TRenewDelegationTokenResp) Read 

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

func (*TRenewDelegationTokenResp) ReadField1 

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

func (*TRenewDelegationTokenResp) String 

func (p *TRenewDelegationTokenResp) String() string

func (*TRenewDelegationTokenResp) Validate added in v1.5.0 

func (p *TRenewDelegationTokenResp) Validate() error

func (*TRenewDelegationTokenResp) Write 

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

type TRow 

type TRow struct {
	ColVals []*TColumnValue `thrift:"colVals,1,required" db:"colVals" json:"colVals"`
}

Attributes:

  • ColVals

func NewTRow 

func NewTRow() *TRow

func (*TRow) Equals 

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

func (*TRow) GetColVals 

func (p *TRow) GetColVals() []*TColumnValue

func (*TRow) Read 

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

func (*TRow) ReadField1 

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

func (*TRow) String 

func (p *TRow) String() string

func (*TRow) Validate added in v1.5.0 

func (p *TRow) Validate() error

func (*TRow) Write 

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

type TRowSet 

type TRowSet struct {
	StartRowOffset int64      `thrift:"startRowOffset,1,required" db:"startRowOffset" json:"startRowOffset"`
	Rows           []*TRow    `thrift:"rows,2,required" db:"rows" json:"rows"`
	Columns        []*TColumn `thrift:"columns,3" db:"columns" json:"columns,omitempty"`
	BinaryColumns  []byte     `thrift:"binaryColumns,4" db:"binaryColumns" json:"binaryColumns,omitempty"`
	ColumnCount    *int32     `thrift:"columnCount,5" db:"columnCount" json:"columnCount,omitempty"`
	// unused fields # 6 to 1280
	ArrowBatches []*TSparkArrowBatch      `thrift:"arrowBatches,1281" db:"arrowBatches" json:"arrowBatches,omitempty"`
	ResultLinks  []*TSparkArrowResultLink `thrift:"resultLinks,1282" db:"resultLinks" json:"resultLinks,omitempty"`
}

Attributes:

  • StartRowOffset
  • Rows
  • Columns
  • BinaryColumns
  • ColumnCount
  • ArrowBatches
  • ResultLinks
var TFetchResultsResp_Results_DEFAULT *TRowSet

func NewTRowSet 

func NewTRowSet() *TRowSet

func (*TRowSet) Equals 

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

func (*TRowSet) GetArrowBatches 

func (p *TRowSet) GetArrowBatches() []*TSparkArrowBatch

func (*TRowSet) GetBinaryColumns 

func (p *TRowSet) GetBinaryColumns() []byte

func (*TRowSet) GetColumnCount 

func (p *TRowSet) GetColumnCount() int32

func (*TRowSet) GetColumns 

func (p *TRowSet) GetColumns() []*TColumn
func (p *TRowSet) GetResultLinks() []*TSparkArrowResultLink

func (*TRowSet) GetRows 

func (p *TRowSet) GetRows() []*TRow

func (*TRowSet) GetStartRowOffset 

func (p *TRowSet) GetStartRowOffset() int64

func (*TRowSet) IsSetArrowBatches 

func (p *TRowSet) IsSetArrowBatches() bool

func (*TRowSet) IsSetBinaryColumns 

func (p *TRowSet) IsSetBinaryColumns() bool

func (*TRowSet) IsSetColumnCount 

func (p *TRowSet) IsSetColumnCount() bool

func (*TRowSet) IsSetColumns 

func (p *TRowSet) IsSetColumns() bool
func (p *TRowSet) IsSetResultLinks() bool

func (*TRowSet) Read 

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

func (*TRowSet) ReadField1 

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

func (*TRowSet) ReadField1281 

func (p *TRowSet) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TRowSet) ReadField1282 

func (p *TRowSet) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

func (*TRowSet) ReadField2 

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

func (*TRowSet) ReadField3 

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

func (*TRowSet) ReadField4 

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

func (*TRowSet) ReadField5 

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

func (*TRowSet) String 

func (p *TRowSet) String() string

func (*TRowSet) Validate added in v1.5.0 

func (p *TRowSet) Validate() error

func (*TRowSet) Write 

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

type TSessionHandle 

type TSessionHandle struct {
	SessionId *THandleIdentifier `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
}

Attributes:

  • SessionId
var TCancelDelegationTokenReq_SessionHandle_DEFAULT *TSessionHandle
var TCloseSessionReq_SessionHandle_DEFAULT *TSessionHandle
var TExecuteStatementReq_SessionHandle_DEFAULT *TSessionHandle
var TGetCatalogsReq_SessionHandle_DEFAULT *TSessionHandle
var TGetColumnsReq_SessionHandle_DEFAULT *TSessionHandle
var TGetCrossReferenceReq_SessionHandle_DEFAULT *TSessionHandle
var TGetDelegationTokenReq_SessionHandle_DEFAULT *TSessionHandle
var TGetFunctionsReq_SessionHandle_DEFAULT *TSessionHandle
var TGetInfoReq_SessionHandle_DEFAULT *TSessionHandle
var TGetPrimaryKeysReq_SessionHandle_DEFAULT *TSessionHandle
var TGetSchemasReq_SessionHandle_DEFAULT *TSessionHandle
var TGetTableTypesReq_SessionHandle_DEFAULT *TSessionHandle
var TGetTablesReq_SessionHandle_DEFAULT *TSessionHandle
var TGetTypeInfoReq_SessionHandle_DEFAULT *TSessionHandle
var TOpenSessionResp_SessionHandle_DEFAULT *TSessionHandle
var TRenewDelegationTokenReq_SessionHandle_DEFAULT *TSessionHandle

func NewTSessionHandle 

func NewTSessionHandle() *TSessionHandle

func (*TSessionHandle) Equals 

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

func (*TSessionHandle) GetSessionId 

func (p *TSessionHandle) GetSessionId() *THandleIdentifier

func (*TSessionHandle) IsSetSessionId 

func (p *TSessionHandle) IsSetSessionId() bool

func (*TSessionHandle) Read 

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

func (*TSessionHandle) ReadField1 

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

func (*TSessionHandle) String 

func (p *TSessionHandle) String() string

func (*TSessionHandle) Validate added in v1.5.0 

func (p *TSessionHandle) Validate() error

func (*TSessionHandle) Write 

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

type TSparkArrowBatch 

type TSparkArrowBatch struct {
	Batch    []byte `thrift:"batch,1,required" db:"batch" json:"batch"`
	RowCount int64  `thrift:"rowCount,2,required" db:"rowCount" json:"rowCount"`
}

Attributes:

  • Batch
  • RowCount

func NewTSparkArrowBatch 

func NewTSparkArrowBatch() *TSparkArrowBatch

func (*TSparkArrowBatch) Equals 

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

func (*TSparkArrowBatch) GetBatch 

func (p *TSparkArrowBatch) GetBatch() []byte

func (*TSparkArrowBatch) GetRowCount 

func (p *TSparkArrowBatch) GetRowCount() int64

func (*TSparkArrowBatch) Read 

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

func (*TSparkArrowBatch) ReadField1 

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

func (*TSparkArrowBatch) ReadField2 

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

func (*TSparkArrowBatch) String 

func (p *TSparkArrowBatch) String() string

func (*TSparkArrowBatch) Validate added in v1.5.0 

func (p *TSparkArrowBatch) Validate() error

func (*TSparkArrowBatch) Write 

func (p *TSparkArrowBatch) Write(ctx context.Context, oprot thrift.TProtocol) error
type TSparkArrowResultLink struct {
	FileLink       string            `thrift:"fileLink,1,required" db:"fileLink" json:"fileLink"`
	ExpiryTime     int64             `thrift:"expiryTime,2,required" db:"expiryTime" json:"expiryTime"`
	StartRowOffset int64             `thrift:"startRowOffset,3,required" db:"startRowOffset" json:"startRowOffset"`
	RowCount       int64             `thrift:"rowCount,4,required" db:"rowCount" json:"rowCount"`
	BytesNum       int64             `thrift:"bytesNum,5,required" db:"bytesNum" json:"bytesNum"`
	HttpHeaders    map[string]string `thrift:"httpHeaders,6" db:"httpHeaders" json:"httpHeaders,omitempty"`
}

Attributes:

  • FileLink
  • ExpiryTime
  • StartRowOffset
  • RowCount
  • BytesNum
  • HttpHeaders
func NewTSparkArrowResultLink() *TSparkArrowResultLink

func (*TSparkArrowResultLink) Equals 

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

func (*TSparkArrowResultLink) GetBytesNum 

func (p *TSparkArrowResultLink) GetBytesNum() int64

func (*TSparkArrowResultLink) GetExpiryTime 

func (p *TSparkArrowResultLink) GetExpiryTime() int64
func (p *TSparkArrowResultLink) GetFileLink() string

func (*TSparkArrowResultLink) GetHttpHeaders added in v1.5.0 

func (p *TSparkArrowResultLink) GetHttpHeaders() map[string]string

func (*TSparkArrowResultLink) GetRowCount 

func (p *TSparkArrowResultLink) GetRowCount() int64

func (*TSparkArrowResultLink) GetStartRowOffset 

func (p *TSparkArrowResultLink) GetStartRowOffset() int64

func (*TSparkArrowResultLink) IsSetHttpHeaders added in v1.5.0 

func (p *TSparkArrowResultLink) IsSetHttpHeaders() bool

func (*TSparkArrowResultLink) Read 

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

func (*TSparkArrowResultLink) ReadField1 

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

func (*TSparkArrowResultLink) ReadField2 

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

func (*TSparkArrowResultLink) ReadField3 

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

func (*TSparkArrowResultLink) ReadField4 

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

func (*TSparkArrowResultLink) ReadField5 

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

func (*TSparkArrowResultLink) ReadField6 added in v1.5.0 

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

func (*TSparkArrowResultLink) String 

func (p *TSparkArrowResultLink) String() string

func (*TSparkArrowResultLink) Validate added in v1.5.0 

func (p *TSparkArrowResultLink) Validate() error

func (*TSparkArrowResultLink) Write 

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

type TSparkArrowTypes 

type TSparkArrowTypes struct {
	TimestampAsArrow     *bool `thrift:"timestampAsArrow,1" db:"timestampAsArrow" json:"timestampAsArrow,omitempty"`
	DecimalAsArrow       *bool `thrift:"decimalAsArrow,2" db:"decimalAsArrow" json:"decimalAsArrow,omitempty"`
	ComplexTypesAsArrow  *bool `thrift:"complexTypesAsArrow,3" db:"complexTypesAsArrow" json:"complexTypesAsArrow,omitempty"`
	IntervalTypesAsArrow *bool `thrift:"intervalTypesAsArrow,4" db:"intervalTypesAsArrow" json:"intervalTypesAsArrow,omitempty"`
	NullTypeAsArrow      *bool `thrift:"nullTypeAsArrow,5" db:"nullTypeAsArrow" json:"nullTypeAsArrow,omitempty"`
}

Attributes:

  • TimestampAsArrow
  • DecimalAsArrow
  • ComplexTypesAsArrow
  • IntervalTypesAsArrow
  • NullTypeAsArrow
var TExecuteStatementReq_UseArrowNativeTypes_DEFAULT *TSparkArrowTypes

func NewTSparkArrowTypes 

func NewTSparkArrowTypes() *TSparkArrowTypes

func (*TSparkArrowTypes) Equals 

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

func (*TSparkArrowTypes) GetComplexTypesAsArrow 

func (p *TSparkArrowTypes) GetComplexTypesAsArrow() bool

func (*TSparkArrowTypes) GetDecimalAsArrow 

func (p *TSparkArrowTypes) GetDecimalAsArrow() bool

func (*TSparkArrowTypes) GetIntervalTypesAsArrow 

func (p *TSparkArrowTypes) GetIntervalTypesAsArrow() bool

func (*TSparkArrowTypes) GetNullTypeAsArrow added in v1.5.0 

func (p *TSparkArrowTypes) GetNullTypeAsArrow() bool

func (*TSparkArrowTypes) GetTimestampAsArrow 

func (p *TSparkArrowTypes) GetTimestampAsArrow() bool

func (*TSparkArrowTypes) IsSetComplexTypesAsArrow 

func (p *TSparkArrowTypes) IsSetComplexTypesAsArrow() bool

func (*TSparkArrowTypes) IsSetDecimalAsArrow 

func (p *TSparkArrowTypes) IsSetDecimalAsArrow() bool

func (*TSparkArrowTypes) IsSetIntervalTypesAsArrow 

func (p *TSparkArrowTypes) IsSetIntervalTypesAsArrow() bool

func (*TSparkArrowTypes) IsSetNullTypeAsArrow added in v1.5.0 

func (p *TSparkArrowTypes) IsSetNullTypeAsArrow() bool

func (*TSparkArrowTypes) IsSetTimestampAsArrow 

func (p *TSparkArrowTypes) IsSetTimestampAsArrow() bool

func (*TSparkArrowTypes) Read 

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

func (*TSparkArrowTypes) ReadField1 

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

func (*TSparkArrowTypes) ReadField2 

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

func (*TSparkArrowTypes) ReadField3 

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

func (*TSparkArrowTypes) ReadField4 

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

func (*TSparkArrowTypes) ReadField5 added in v1.5.0 

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

func (*TSparkArrowTypes) String 

func (p *TSparkArrowTypes) String() string

func (*TSparkArrowTypes) Validate added in v1.5.0 

func (p *TSparkArrowTypes) Validate() error

func (*TSparkArrowTypes) Write 

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

type TSparkDirectResults 

type TSparkDirectResults struct {
	OperationStatus   *TGetOperationStatusResp   `thrift:"operationStatus,1" db:"operationStatus" json:"operationStatus,omitempty"`
	ResultSetMetadata *TGetResultSetMetadataResp `thrift:"resultSetMetadata,2" db:"resultSetMetadata" json:"resultSetMetadata,omitempty"`
	ResultSet         *TFetchResultsResp         `thrift:"resultSet,3" db:"resultSet" json:"resultSet,omitempty"`
	CloseOperation    *TCloseOperationResp       `thrift:"closeOperation,4" db:"closeOperation" json:"closeOperation,omitempty"`
}

Attributes:

  • OperationStatus
  • ResultSetMetadata
  • ResultSet
  • CloseOperation
var TExecuteStatementResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetCatalogsResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetColumnsResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetCrossReferenceResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetFunctionsResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetPrimaryKeysResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetSchemasResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetTableTypesResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetTablesResp_DirectResults_DEFAULT *TSparkDirectResults
var TGetTypeInfoResp_DirectResults_DEFAULT *TSparkDirectResults

func NewTSparkDirectResults 

func NewTSparkDirectResults() *TSparkDirectResults

func (*TSparkDirectResults) Equals 

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

func (*TSparkDirectResults) GetCloseOperation 

func (p *TSparkDirectResults) GetCloseOperation() *TCloseOperationResp

func (*TSparkDirectResults) GetOperationStatus 

func (p *TSparkDirectResults) GetOperationStatus() *TGetOperationStatusResp

func (*TSparkDirectResults) GetResultSet 

func (p *TSparkDirectResults) GetResultSet() *TFetchResultsResp

func (*TSparkDirectResults) GetResultSetMetadata 

func (p *TSparkDirectResults) GetResultSetMetadata() *TGetResultSetMetadataResp

func (*TSparkDirectResults) IsSetCloseOperation 

func (p *TSparkDirectResults) IsSetCloseOperation() bool

func (*TSparkDirectResults) IsSetOperationStatus 

func (p *TSparkDirectResults) IsSetOperationStatus() bool

func (*TSparkDirectResults) IsSetResultSet 

func (p *TSparkDirectResults) IsSetResultSet() bool

func (*TSparkDirectResults) IsSetResultSetMetadata 

func (p *TSparkDirectResults) IsSetResultSetMetadata() bool

func (*TSparkDirectResults) Read 

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

func (*TSparkDirectResults) ReadField1 

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

func (*TSparkDirectResults) ReadField2 

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

func (*TSparkDirectResults) ReadField3 

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

func (*TSparkDirectResults) ReadField4 

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

func (*TSparkDirectResults) String 

func (p *TSparkDirectResults) String() string

func (*TSparkDirectResults) Validate added in v1.5.0 

func (p *TSparkDirectResults) Validate() error

func (*TSparkDirectResults) Write 

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

type TSparkGetDirectResults 

type TSparkGetDirectResults struct {
	MaxRows  int64  `thrift:"maxRows,1,required" db:"maxRows" json:"maxRows"`
	MaxBytes *int64 `thrift:"maxBytes,2" db:"maxBytes" json:"maxBytes,omitempty"`
}

Attributes:

  • MaxRows
  • MaxBytes
var TExecuteStatementReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetCatalogsReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetColumnsReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetCrossReferenceReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetFunctionsReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetPrimaryKeysReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetSchemasReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetTableTypesReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetTablesReq_GetDirectResults_DEFAULT *TSparkGetDirectResults
var TGetTypeInfoReq_GetDirectResults_DEFAULT *TSparkGetDirectResults

func NewTSparkGetDirectResults 

func NewTSparkGetDirectResults() *TSparkGetDirectResults

func (*TSparkGetDirectResults) Equals 

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

func (*TSparkGetDirectResults) GetMaxBytes 

func (p *TSparkGetDirectResults) GetMaxBytes() int64

func (*TSparkGetDirectResults) GetMaxRows 

func (p *TSparkGetDirectResults) GetMaxRows() int64

func (*TSparkGetDirectResults) IsSetMaxBytes 

func (p *TSparkGetDirectResults) IsSetMaxBytes() bool

func (*TSparkGetDirectResults) Read 

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

func (*TSparkGetDirectResults) ReadField1 

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

func (*TSparkGetDirectResults) ReadField2 

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

func (*TSparkGetDirectResults) String 

func (p *TSparkGetDirectResults) String() string

func (*TSparkGetDirectResults) Validate added in v1.5.0 

func (p *TSparkGetDirectResults) Validate() error

func (*TSparkGetDirectResults) Write 

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

type TSparkParameter added in v1.5.0 

type TSparkParameter struct {
	Ordinal   *int32                     `thrift:"ordinal,1" db:"ordinal" json:"ordinal,omitempty"`
	Name      *string                    `thrift:"name,2" db:"name" json:"name,omitempty"`
	Type      *string                    `thrift:"type,3" db:"type" json:"type,omitempty"`
	Value     *TSparkParameterValue      `thrift:"value,4" db:"value" json:"value,omitempty"`
	Arguments []*TSparkParameterValueArg `thrift:"arguments,5" db:"arguments" json:"arguments,omitempty"`
}

Attributes:

  • Ordinal
  • Name
  • Type
  • Value
  • Arguments

func NewTSparkParameter added in v1.5.0 

func NewTSparkParameter() *TSparkParameter

func (*TSparkParameter) Equals added in v1.5.0 

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

func (*TSparkParameter) GetArguments added in v1.7.1 

func (p *TSparkParameter) GetArguments() []*TSparkParameterValueArg

func (*TSparkParameter) GetName added in v1.5.0 

func (p *TSparkParameter) GetName() string

func (*TSparkParameter) GetOrdinal added in v1.5.0 

func (p *TSparkParameter) GetOrdinal() int32

func (*TSparkParameter) GetType added in v1.5.0 

func (p *TSparkParameter) GetType() string

func (*TSparkParameter) GetValue added in v1.5.0 

func (p *TSparkParameter) GetValue() *TSparkParameterValue

func (*TSparkParameter) IsSetArguments added in v1.7.1 

func (p *TSparkParameter) IsSetArguments() bool

func (*TSparkParameter) IsSetName added in v1.5.0 

func (p *TSparkParameter) IsSetName() bool

func (*TSparkParameter) IsSetOrdinal added in v1.5.0 

func (p *TSparkParameter) IsSetOrdinal() bool

func (*TSparkParameter) IsSetType added in v1.5.0 

func (p *TSparkParameter) IsSetType() bool

func (*TSparkParameter) IsSetValue added in v1.5.0 

func (p *TSparkParameter) IsSetValue() bool

func (*TSparkParameter) Read added in v1.5.0 

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

func (*TSparkParameter) ReadField1 added in v1.5.0 

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

func (*TSparkParameter) ReadField2 added in v1.5.0 

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

func (*TSparkParameter) ReadField3 added in v1.5.0 

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

func (*TSparkParameter) ReadField4 added in v1.5.0 

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

func (*TSparkParameter) ReadField5 added in v1.7.1 

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

func (*TSparkParameter) String added in v1.5.0 

func (p *TSparkParameter) String() string

func (*TSparkParameter) Validate added in v1.5.0 

func (p *TSparkParameter) Validate() error

func (*TSparkParameter) Write added in v1.5.0 

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

type TSparkParameterList added in v1.5.0 

type TSparkParameterList []*TSparkParameter

func TSparkParameterListPtr added in v1.5.0 

func TSparkParameterListPtr(v TSparkParameterList) *TSparkParameterList

type TSparkParameterValue added in v1.5.0 

type TSparkParameterValue struct {
	StringValue  *string  `thrift:"stringValue,1" db:"stringValue" json:"stringValue,omitempty"`
	DoubleValue  *float64 `thrift:"doubleValue,2" db:"doubleValue" json:"doubleValue,omitempty"`
	BooleanValue *bool    `thrift:"booleanValue,3" db:"booleanValue" json:"booleanValue,omitempty"`
}

Attributes:

  • StringValue
  • DoubleValue
  • BooleanValue
var TSparkParameter_Value_DEFAULT *TSparkParameterValue

func NewTSparkParameterValue added in v1.5.0 

func NewTSparkParameterValue() *TSparkParameterValue

func (*TSparkParameterValue) CountSetFieldsTSparkParameterValue added in v1.5.0 

func (p *TSparkParameterValue) CountSetFieldsTSparkParameterValue() int

func (*TSparkParameterValue) Equals added in v1.5.0 

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

func (*TSparkParameterValue) GetBooleanValue added in v1.5.0 

func (p *TSparkParameterValue) GetBooleanValue() bool

func (*TSparkParameterValue) GetDoubleValue added in v1.5.0 

func (p *TSparkParameterValue) GetDoubleValue() float64

func (*TSparkParameterValue) GetStringValue added in v1.5.0 

func (p *TSparkParameterValue) GetStringValue() string

func (*TSparkParameterValue) IsSetBooleanValue added in v1.5.0 

func (p *TSparkParameterValue) IsSetBooleanValue() bool

func (*TSparkParameterValue) IsSetDoubleValue added in v1.5.0 

func (p *TSparkParameterValue) IsSetDoubleValue() bool

func (*TSparkParameterValue) IsSetStringValue added in v1.5.0 

func (p *TSparkParameterValue) IsSetStringValue() bool

func (*TSparkParameterValue) Read added in v1.5.0 

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

func (*TSparkParameterValue) ReadField1 added in v1.5.0 

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

func (*TSparkParameterValue) ReadField2 added in v1.5.0 

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

func (*TSparkParameterValue) ReadField3 added in v1.5.0 

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

func (*TSparkParameterValue) String added in v1.5.0 

func (p *TSparkParameterValue) String() string

func (*TSparkParameterValue) Validate added in v1.5.0 

func (p *TSparkParameterValue) Validate() error

func (*TSparkParameterValue) Write added in v1.5.0 

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

type TSparkParameterValueArg added in v1.7.1 

type TSparkParameterValueArg struct {
	Type      *string                    `thrift:"type,1" db:"type" json:"type,omitempty"`
	Value     *string                    `thrift:"value,2" db:"value" json:"value,omitempty"`
	Arguments []*TSparkParameterValueArg `thrift:"arguments,3" db:"arguments" json:"arguments,omitempty"`
}

Attributes:

  • Type
  • Value
  • Arguments

func NewTSparkParameterValueArg added in v1.7.1 

func NewTSparkParameterValueArg() *TSparkParameterValueArg

func (*TSparkParameterValueArg) Equals added in v1.7.1 

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

func (*TSparkParameterValueArg) GetArguments added in v1.7.1 

func (p *TSparkParameterValueArg) GetArguments() []*TSparkParameterValueArg

func (*TSparkParameterValueArg) GetType added in v1.7.1 

func (p *TSparkParameterValueArg) GetType() string

func (*TSparkParameterValueArg) GetValue added in v1.7.1 

func (p *TSparkParameterValueArg) GetValue() string

func (*TSparkParameterValueArg) IsSetArguments added in v1.7.1 

func (p *TSparkParameterValueArg) IsSetArguments() bool

func (*TSparkParameterValueArg) IsSetType added in v1.7.1 

func (p *TSparkParameterValueArg) IsSetType() bool

func (*TSparkParameterValueArg) IsSetValue added in v1.7.1 

func (p *TSparkParameterValueArg) IsSetValue() bool

func (*TSparkParameterValueArg) Read added in v1.7.1 

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

func (*TSparkParameterValueArg) ReadField1 added in v1.7.1 

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

func (*TSparkParameterValueArg) ReadField2 added in v1.7.1 

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

func (*TSparkParameterValueArg) ReadField3 added in v1.7.1 

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

func (*TSparkParameterValueArg) String added in v1.7.1 

func (p *TSparkParameterValueArg) String() string

func (*TSparkParameterValueArg) Validate added in v1.7.1 

func (p *TSparkParameterValueArg) Validate() error

func (*TSparkParameterValueArg) Write added in v1.7.1 

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

type TSparkRowSetType 

type TSparkRowSetType int64
const (
	TSparkRowSetType_ARROW_BASED_SET  TSparkRowSetType = 0
	TSparkRowSetType_COLUMN_BASED_SET TSparkRowSetType = 1
	TSparkRowSetType_ROW_BASED_SET    TSparkRowSetType = 2
	TSparkRowSetType_URL_BASED_SET    TSparkRowSetType = 3
)
var TGetResultSetMetadataResp_ResultFormat_DEFAULT TSparkRowSetType

func TSparkRowSetTypeFromString 

func TSparkRowSetTypeFromString(s string) (TSparkRowSetType, error)

func TSparkRowSetTypePtr 

func TSparkRowSetTypePtr(v TSparkRowSetType) *TSparkRowSetType

func (TSparkRowSetType) MarshalText 

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

func (*TSparkRowSetType) Scan 

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

func (TSparkRowSetType) String 

func (p TSparkRowSetType) String() string

func (*TSparkRowSetType) UnmarshalText 

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

func (*TSparkRowSetType) Value 

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

type TStatementConf added in v1.5.0 

type TStatementConf struct {
	Sessionless       *bool             `thrift:"sessionless,1" db:"sessionless" json:"sessionless,omitempty"`
	InitialNamespace  *TNamespace       `thrift:"initialNamespace,2" db:"initialNamespace" json:"initialNamespace,omitempty"`
	ClientProtocol    *TProtocolVersion `thrift:"client_protocol,3" db:"client_protocol" json:"client_protocol,omitempty"`
	ClientProtocolI64 *int64            `thrift:"client_protocol_i64,4" db:"client_protocol_i64" json:"client_protocol_i64,omitempty"`
}

Attributes:

  • Sessionless
  • InitialNamespace
  • ClientProtocol
  • ClientProtocolI64
var TExecuteStatementReq_StatementConf_DEFAULT *TStatementConf

func NewTStatementConf added in v1.5.0 

func NewTStatementConf() *TStatementConf

func (*TStatementConf) Equals added in v1.5.0 

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

func (*TStatementConf) GetClientProtocol added in v1.5.0 

func (p *TStatementConf) GetClientProtocol() TProtocolVersion

func (*TStatementConf) GetClientProtocolI64 added in v1.5.0 

func (p *TStatementConf) GetClientProtocolI64() int64

func (*TStatementConf) GetInitialNamespace added in v1.5.0 

func (p *TStatementConf) GetInitialNamespace() *TNamespace

func (*TStatementConf) GetSessionless added in v1.5.0 

func (p *TStatementConf) GetSessionless() bool

func (*TStatementConf) IsSetClientProtocol added in v1.5.0 

func (p *TStatementConf) IsSetClientProtocol() bool

func (*TStatementConf) IsSetClientProtocolI64 added in v1.5.0 

func (p *TStatementConf) IsSetClientProtocolI64() bool

func (*TStatementConf) IsSetInitialNamespace added in v1.5.0 

func (p *TStatementConf) IsSetInitialNamespace() bool

func (*TStatementConf) IsSetSessionless added in v1.5.0 

func (p *TStatementConf) IsSetSessionless() bool

func (*TStatementConf) Read added in v1.5.0 

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

func (*TStatementConf) ReadField1 added in v1.5.0 

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

func (*TStatementConf) ReadField2 added in v1.5.0 

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

func (*TStatementConf) ReadField3 added in v1.5.0 

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

func (*TStatementConf) ReadField4 added in v1.5.0 

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

func (*TStatementConf) String added in v1.5.0 

func (p *TStatementConf) String() string

func (*TStatementConf) Validate added in v1.5.0 

func (p *TStatementConf) Validate() error

func (*TStatementConf) Write added in v1.5.0 

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

type TStatus 

type TStatus struct {
	StatusCode     TStatusCode `thrift:"statusCode,1,required" db:"statusCode" json:"statusCode"`
	InfoMessages   []string    `thrift:"infoMessages,2" db:"infoMessages" json:"infoMessages,omitempty"`
	SqlState       *string     `thrift:"sqlState,3" db:"sqlState" json:"sqlState,omitempty"`
	ErrorCode      *int32      `thrift:"errorCode,4" db:"errorCode" json:"errorCode,omitempty"`
	ErrorMessage   *string     `thrift:"errorMessage,5" db:"errorMessage" json:"errorMessage,omitempty"`
	DisplayMessage *string     `thrift:"displayMessage,6" db:"displayMessage" json:"displayMessage,omitempty"`
	// unused fields # 7 to 1280
	ErrorDetailsJson *string `thrift:"errorDetailsJson,1281" db:"errorDetailsJson" json:"errorDetailsJson,omitempty"`
}

Attributes:

  • StatusCode
  • InfoMessages
  • SqlState
  • ErrorCode
  • ErrorMessage
  • DisplayMessage
  • ErrorDetailsJson
var TCancelDelegationTokenResp_Status_DEFAULT *TStatus
var TCancelOperationResp_Status_DEFAULT *TStatus
var TCloseOperationResp_Status_DEFAULT *TStatus
var TCloseSessionResp_Status_DEFAULT *TStatus
var TExecuteStatementResp_Status_DEFAULT *TStatus
var TFetchResultsResp_Status_DEFAULT *TStatus
var TGetCatalogsResp_Status_DEFAULT *TStatus
var TGetColumnsResp_Status_DEFAULT *TStatus
var TGetCrossReferenceResp_Status_DEFAULT *TStatus
var TGetDelegationTokenResp_Status_DEFAULT *TStatus
var TGetFunctionsResp_Status_DEFAULT *TStatus
var TGetInfoResp_Status_DEFAULT *TStatus
var TGetOperationStatusResp_Status_DEFAULT *TStatus
var TGetPrimaryKeysResp_Status_DEFAULT *TStatus
var TGetResultSetMetadataResp_Status_DEFAULT *TStatus
var TGetSchemasResp_Status_DEFAULT *TStatus
var TGetTableTypesResp_Status_DEFAULT *TStatus
var TGetTablesResp_Status_DEFAULT *TStatus
var TGetTypeInfoResp_Status_DEFAULT *TStatus
var TOpenSessionResp_Status_DEFAULT *TStatus
var TRenewDelegationTokenResp_Status_DEFAULT *TStatus

func NewTStatus 

func NewTStatus() *TStatus

func (*TStatus) Equals 

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

func (*TStatus) GetDisplayMessage 

func (p *TStatus) GetDisplayMessage() string

func (*TStatus) GetErrorCode 

func (p *TStatus) GetErrorCode() int32

func (*TStatus) GetErrorDetailsJson added in v1.5.0 

func (p *TStatus) GetErrorDetailsJson() string

func (*TStatus) GetErrorMessage 

func (p *TStatus) GetErrorMessage() string

func (*TStatus) GetInfoMessages 

func (p *TStatus) GetInfoMessages() []string

func (*TStatus) GetSqlState 

func (p *TStatus) GetSqlState() string

func (*TStatus) GetStatusCode 

func (p *TStatus) GetStatusCode() TStatusCode

func (*TStatus) IsSetDisplayMessage 

func (p *TStatus) IsSetDisplayMessage() bool

func (*TStatus) IsSetErrorCode 

func (p *TStatus) IsSetErrorCode() bool

func (*TStatus) IsSetErrorDetailsJson added in v1.5.0 

func (p *TStatus) IsSetErrorDetailsJson() bool

func (*TStatus) IsSetErrorMessage 

func (p *TStatus) IsSetErrorMessage() bool

func (*TStatus) IsSetInfoMessages 

func (p *TStatus) IsSetInfoMessages() bool

func (*TStatus) IsSetSqlState 

func (p *TStatus) IsSetSqlState() bool

func (*TStatus) Read 

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

func (*TStatus) ReadField1 

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

func (*TStatus) ReadField1281 added in v1.5.0 

func (p *TStatus) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

func (*TStatus) ReadField2 

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

func (*TStatus) ReadField3 

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

func (*TStatus) ReadField4 

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

func (*TStatus) ReadField5 

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

func (*TStatus) ReadField6 

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

func (*TStatus) String 

func (p *TStatus) String() string

func (*TStatus) Validate added in v1.5.0 

func (p *TStatus) Validate() error

func (*TStatus) Write 

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

type TStatusCode 

type TStatusCode int64
const (
	TStatusCode_SUCCESS_STATUS           TStatusCode = 0
	TStatusCode_SUCCESS_WITH_INFO_STATUS TStatusCode = 1
	TStatusCode_STILL_EXECUTING_STATUS   TStatusCode = 2
	TStatusCode_ERROR_STATUS             TStatusCode = 3
	TStatusCode_INVALID_HANDLE_STATUS    TStatusCode = 4
)

func TStatusCodeFromString 

func TStatusCodeFromString(s string) (TStatusCode, error)

func TStatusCodePtr 

func TStatusCodePtr(v TStatusCode) *TStatusCode

func (TStatusCode) MarshalText 

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

func (*TStatusCode) Scan 

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

func (TStatusCode) String 

func (p TStatusCode) String() string

func (*TStatusCode) UnmarshalText 

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

func (*TStatusCode) Value 

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

type TStringColumn 

type TStringColumn struct {
	Values []string `thrift:"values,1,required" db:"values" json:"values"`
	Nulls  []byte   `thrift:"nulls,2,required" db:"nulls" json:"nulls"`
}

Attributes:

  • Values
  • Nulls
var TColumn_StringVal_DEFAULT *TStringColumn

func NewTStringColumn 

func NewTStringColumn() *TStringColumn

func (*TStringColumn) Equals 

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

func (*TStringColumn) GetNulls 

func (p *TStringColumn) GetNulls() []byte

func (*TStringColumn) GetValues 

func (p *TStringColumn) GetValues() []string

func (*TStringColumn) Read 

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

func (*TStringColumn) ReadField1 

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

func (*TStringColumn) ReadField2 

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

func (*TStringColumn) String 

func (p *TStringColumn) String() string

func (*TStringColumn) Validate added in v1.5.0 

func (p *TStringColumn) Validate() error

func (*TStringColumn) Write 

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

type TStringValue 

type TStringValue struct {
	Value *string `thrift:"value,1" db:"value" json:"value,omitempty"`
}

Attributes:

  • Value
var TColumnValue_StringVal_DEFAULT *TStringValue

func NewTStringValue 

func NewTStringValue() *TStringValue

func (*TStringValue) Equals 

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

func (*TStringValue) GetValue 

func (p *TStringValue) GetValue() string

func (*TStringValue) IsSetValue 

func (p *TStringValue) IsSetValue() bool

func (*TStringValue) Read 

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

func (*TStringValue) ReadField1 

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

func (*TStringValue) String 

func (p *TStringValue) String() string

func (*TStringValue) Validate added in v1.5.0 

func (p *TStringValue) Validate() error

func (*TStringValue) Write 

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

type TStructTypeEntry 

type TStructTypeEntry struct {
	NameToTypePtr map[string]TTypeEntryPtr `thrift:"nameToTypePtr,1,required" db:"nameToTypePtr" json:"nameToTypePtr"`
}

Attributes:

  • NameToTypePtr
var TTypeEntry_StructEntry_DEFAULT *TStructTypeEntry

func NewTStructTypeEntry 

func NewTStructTypeEntry() *TStructTypeEntry

func (*TStructTypeEntry) Equals 

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

func (*TStructTypeEntry) GetNameToTypePtr 

func (p *TStructTypeEntry) GetNameToTypePtr() map[string]TTypeEntryPtr

func (*TStructTypeEntry) Read 

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

func (*TStructTypeEntry) ReadField1 

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

func (*TStructTypeEntry) String 

func (p *TStructTypeEntry) String() string

func (*TStructTypeEntry) Validate added in v1.5.0 

func (p *TStructTypeEntry) Validate() error

func (*TStructTypeEntry) Write 

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

type TTableSchema 

type TTableSchema struct {
	Columns []*TColumnDesc `thrift:"columns,1,required" db:"columns" json:"columns"`
}

Attributes:

  • Columns
var TGetResultSetMetadataResp_Schema_DEFAULT *TTableSchema

func NewTTableSchema 

func NewTTableSchema() *TTableSchema

func (*TTableSchema) Equals 

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

func (*TTableSchema) GetColumns 

func (p *TTableSchema) GetColumns() []*TColumnDesc

func (*TTableSchema) Read 

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

func (*TTableSchema) ReadField1 

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

func (*TTableSchema) String 

func (p *TTableSchema) String() string

func (*TTableSchema) Validate added in v1.5.0 

func (p *TTableSchema) Validate() error

func (*TTableSchema) Write 

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

type TTypeDesc 

type TTypeDesc struct {
	Types []*TTypeEntry `thrift:"types,1,required" db:"types" json:"types"`
}

Attributes:

  • Types
var TColumnDesc_TypeDesc_DEFAULT *TTypeDesc

func NewTTypeDesc 

func NewTTypeDesc() *TTypeDesc

func (*TTypeDesc) Equals 

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

func (*TTypeDesc) GetTypes 

func (p *TTypeDesc) GetTypes() []*TTypeEntry

func (*TTypeDesc) Read 

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

func (*TTypeDesc) ReadField1 

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

func (*TTypeDesc) String 

func (p *TTypeDesc) String() string

func (*TTypeDesc) Validate added in v1.5.0 

func (p *TTypeDesc) Validate() error

func (*TTypeDesc) Write 

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

type TTypeEntry 

type TTypeEntry struct {
	PrimitiveEntry       *TPrimitiveTypeEntry   `thrift:"primitiveEntry,1" db:"primitiveEntry" json:"primitiveEntry,omitempty"`
	ArrayEntry           *TArrayTypeEntry       `thrift:"arrayEntry,2" db:"arrayEntry" json:"arrayEntry,omitempty"`
	MapEntry             *TMapTypeEntry         `thrift:"mapEntry,3" db:"mapEntry" json:"mapEntry,omitempty"`
	StructEntry          *TStructTypeEntry      `thrift:"structEntry,4" db:"structEntry" json:"structEntry,omitempty"`
	UnionEntry           *TUnionTypeEntry       `thrift:"unionEntry,5" db:"unionEntry" json:"unionEntry,omitempty"`
	UserDefinedTypeEntry *TUserDefinedTypeEntry `thrift:"userDefinedTypeEntry,6" db:"userDefinedTypeEntry" json:"userDefinedTypeEntry,omitempty"`
}

Attributes:

  • PrimitiveEntry
  • ArrayEntry
  • MapEntry
  • StructEntry
  • UnionEntry
  • UserDefinedTypeEntry

func NewTTypeEntry 

func NewTTypeEntry() *TTypeEntry

func (*TTypeEntry) CountSetFieldsTTypeEntry 

func (p *TTypeEntry) CountSetFieldsTTypeEntry() int

func (*TTypeEntry) Equals 

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

func (*TTypeEntry) GetArrayEntry 

func (p *TTypeEntry) GetArrayEntry() *TArrayTypeEntry

func (*TTypeEntry) GetMapEntry 

func (p *TTypeEntry) GetMapEntry() *TMapTypeEntry

func (*TTypeEntry) GetPrimitiveEntry 

func (p *TTypeEntry) GetPrimitiveEntry() *TPrimitiveTypeEntry

func (*TTypeEntry) GetStructEntry 

func (p *TTypeEntry) GetStructEntry() *TStructTypeEntry

func (*TTypeEntry) GetUnionEntry 

func (p *TTypeEntry) GetUnionEntry() *TUnionTypeEntry

func (*TTypeEntry) GetUserDefinedTypeEntry 

func (p *TTypeEntry) GetUserDefinedTypeEntry() *TUserDefinedTypeEntry

func (*TTypeEntry) IsSetArrayEntry 

func (p *TTypeEntry) IsSetArrayEntry() bool

func (*TTypeEntry) IsSetMapEntry 

func (p *TTypeEntry) IsSetMapEntry() bool

func (*TTypeEntry) IsSetPrimitiveEntry 

func (p *TTypeEntry) IsSetPrimitiveEntry() bool

func (*TTypeEntry) IsSetStructEntry 

func (p *TTypeEntry) IsSetStructEntry() bool

func (*TTypeEntry) IsSetUnionEntry 

func (p *TTypeEntry) IsSetUnionEntry() bool

func (*TTypeEntry) IsSetUserDefinedTypeEntry 

func (p *TTypeEntry) IsSetUserDefinedTypeEntry() bool

func (*TTypeEntry) Read 

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

func (*TTypeEntry) ReadField1 

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

func (*TTypeEntry) ReadField2 

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

func (*TTypeEntry) ReadField3 

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

func (*TTypeEntry) ReadField4 

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

func (*TTypeEntry) ReadField5 

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

func (*TTypeEntry) ReadField6 

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

func (*TTypeEntry) String 

func (p *TTypeEntry) String() string

func (*TTypeEntry) Validate added in v1.5.0 

func (p *TTypeEntry) Validate() error

func (*TTypeEntry) Write 

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

type TTypeEntryPtr 

type TTypeEntryPtr int32

func TTypeEntryPtrPtr 

func TTypeEntryPtrPtr(v TTypeEntryPtr) *TTypeEntryPtr

type TTypeId 

type TTypeId int64
const (
	TTypeId_BOOLEAN_TYPE             TTypeId = 0
	TTypeId_TINYINT_TYPE             TTypeId = 1
	TTypeId_SMALLINT_TYPE            TTypeId = 2
	TTypeId_INT_TYPE                 TTypeId = 3
	TTypeId_BIGINT_TYPE              TTypeId = 4
	TTypeId_FLOAT_TYPE               TTypeId = 5
	TTypeId_DOUBLE_TYPE              TTypeId = 6
	TTypeId_STRING_TYPE              TTypeId = 7
	TTypeId_TIMESTAMP_TYPE           TTypeId = 8
	TTypeId_BINARY_TYPE              TTypeId = 9
	TTypeId_ARRAY_TYPE               TTypeId = 10
	TTypeId_MAP_TYPE                 TTypeId = 11
	TTypeId_STRUCT_TYPE              TTypeId = 12
	TTypeId_UNION_TYPE               TTypeId = 13
	TTypeId_USER_DEFINED_TYPE        TTypeId = 14
	TTypeId_DECIMAL_TYPE             TTypeId = 15
	TTypeId_NULL_TYPE                TTypeId = 16
	TTypeId_DATE_TYPE                TTypeId = 17
	TTypeId_VARCHAR_TYPE             TTypeId = 18
	TTypeId_CHAR_TYPE                TTypeId = 19
	TTypeId_INTERVAL_YEAR_MONTH_TYPE TTypeId = 20
	TTypeId_INTERVAL_DAY_TIME_TYPE   TTypeId = 21
)

func TTypeIdFromString 

func TTypeIdFromString(s string) (TTypeId, error)

func TTypeIdPtr 

func TTypeIdPtr(v TTypeId) *TTypeId

func (TTypeId) MarshalText 

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

func (*TTypeId) Scan 

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

func (TTypeId) String 

func (p TTypeId) String() string

func (*TTypeId) UnmarshalText 

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

func (*TTypeId) Value 

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

type TTypeQualifierValue 

type TTypeQualifierValue struct {
	I32Value    *int32  `thrift:"i32Value,1" db:"i32Value" json:"i32Value,omitempty"`
	StringValue *string `thrift:"stringValue,2" db:"stringValue" json:"stringValue,omitempty"`
}

Attributes:

  • I32Value
  • StringValue

func NewTTypeQualifierValue 

func NewTTypeQualifierValue() *TTypeQualifierValue

func (*TTypeQualifierValue) CountSetFieldsTTypeQualifierValue 

func (p *TTypeQualifierValue) CountSetFieldsTTypeQualifierValue() int

func (*TTypeQualifierValue) Equals 

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

func (*TTypeQualifierValue) GetI32Value 

func (p *TTypeQualifierValue) GetI32Value() int32

func (*TTypeQualifierValue) GetStringValue 

func (p *TTypeQualifierValue) GetStringValue() string

func (*TTypeQualifierValue) IsSetI32Value 

func (p *TTypeQualifierValue) IsSetI32Value() bool

func (*TTypeQualifierValue) IsSetStringValue 

func (p *TTypeQualifierValue) IsSetStringValue() bool

func (*TTypeQualifierValue) Read 

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

func (*TTypeQualifierValue) ReadField1 

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

func (*TTypeQualifierValue) ReadField2 

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

func (*TTypeQualifierValue) String 

func (p *TTypeQualifierValue) String() string

func (*TTypeQualifierValue) Validate added in v1.5.0 

func (p *TTypeQualifierValue) Validate() error

func (*TTypeQualifierValue) Write 

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

type TTypeQualifiers 

type TTypeQualifiers struct {
	Qualifiers map[string]*TTypeQualifierValue `thrift:"qualifiers,1,required" db:"qualifiers" json:"qualifiers"`
}

Attributes:

  • Qualifiers
var TPrimitiveTypeEntry_TypeQualifiers_DEFAULT *TTypeQualifiers

func NewTTypeQualifiers 

func NewTTypeQualifiers() *TTypeQualifiers

func (*TTypeQualifiers) Equals 

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

func (*TTypeQualifiers) GetQualifiers 

func (p *TTypeQualifiers) GetQualifiers() map[string]*TTypeQualifierValue

func (*TTypeQualifiers) Read 

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

func (*TTypeQualifiers) ReadField1 

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

func (*TTypeQualifiers) String 

func (p *TTypeQualifiers) String() string

func (*TTypeQualifiers) Validate added in v1.5.0 

func (p *TTypeQualifiers) Validate() error

func (*TTypeQualifiers) Write 

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

type TUnionTypeEntry 

type TUnionTypeEntry struct {
	NameToTypePtr map[string]TTypeEntryPtr `thrift:"nameToTypePtr,1,required" db:"nameToTypePtr" json:"nameToTypePtr"`
}

Attributes:

  • NameToTypePtr
var TTypeEntry_UnionEntry_DEFAULT *TUnionTypeEntry

func NewTUnionTypeEntry 

func NewTUnionTypeEntry() *TUnionTypeEntry

func (*TUnionTypeEntry) Equals 

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

func (*TUnionTypeEntry) GetNameToTypePtr 

func (p *TUnionTypeEntry) GetNameToTypePtr() map[string]TTypeEntryPtr

func (*TUnionTypeEntry) Read 

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

func (*TUnionTypeEntry) ReadField1 

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

func (*TUnionTypeEntry) String 

func (p *TUnionTypeEntry) String() string

func (*TUnionTypeEntry) Validate added in v1.5.0 

func (p *TUnionTypeEntry) Validate() error

func (*TUnionTypeEntry) Write 

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

type TUserDefinedTypeEntry 

type TUserDefinedTypeEntry struct {
	TypeClassName string `thrift:"typeClassName,1,required" db:"typeClassName" json:"typeClassName"`
}

Attributes:

  • TypeClassName
var TTypeEntry_UserDefinedTypeEntry_DEFAULT *TUserDefinedTypeEntry

func NewTUserDefinedTypeEntry 

func NewTUserDefinedTypeEntry() *TUserDefinedTypeEntry

func (*TUserDefinedTypeEntry) Equals 

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

func (*TUserDefinedTypeEntry) GetTypeClassName 

func (p *TUserDefinedTypeEntry) GetTypeClassName() string

func (*TUserDefinedTypeEntry) Read 

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

func (*TUserDefinedTypeEntry) ReadField1 

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

func (*TUserDefinedTypeEntry) String 

func (p *TUserDefinedTypeEntry) String() string

func (*TUserDefinedTypeEntry) Validate added in v1.5.0 

func (p *TUserDefinedTypeEntry) Validate() error

func (*TUserDefinedTypeEntry) Write 

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

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.