cli_service

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 27, 2024

v1.6.0

Jul 31, 2024

v1.5.7

Jun 4, 2024

v1.5.6

May 28, 2024

v1.5.5

Apr 30, 2024

v1.5.4

Apr 10, 2024

v1.5.3

Jan 17, 2024

v1.5.2

Nov 17, 2023

v1.5.1

Oct 16, 2023

v1.5.0

Oct 2, 2023

Changes in this version

+ var TCancelOperationReq_ReplacedByNextAttempt_DEFAULT bool

+ var TDBSqlCloudResultFile_CompressedBytes_DEFAULT int64

+ var TDBSqlCloudResultFile_FileLink_DEFAULT string

+ var TDBSqlCloudResultFile_FilePath_DEFAULT string

+ var TDBSqlCloudResultFile_HttpHeaders_DEFAULT map[string]string

+ var TDBSqlCloudResultFile_LinkExpiryTime_DEFAULT int64

+ var TDBSqlCloudResultFile_RowCount_DEFAULT int64

+ var TDBSqlCloudResultFile_StartRowOffset_DEFAULT int64

+ var TDBSqlCloudResultFile_UncompressedBytes_DEFAULT int64

+ var TDBSqlConfValue_Value_DEFAULT string

+ var TDBSqlStatement_Statement_DEFAULT string

+ var TExecuteStatementReq_EnforceEmbeddedSchemaCorrectness_DEFAULT bool = false

+ var TExecuteStatementReq_EnforceResultPersistenceMode_DEFAULT bool

+ var TExecuteStatementReq_IdempotencyToken_DEFAULT string

+ var TExecuteStatementReq_MaxBytesPerBatch_DEFAULT int64

+ var TExecuteStatementReq_OriginatingClientIdentity_DEFAULT string

+ var TExecuteStatementReq_Parameters_DEFAULT []*TSparkParameter

+ var TExecuteStatementReq_PersistResultManifest_DEFAULT bool

+ var TExecuteStatementReq_PreferDriverOnlyUpload_DEFAULT bool

+ var TExecuteStatementReq_PreferSingleFileResult__DEFAULT bool

+ var TExecuteStatementReq_RequestValidation_DEFAULT []byte

+ var TExecuteStatementReq_ResultByteLimit_DEFAULT int64

+ var TExecuteStatementReq_ResultRetentionSeconds_DEFAULT int64

+ var TExecuteStatementReq_ResultRowLimit_DEFAULT int64

+ var TExecuteStatementReq_StatementList_DEFAULT []*TDBSqlStatement

+ var TExecuteStatementReq_ThrowErrorOnByteLimitTruncation_DEFAULT bool

+ var TExecuteStatementReq_TrimArrowBatchesToLimit_DEFAULT bool

+ var TExecuteStatementResp_IsServerless_DEFAULT bool

+ var TExecuteStatementResp_OperationHandles_DEFAULT []*TOperationHandle

+ var TExecuteStatementResp_RemoteResultCacheEnabled_DEFAULT bool

+ var TFetchResultsResp_ResponseValidation_DEFAULT []byte

+ var TGetOperationStatusResp_ErrorDetailsJson_DEFAULT string

+ var TGetOperationStatusResp_ResponseValidation_DEFAULT []byte

+ var TGetOperationStatusResp_StatementTimeout_DEFAULT int64

+ var TGetResultSetMetadataReq_IncludeCloudResultFiles_DEFAULT bool

+ var TGetResultSetMetadataResp_CacheLookupLatency_DEFAULT int64

+ var TGetResultSetMetadataResp_IsServerless_DEFAULT bool

+ var TGetResultSetMetadataResp_IsStagingOperation_DEFAULT bool

+ var TGetResultSetMetadataResp_ManifestFile_DEFAULT string

+ var TGetResultSetMetadataResp_RemoteCacheMissReason_DEFAULT string

+ var TGetResultSetMetadataResp_RemoteResultCacheEnabled_DEFAULT bool

+ var TGetResultSetMetadataResp_ResultByteLimit_DEFAULT int64

+ var TGetResultSetMetadataResp_ResultFiles_DEFAULT []*TDBSqlCloudResultFile

+ var TGetResultSetMetadataResp_TruncatedByThriftLimit_DEFAULT bool

+ var THandleIdentifier_ExecutionVersion_DEFAULT int16

+ var TRowSet_CloudFetchResults_DEFAULT []*TDBSqlCloudResultFile

+ var TSparkArrowResultLink_HttpHeaders_DEFAULT map[string]string

+ var TSparkArrowTypes_NullTypeAsArrow_DEFAULT bool

+ var TSparkParameterValue_BooleanValue_DEFAULT bool

+ var TSparkParameterValue_DoubleValue_DEFAULT float64

+ var TSparkParameterValue_StringValue_DEFAULT string

+ var TSparkParameter_Name_DEFAULT string

+ var TSparkParameter_Ordinal_DEFAULT int32

+ var TSparkParameter_Type_DEFAULT string

+ var TStatementConf_ClientProtocolI64_DEFAULT int64

+ var TStatementConf_Sessionless_DEFAULT bool

+ var TStatus_ErrorDetailsJson_DEFAULT string

+ var TStatus_ResponseValidation_DEFAULT []byte

type TArrayTypeEntry

+ func (p *TArrayTypeEntry) Validate() error

type TBinaryColumn

+ func (p *TBinaryColumn) Validate() error

type TBoolColumn

+ func (p *TBoolColumn) Validate() error

type TBoolValue

+ func (p *TBoolValue) Validate() error

type TByteColumn

+ func (p *TByteColumn) Validate() error

type TByteValue

+ func (p *TByteValue) Validate() error

type TCancelDelegationTokenReq

+ func (p *TCancelDelegationTokenReq) Validate() error

type TCancelDelegationTokenResp

+ func (p *TCancelDelegationTokenResp) Validate() error

type TCancelOperationReq

+ ReplacedByNextAttempt *bool

+ func (p *TCancelOperationReq) GetReplacedByNextAttempt() bool

+ func (p *TCancelOperationReq) IsSetReplacedByNextAttempt() bool

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

+ func (p *TCancelOperationReq) Validate() error

type TCancelOperationResp

+ func (p *TCancelOperationResp) Validate() error

type TCloseOperationReq

+ CloseReason TDBSqlCloseOperationReason

+ func (p *TCloseOperationReq) GetCloseReason() TDBSqlCloseOperationReason

+ func (p *TCloseOperationReq) IsSetCloseReason() bool

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

+ func (p *TCloseOperationReq) Validate() error

type TCloseOperationResp

+ func (p *TCloseOperationResp) Validate() error

type TCloseSessionReq

+ func (p *TCloseSessionReq) Validate() error

type TCloseSessionResp

+ func (p *TCloseSessionResp) Validate() error

+ type TCloudFetchDisabledReason int64

+ const TCloudFetchDisabledReason_ARROW_SUPPORT

+ const TCloudFetchDisabledReason_BLOCKLISTED_OPERATION

+ const TCloudFetchDisabledReason_CLOUD_FETCH_SUPPORT

+ const TCloudFetchDisabledReason_CUSTOMER_STORAGE_SUPPORT

+ const TCloudFetchDisabledReason_PROTOCOL_VERSION

+ const TCloudFetchDisabledReason_REGION_SUPPORT

+ const TCloudFetchDisabledReason_SMALL_RESULT_SIZE

+ const TCloudFetchDisabledReason_UNKNOWN

+ var TGetResultSetMetadataResp_ReasonForNoCloudFetch_DEFAULT TCloudFetchDisabledReason

+ func TCloudFetchDisabledReasonFromString(s string) (TCloudFetchDisabledReason, error)

+ func TCloudFetchDisabledReasonPtr(v TCloudFetchDisabledReason) *TCloudFetchDisabledReason

+ func (p *TCloudFetchDisabledReason) Scan(value interface{}) error

+ func (p *TCloudFetchDisabledReason) UnmarshalText(text []byte) error

+ func (p *TCloudFetchDisabledReason) Value() (driver.Value, error)

+ func (p TCloudFetchDisabledReason) MarshalText() ([]byte, error)

+ func (p TCloudFetchDisabledReason) String() string

type TColumn

+ func (p *TColumn) Validate() error

type TColumnDesc

+ func (p *TColumnDesc) Validate() error

type TColumnValue

+ func (p *TColumnValue) Validate() error

+ type TDBSqlArrowFormat struct

+ ArrowLayout *TDBSqlArrowLayout

+ CompressionCodec *TDBSqlCompressionCodec

+ var TDBSqlResultFormat_ArrowFormat_DEFAULT *TDBSqlArrowFormat

+ func NewTDBSqlArrowFormat() *TDBSqlArrowFormat

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

+ func (p *TDBSqlArrowFormat) GetArrowLayout() TDBSqlArrowLayout

+ func (p *TDBSqlArrowFormat) GetCompressionCodec() TDBSqlCompressionCodec

+ func (p *TDBSqlArrowFormat) IsSetArrowLayout() bool

+ func (p *TDBSqlArrowFormat) IsSetCompressionCodec() bool

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

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

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

+ func (p *TDBSqlArrowFormat) String() string

+ func (p *TDBSqlArrowFormat) Validate() error

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

+ type TDBSqlArrowLayout int64

+ const TDBSqlArrowLayout_ARROW_BATCH

+ const TDBSqlArrowLayout_ARROW_STREAMING

+ var TDBSqlArrowFormat_ArrowLayout_DEFAULT TDBSqlArrowLayout

+ func TDBSqlArrowLayoutFromString(s string) (TDBSqlArrowLayout, error)

+ func TDBSqlArrowLayoutPtr(v TDBSqlArrowLayout) *TDBSqlArrowLayout

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

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

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

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

+ func (p TDBSqlArrowLayout) String() string

+ type TDBSqlCloseOperationReason int64

+ const TDBSqlCloseOperationReason_COMMAND_INACTIVITY_TIMEOUT

+ const TDBSqlCloseOperationReason_NONE

+ var TCloseOperationReq_CloseReason_DEFAULT TDBSqlCloseOperationReason = 0

+ func TDBSqlCloseOperationReasonFromString(s string) (TDBSqlCloseOperationReason, error)

+ func TDBSqlCloseOperationReasonPtr(v TDBSqlCloseOperationReason) *TDBSqlCloseOperationReason

+ func (p *TDBSqlCloseOperationReason) Scan(value interface{}) error

+ func (p *TDBSqlCloseOperationReason) UnmarshalText(text []byte) error

+ func (p *TDBSqlCloseOperationReason) Value() (driver.Value, error)

+ func (p TDBSqlCloseOperationReason) MarshalText() ([]byte, error)

+ func (p TDBSqlCloseOperationReason) String() string

+ type TDBSqlCloudResultFile struct

+ CompressedBytes *int64

+ FileLink *string

+ FilePath *string

+ HttpHeaders map[string]string

+ LinkExpiryTime *int64

+ RowCount *int64

+ StartRowOffset *int64

+ UncompressedBytes *int64

+ func NewTDBSqlCloudResultFile() *TDBSqlCloudResultFile

+ func (p *TDBSqlCloudResultFile) Equals(other *TDBSqlCloudResultFile) bool

+ func (p *TDBSqlCloudResultFile) GetCompressedBytes() int64

+ func (p *TDBSqlCloudResultFile) GetFileLink() string

+ func (p *TDBSqlCloudResultFile) GetFilePath() string

+ func (p *TDBSqlCloudResultFile) GetHttpHeaders() map[string]string

+ func (p *TDBSqlCloudResultFile) GetLinkExpiryTime() int64

+ func (p *TDBSqlCloudResultFile) GetRowCount() int64

+ func (p *TDBSqlCloudResultFile) GetStartRowOffset() int64

+ func (p *TDBSqlCloudResultFile) GetUncompressedBytes() int64

+ func (p *TDBSqlCloudResultFile) IsSetCompressedBytes() bool

+ func (p *TDBSqlCloudResultFile) IsSetFileLink() bool

+ func (p *TDBSqlCloudResultFile) IsSetFilePath() bool

+ func (p *TDBSqlCloudResultFile) IsSetHttpHeaders() bool

+ func (p *TDBSqlCloudResultFile) IsSetLinkExpiryTime() bool

+ func (p *TDBSqlCloudResultFile) IsSetRowCount() bool

+ func (p *TDBSqlCloudResultFile) IsSetStartRowOffset() bool

+ func (p *TDBSqlCloudResultFile) IsSetUncompressedBytes() bool

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

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

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

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

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

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

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

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

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

+ func (p *TDBSqlCloudResultFile) String() string

+ func (p *TDBSqlCloudResultFile) Validate() error

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

+ type TDBSqlCompressionCodec int64

+ const TDBSqlCompressionCodec_LZ4_BLOCK

+ const TDBSqlCompressionCodec_LZ4_FRAME

+ const TDBSqlCompressionCodec_NONE

+ var TDBSqlArrowFormat_CompressionCodec_DEFAULT TDBSqlCompressionCodec

+ var TDBSqlCsvFormat_CompressionCodec_DEFAULT TDBSqlCompressionCodec

+ var TDBSqlJsonArrayFormat_CompressionCodec_DEFAULT TDBSqlCompressionCodec

+ func TDBSqlCompressionCodecFromString(s string) (TDBSqlCompressionCodec, error)

+ func TDBSqlCompressionCodecPtr(v TDBSqlCompressionCodec) *TDBSqlCompressionCodec

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

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

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

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

+ func (p TDBSqlCompressionCodec) String() string

+ type TDBSqlConfValue struct

+ Value *string

+ func NewTDBSqlConfValue() *TDBSqlConfValue

+ func (p *TDBSqlConfValue) Equals(other *TDBSqlConfValue) bool

+ func (p *TDBSqlConfValue) GetValue() string

+ func (p *TDBSqlConfValue) IsSetValue() bool

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

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

+ func (p *TDBSqlConfValue) String() string

+ func (p *TDBSqlConfValue) Validate() error

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

+ type TDBSqlCsvFormat struct

+ CompressionCodec *TDBSqlCompressionCodec

+ var TDBSqlResultFormat_CsvFormat_DEFAULT *TDBSqlCsvFormat

+ func NewTDBSqlCsvFormat() *TDBSqlCsvFormat

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

+ func (p *TDBSqlCsvFormat) GetCompressionCodec() TDBSqlCompressionCodec

+ func (p *TDBSqlCsvFormat) IsSetCompressionCodec() bool

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

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

+ func (p *TDBSqlCsvFormat) String() string

+ func (p *TDBSqlCsvFormat) Validate() error

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

+ type TDBSqlFetchDisposition int64

+ const TDBSqlFetchDisposition_DISPOSITION_EXTERNAL_LINKS

+ const TDBSqlFetchDisposition_DISPOSITION_INLINE

+ const TDBSqlFetchDisposition_DISPOSITION_INTERNAL_DBFS

+ const TDBSqlFetchDisposition_DISPOSITION_UNSPECIFIED

+ var TExecuteStatementReq_FetchDisposition_DEFAULT TDBSqlFetchDisposition

+ var TGetResultSetMetadataResp_FetchDisposition_DEFAULT TDBSqlFetchDisposition

+ func TDBSqlFetchDispositionFromString(s string) (TDBSqlFetchDisposition, error)

+ func TDBSqlFetchDispositionPtr(v TDBSqlFetchDisposition) *TDBSqlFetchDisposition

+ func (p *TDBSqlFetchDisposition) Scan(value interface{}) error

+ func (p *TDBSqlFetchDisposition) UnmarshalText(text []byte) error

+ func (p *TDBSqlFetchDisposition) Value() (driver.Value, error)

+ func (p TDBSqlFetchDisposition) MarshalText() ([]byte, error)

+ func (p TDBSqlFetchDisposition) String() string

+ type TDBSqlJsonArrayFormat struct

+ CompressionCodec *TDBSqlCompressionCodec

+ var TDBSqlResultFormat_JsonArrayFormat_DEFAULT *TDBSqlJsonArrayFormat

+ func NewTDBSqlJsonArrayFormat() *TDBSqlJsonArrayFormat

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

+ func (p *TDBSqlJsonArrayFormat) GetCompressionCodec() TDBSqlCompressionCodec

+ func (p *TDBSqlJsonArrayFormat) IsSetCompressionCodec() bool

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

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

+ func (p *TDBSqlJsonArrayFormat) String() string

+ func (p *TDBSqlJsonArrayFormat) Validate() error

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

+ type TDBSqlManifestFileFormat int64

+ const TDBSqlManifestFileFormat_THRIFT_GET_RESULT_SET_METADATA_RESP

+ var TGetResultSetMetadataResp_ManifestFileFormat_DEFAULT TDBSqlManifestFileFormat

+ func TDBSqlManifestFileFormatFromString(s string) (TDBSqlManifestFileFormat, error)

+ func TDBSqlManifestFileFormatPtr(v TDBSqlManifestFileFormat) *TDBSqlManifestFileFormat

+ func (p *TDBSqlManifestFileFormat) Scan(value interface{}) error

+ func (p *TDBSqlManifestFileFormat) UnmarshalText(text []byte) error

+ func (p *TDBSqlManifestFileFormat) Value() (driver.Value, error)

+ func (p TDBSqlManifestFileFormat) MarshalText() ([]byte, error)

+ func (p TDBSqlManifestFileFormat) String() string

+ type TDBSqlResultFormat struct

+ ArrowFormat *TDBSqlArrowFormat

+ CsvFormat *TDBSqlCsvFormat

+ JsonArrayFormat *TDBSqlJsonArrayFormat

+ var TExecuteStatementReq_ResultDataFormat_DEFAULT *TDBSqlResultFormat

+ var TGetResultSetMetadataResp_ResultDataFormat_DEFAULT *TDBSqlResultFormat

+ func NewTDBSqlResultFormat() *TDBSqlResultFormat

+ func (p *TDBSqlResultFormat) CountSetFieldsTDBSqlResultFormat() int

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

+ func (p *TDBSqlResultFormat) GetArrowFormat() *TDBSqlArrowFormat

+ func (p *TDBSqlResultFormat) GetCsvFormat() *TDBSqlCsvFormat

+ func (p *TDBSqlResultFormat) GetJsonArrayFormat() *TDBSqlJsonArrayFormat

+ func (p *TDBSqlResultFormat) IsSetArrowFormat() bool

+ func (p *TDBSqlResultFormat) IsSetCsvFormat() bool

+ func (p *TDBSqlResultFormat) IsSetJsonArrayFormat() bool

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

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

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

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

+ func (p *TDBSqlResultFormat) String() string

+ func (p *TDBSqlResultFormat) Validate() error

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

type TDBSqlSessionCapabilities

+ func (p *TDBSqlSessionCapabilities) Validate() error

type TDBSqlSessionConf

+ func (p *TDBSqlSessionConf) Validate() error

+ type TDBSqlStatement struct

+ Statement *string

+ func NewTDBSqlStatement() *TDBSqlStatement

+ func (p *TDBSqlStatement) Equals(other *TDBSqlStatement) bool

+ func (p *TDBSqlStatement) GetStatement() string

+ func (p *TDBSqlStatement) IsSetStatement() bool

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

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

+ func (p *TDBSqlStatement) String() string

+ func (p *TDBSqlStatement) Validate() error

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

type TDBSqlTempView

+ func (p *TDBSqlTempView) Validate() error

type TDoubleColumn

+ func (p *TDoubleColumn) Validate() error

type TDoubleValue

+ func (p *TDoubleValue) Validate() error

type TExecuteStatementReq

+ EnforceEmbeddedSchemaCorrectness bool

+ EnforceResultPersistenceMode *bool

+ FetchDisposition *TDBSqlFetchDisposition

+ IdempotencyToken *string

+ MaxBytesPerBatch *int64

+ OriginatingClientIdentity *string

+ Parameters []*TSparkParameter

+ PersistResultManifest *bool

+ PreferDriverOnlyUpload *bool

+ PreferSingleFileResult_ *bool

+ RequestValidation []byte

+ ResultByteLimit *int64

+ ResultDataFormat *TDBSqlResultFormat

+ ResultPersistenceMode *TResultPersistenceMode

+ ResultRetentionSeconds *int64

+ ResultRowLimit *int64

+ StatementConf *TStatementConf

+ StatementList []*TDBSqlStatement

+ ThrowErrorOnByteLimitTruncation *bool

+ TrimArrowBatchesToLimit *bool

+ func (p *TExecuteStatementReq) GetEnforceEmbeddedSchemaCorrectness() bool

+ func (p *TExecuteStatementReq) GetEnforceResultPersistenceMode() bool

+ func (p *TExecuteStatementReq) GetFetchDisposition() TDBSqlFetchDisposition

+ func (p *TExecuteStatementReq) GetIdempotencyToken() string

+ func (p *TExecuteStatementReq) GetMaxBytesPerBatch() int64

+ func (p *TExecuteStatementReq) GetOriginatingClientIdentity() string

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

+ func (p *TExecuteStatementReq) GetPersistResultManifest() bool

+ func (p *TExecuteStatementReq) GetPreferDriverOnlyUpload() bool

+ func (p *TExecuteStatementReq) GetPreferSingleFileResult_() bool

+ func (p *TExecuteStatementReq) GetRequestValidation() []byte

+ func (p *TExecuteStatementReq) GetResultByteLimit() int64

+ func (p *TExecuteStatementReq) GetResultDataFormat() *TDBSqlResultFormat

+ func (p *TExecuteStatementReq) GetResultPersistenceMode() TResultPersistenceMode

+ func (p *TExecuteStatementReq) GetResultRetentionSeconds() int64

+ func (p *TExecuteStatementReq) GetResultRowLimit() int64

+ func (p *TExecuteStatementReq) GetStatementConf() *TStatementConf

+ func (p *TExecuteStatementReq) GetStatementList() []*TDBSqlStatement

+ func (p *TExecuteStatementReq) GetThrowErrorOnByteLimitTruncation() bool

+ func (p *TExecuteStatementReq) GetTrimArrowBatchesToLimit() bool

+ func (p *TExecuteStatementReq) IsSetEnforceEmbeddedSchemaCorrectness() bool

+ func (p *TExecuteStatementReq) IsSetEnforceResultPersistenceMode() bool

+ func (p *TExecuteStatementReq) IsSetFetchDisposition() bool

+ func (p *TExecuteStatementReq) IsSetIdempotencyToken() bool

+ func (p *TExecuteStatementReq) IsSetMaxBytesPerBatch() bool

+ func (p *TExecuteStatementReq) IsSetOriginatingClientIdentity() bool

+ func (p *TExecuteStatementReq) IsSetParameters() bool

+ func (p *TExecuteStatementReq) IsSetPersistResultManifest() bool

+ func (p *TExecuteStatementReq) IsSetPreferDriverOnlyUpload() bool

+ func (p *TExecuteStatementReq) IsSetPreferSingleFileResult_() bool

+ func (p *TExecuteStatementReq) IsSetRequestValidation() bool

+ func (p *TExecuteStatementReq) IsSetResultByteLimit() bool

+ func (p *TExecuteStatementReq) IsSetResultDataFormat() bool

+ func (p *TExecuteStatementReq) IsSetResultPersistenceMode() bool

+ func (p *TExecuteStatementReq) IsSetResultRetentionSeconds() bool

+ func (p *TExecuteStatementReq) IsSetResultRowLimit() bool

+ func (p *TExecuteStatementReq) IsSetStatementConf() bool

+ func (p *TExecuteStatementReq) IsSetStatementList() bool

+ func (p *TExecuteStatementReq) IsSetThrowErrorOnByteLimitTruncation() bool

+ func (p *TExecuteStatementReq) IsSetTrimArrowBatchesToLimit() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TExecuteStatementReq) Validate() error

type TExecuteStatementResp

+ IsServerless *bool

+ OperationHandles []*TOperationHandle

+ RemoteResultCacheEnabled *bool

+ func (p *TExecuteStatementResp) GetIsServerless() bool

+ func (p *TExecuteStatementResp) GetOperationHandles() []*TOperationHandle

+ func (p *TExecuteStatementResp) GetRemoteResultCacheEnabled() bool

+ func (p *TExecuteStatementResp) IsSetIsServerless() bool

+ func (p *TExecuteStatementResp) IsSetOperationHandles() bool

+ func (p *TExecuteStatementResp) IsSetRemoteResultCacheEnabled() bool

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

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

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

+ func (p *TExecuteStatementResp) Validate() error

type TExpressionInfo

+ func (p *TExpressionInfo) Validate() error

type TFetchResultsReq

+ func (p *TFetchResultsReq) Validate() error

type TFetchResultsResp

+ ResponseValidation []byte

+ func (p *TFetchResultsResp) GetResponseValidation() []byte

+ func (p *TFetchResultsResp) IsSetResponseValidation() bool

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

+ func (p *TFetchResultsResp) Validate() error

type TGetCatalogsReq

+ func (p *TGetCatalogsReq) Validate() error

type TGetCatalogsResp

+ func (p *TGetCatalogsResp) Validate() error

type TGetColumnsReq

+ func (p *TGetColumnsReq) Validate() error

type TGetColumnsResp

+ func (p *TGetColumnsResp) Validate() error

type TGetCrossReferenceReq

+ func (p *TGetCrossReferenceReq) Validate() error

type TGetCrossReferenceResp

+ func (p *TGetCrossReferenceResp) Validate() error

type TGetDelegationTokenReq

+ func (p *TGetDelegationTokenReq) Validate() error

type TGetDelegationTokenResp

+ func (p *TGetDelegationTokenResp) Validate() error

type TGetFunctionsReq

+ func (p *TGetFunctionsReq) Validate() error

type TGetFunctionsResp

+ func (p *TGetFunctionsResp) Validate() error

type TGetInfoReq

+ func (p *TGetInfoReq) Validate() error

type TGetInfoResp

+ func (p *TGetInfoResp) Validate() error

type TGetInfoValue

+ func (p *TGetInfoValue) Validate() error

type TGetOperationStatusReq

+ func (p *TGetOperationStatusReq) Validate() error

type TGetOperationStatusResp

+ ErrorDetailsJson *string

+ IdempotencyType *TOperationIdempotencyType

+ ResponseValidation []byte

+ StatementTimeout *int64

+ StatementTimeoutLevel *TOperationTimeoutLevel

+ func (p *TGetOperationStatusResp) GetErrorDetailsJson() string

+ func (p *TGetOperationStatusResp) GetIdempotencyType() TOperationIdempotencyType

+ func (p *TGetOperationStatusResp) GetResponseValidation() []byte

+ func (p *TGetOperationStatusResp) GetStatementTimeout() int64

+ func (p *TGetOperationStatusResp) GetStatementTimeoutLevel() TOperationTimeoutLevel

+ func (p *TGetOperationStatusResp) IsSetErrorDetailsJson() bool

+ func (p *TGetOperationStatusResp) IsSetIdempotencyType() bool

+ func (p *TGetOperationStatusResp) IsSetResponseValidation() bool

+ func (p *TGetOperationStatusResp) IsSetStatementTimeout() bool

+ func (p *TGetOperationStatusResp) IsSetStatementTimeoutLevel() bool

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

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

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

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

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

+ func (p *TGetOperationStatusResp) Validate() error

type TGetPrimaryKeysReq

+ func (p *TGetPrimaryKeysReq) Validate() error

type TGetPrimaryKeysResp

+ func (p *TGetPrimaryKeysResp) Validate() error

type TGetResultSetMetadataReq

+ IncludeCloudResultFiles *bool

+ func (p *TGetResultSetMetadataReq) GetIncludeCloudResultFiles() bool

+ func (p *TGetResultSetMetadataReq) IsSetIncludeCloudResultFiles() bool

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

+ func (p *TGetResultSetMetadataReq) Validate() error

type TGetResultSetMetadataResp

+ CacheLookupLatency *int64

+ FetchDisposition *TDBSqlFetchDisposition

+ IsServerless *bool

+ IsStagingOperation *bool

+ ManifestFile *string

+ ManifestFileFormat *TDBSqlManifestFileFormat

+ ReasonForNoCloudFetch *TCloudFetchDisabledReason

+ RemoteCacheMissReason *string

+ RemoteResultCacheEnabled *bool

+ ResultByteLimit *int64

+ ResultDataFormat *TDBSqlResultFormat

+ ResultFiles []*TDBSqlCloudResultFile

+ TruncatedByThriftLimit *bool

+ func (p *TGetResultSetMetadataResp) GetCacheLookupLatency() int64

+ func (p *TGetResultSetMetadataResp) GetFetchDisposition() TDBSqlFetchDisposition

+ func (p *TGetResultSetMetadataResp) GetIsServerless() bool

+ func (p *TGetResultSetMetadataResp) GetIsStagingOperation() bool

+ func (p *TGetResultSetMetadataResp) GetManifestFile() string

+ func (p *TGetResultSetMetadataResp) GetManifestFileFormat() TDBSqlManifestFileFormat

+ func (p *TGetResultSetMetadataResp) GetReasonForNoCloudFetch() TCloudFetchDisabledReason

+ func (p *TGetResultSetMetadataResp) GetRemoteCacheMissReason() string

+ func (p *TGetResultSetMetadataResp) GetRemoteResultCacheEnabled() bool

+ func (p *TGetResultSetMetadataResp) GetResultByteLimit() int64

+ func (p *TGetResultSetMetadataResp) GetResultDataFormat() *TDBSqlResultFormat

+ func (p *TGetResultSetMetadataResp) GetResultFiles() []*TDBSqlCloudResultFile

+ func (p *TGetResultSetMetadataResp) GetTruncatedByThriftLimit() bool

+ func (p *TGetResultSetMetadataResp) IsSetCacheLookupLatency() bool

+ func (p *TGetResultSetMetadataResp) IsSetFetchDisposition() bool

+ func (p *TGetResultSetMetadataResp) IsSetIsServerless() bool

+ func (p *TGetResultSetMetadataResp) IsSetIsStagingOperation() bool

+ func (p *TGetResultSetMetadataResp) IsSetManifestFile() bool

+ func (p *TGetResultSetMetadataResp) IsSetManifestFileFormat() bool

+ func (p *TGetResultSetMetadataResp) IsSetReasonForNoCloudFetch() bool

+ func (p *TGetResultSetMetadataResp) IsSetRemoteCacheMissReason() bool

+ func (p *TGetResultSetMetadataResp) IsSetRemoteResultCacheEnabled() bool

+ func (p *TGetResultSetMetadataResp) IsSetResultByteLimit() bool

+ func (p *TGetResultSetMetadataResp) IsSetResultDataFormat() bool

+ func (p *TGetResultSetMetadataResp) IsSetResultFiles() bool

+ func (p *TGetResultSetMetadataResp) IsSetTruncatedByThriftLimit() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TGetResultSetMetadataResp) Validate() error

type TGetSchemasReq

+ func (p *TGetSchemasReq) Validate() error

type TGetSchemasResp

+ func (p *TGetSchemasResp) Validate() error

type TGetTableTypesReq

+ func (p *TGetTableTypesReq) Validate() error

type TGetTableTypesResp

+ func (p *TGetTableTypesResp) Validate() error

type TGetTablesReq

+ func (p *TGetTablesReq) Validate() error

type TGetTablesResp

+ func (p *TGetTablesResp) Validate() error

type TGetTypeInfoReq

+ func (p *TGetTypeInfoReq) Validate() error

type TGetTypeInfoResp

+ func (p *TGetTypeInfoResp) Validate() error

type THandleIdentifier

+ ExecutionVersion *int16

+ func (p *THandleIdentifier) GetExecutionVersion() int16

+ func (p *THandleIdentifier) IsSetExecutionVersion() bool

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

+ func (p *THandleIdentifier) Validate() error

type TI16Column

+ func (p *TI16Column) Validate() error

type TI16Value

+ func (p *TI16Value) Validate() error

type TI32Column

+ func (p *TI32Column) Validate() error

type TI32Value

+ func (p *TI32Value) Validate() error

type TI64Column

+ func (p *TI64Column) Validate() error

type TI64Value

+ func (p *TI64Value) Validate() error

type TMapTypeEntry

+ func (p *TMapTypeEntry) Validate() error

type TNamespace

+ var TStatementConf_InitialNamespace_DEFAULT *TNamespace

+ func (p *TNamespace) Validate() error

type TOpenSessionReq

+ func (p *TOpenSessionReq) Validate() error

type TOpenSessionResp

+ func (p *TOpenSessionResp) Validate() error

type TOperationHandle

+ func (p *TOperationHandle) Validate() error

type TOperationIdempotencyType

+ var TGetOperationStatusResp_IdempotencyType_DEFAULT TOperationIdempotencyType

+ type TOperationTimeoutLevel int64

+ const TOperationTimeoutLevel_CLUSTER

+ const TOperationTimeoutLevel_SESSION

+ var TGetOperationStatusResp_StatementTimeoutLevel_DEFAULT TOperationTimeoutLevel

+ func TOperationTimeoutLevelFromString(s string) (TOperationTimeoutLevel, error)

+ func TOperationTimeoutLevelPtr(v TOperationTimeoutLevel) *TOperationTimeoutLevel

+ func (p *TOperationTimeoutLevel) Scan(value interface{}) error

+ func (p *TOperationTimeoutLevel) UnmarshalText(text []byte) error

+ func (p *TOperationTimeoutLevel) Value() (driver.Value, error)

+ func (p TOperationTimeoutLevel) MarshalText() ([]byte, error)

+ func (p TOperationTimeoutLevel) String() string

type TPrimitiveTypeEntry

+ func (p *TPrimitiveTypeEntry) Validate() error

type TProgressUpdateResp

+ func (p *TProgressUpdateResp) Validate() error

type TProtocolVersion

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V7

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V8

+ var TStatementConf_ClientProtocol_DEFAULT TProtocolVersion

type TRenewDelegationTokenReq

+ func (p *TRenewDelegationTokenReq) Validate() error

type TRenewDelegationTokenResp

+ func (p *TRenewDelegationTokenResp) Validate() error

+ type TResultPersistenceMode int64

+ const TResultPersistenceMode_ALL_QUERY_RESULTS

+ const TResultPersistenceMode_ALL_RESULTS

+ const TResultPersistenceMode_ONLY_LARGE_RESULTS

+ var TExecuteStatementReq_ResultPersistenceMode_DEFAULT TResultPersistenceMode

+ func TResultPersistenceModeFromString(s string) (TResultPersistenceMode, error)

+ func TResultPersistenceModePtr(v TResultPersistenceMode) *TResultPersistenceMode

+ func (p *TResultPersistenceMode) Scan(value interface{}) error

+ func (p *TResultPersistenceMode) UnmarshalText(text []byte) error

+ func (p *TResultPersistenceMode) Value() (driver.Value, error)

+ func (p TResultPersistenceMode) MarshalText() ([]byte, error)

+ func (p TResultPersistenceMode) String() string

type TRow

+ func (p *TRow) Validate() error

type TRowSet

+ CloudFetchResults []*TDBSqlCloudResultFile

+ func (p *TRowSet) GetCloudFetchResults() []*TDBSqlCloudResultFile

+ func (p *TRowSet) IsSetCloudFetchResults() bool

+ func (p *TRowSet) ReadField3329(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) Validate() error

type TSessionHandle

+ func (p *TSessionHandle) Validate() error

type TSparkArrowBatch

+ func (p *TSparkArrowBatch) Validate() error

type TSparkArrowResultLink

+ HttpHeaders map[string]string

+ func (p *TSparkArrowResultLink) GetHttpHeaders() map[string]string

+ func (p *TSparkArrowResultLink) IsSetHttpHeaders() bool

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

+ func (p *TSparkArrowResultLink) Validate() error

type TSparkArrowTypes

+ NullTypeAsArrow *bool

+ func (p *TSparkArrowTypes) GetNullTypeAsArrow() bool

+ func (p *TSparkArrowTypes) IsSetNullTypeAsArrow() bool

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

+ func (p *TSparkArrowTypes) Validate() error

type TSparkDirectResults

+ func (p *TSparkDirectResults) Validate() error

type TSparkGetDirectResults

+ func (p *TSparkGetDirectResults) Validate() error

+ type TSparkParameter struct

+ Name *string

+ Ordinal *int32

+ Type *string

+ Value *TSparkParameterValue

+ func NewTSparkParameter() *TSparkParameter

+ func (p *TSparkParameter) Equals(other *TSparkParameter) bool

+ func (p *TSparkParameter) GetName() string

+ func (p *TSparkParameter) GetOrdinal() int32

+ func (p *TSparkParameter) GetType() string

+ func (p *TSparkParameter) GetValue() *TSparkParameterValue

+ func (p *TSparkParameter) IsSetName() bool

+ func (p *TSparkParameter) IsSetOrdinal() bool

+ func (p *TSparkParameter) IsSetType() bool

+ func (p *TSparkParameter) IsSetValue() bool

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

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

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

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

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

+ func (p *TSparkParameter) String() string

+ func (p *TSparkParameter) Validate() error

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

+ type TSparkParameterList []*TSparkParameter

+ func TSparkParameterListPtr(v TSparkParameterList) *TSparkParameterList

+ type TSparkParameterValue struct

+ BooleanValue *bool

+ DoubleValue *float64

+ StringValue *string

+ var TSparkParameter_Value_DEFAULT *TSparkParameterValue

+ func NewTSparkParameterValue() *TSparkParameterValue

+ func (p *TSparkParameterValue) CountSetFieldsTSparkParameterValue() int

+ func (p *TSparkParameterValue) Equals(other *TSparkParameterValue) bool

+ func (p *TSparkParameterValue) GetBooleanValue() bool

+ func (p *TSparkParameterValue) GetDoubleValue() float64

+ func (p *TSparkParameterValue) GetStringValue() string

+ func (p *TSparkParameterValue) IsSetBooleanValue() bool

+ func (p *TSparkParameterValue) IsSetDoubleValue() bool

+ func (p *TSparkParameterValue) IsSetStringValue() bool

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

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

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

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

+ func (p *TSparkParameterValue) String() string

+ func (p *TSparkParameterValue) Validate() error

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

+ type TStatementConf struct

+ ClientProtocol *TProtocolVersion

+ ClientProtocolI64 *int64

+ InitialNamespace *TNamespace

+ Sessionless *bool

+ var TExecuteStatementReq_StatementConf_DEFAULT *TStatementConf

+ func NewTStatementConf() *TStatementConf

+ func (p *TStatementConf) Equals(other *TStatementConf) bool

+ func (p *TStatementConf) GetClientProtocol() TProtocolVersion

+ func (p *TStatementConf) GetClientProtocolI64() int64

+ func (p *TStatementConf) GetInitialNamespace() *TNamespace

+ func (p *TStatementConf) GetSessionless() bool

+ func (p *TStatementConf) IsSetClientProtocol() bool

+ func (p *TStatementConf) IsSetClientProtocolI64() bool

+ func (p *TStatementConf) IsSetInitialNamespace() bool

+ func (p *TStatementConf) IsSetSessionless() bool

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

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

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

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

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

+ func (p *TStatementConf) String() string

+ func (p *TStatementConf) Validate() error

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

type TStatus

+ ErrorDetailsJson *string

+ ResponseValidation []byte

+ func (p *TStatus) GetErrorDetailsJson() string

+ func (p *TStatus) GetResponseValidation() []byte

+ func (p *TStatus) IsSetErrorDetailsJson() bool

+ func (p *TStatus) IsSetResponseValidation() bool

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

+ func (p *TStatus) ReadField3329(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) Validate() error

type TStringColumn

+ func (p *TStringColumn) Validate() error

type TStringValue

+ func (p *TStringValue) Validate() error

type TStructTypeEntry

+ func (p *TStructTypeEntry) Validate() error

type TTableSchema

+ func (p *TTableSchema) Validate() error

type TTypeDesc

+ func (p *TTypeDesc) Validate() error

type TTypeEntry

+ func (p *TTypeEntry) Validate() error

type TTypeQualifierValue

+ func (p *TTypeQualifierValue) Validate() error

type TTypeQualifiers

+ func (p *TTypeQualifiers) Validate() error

type TUnionTypeEntry

+ func (p *TUnionTypeEntry) Validate() error

type TUserDefinedTypeEntry

+ func (p *TUserDefinedTypeEntry) Validate() error

v1.4.0

Aug 8, 2023

v1.3.1

Jun 26, 2023

v1.3.0

Jun 7, 2023

v1.2.0

Apr 20, 2023

v1.1.0

Mar 7, 2023

v1.0.1

Jan 5, 2023

v1.0.0

Dec 20, 2022

v1.0.0-rc.1

Dec 19, 2022

v0

v0.2.2

Dec 12, 2022

v0.2.1

Dec 5, 2022

v0.2.0

Nov 19, 2022

Changes in this version

+ const CHARACTER_MAXIMUM_LENGTH

+ const PRECISION

+ const SCALE

+ var COLLECTION_TYPES []TTypeId

+ var COMPLEX_TYPES []TTypeId

+ var GoUnusedProtection__ int

+ var PRIMITIVE_TYPES []TTypeId

+ var TBoolValue_Value_DEFAULT bool

+ var TByteValue_Value_DEFAULT int8

+ var TCancelOperationReq_ExecutionVersion_DEFAULT int16

+ var TColumnDesc_Comment_DEFAULT string

+ var TDBSqlSessionCapabilities_SupportsMultipleCatalogs_DEFAULT bool

+ var TDBSqlSessionConf_Confs_DEFAULT map[string]string

+ var TDBSqlSessionConf_CurrentCatalog_DEFAULT string

+ var TDBSqlSessionConf_CurrentDatabase_DEFAULT string

+ var TDBSqlSessionConf_ExpressionsInfos_DEFAULT []*TExpressionInfo

+ var TDBSqlSessionConf_InternalConfs_DEFAULT map[string]string

+ var TDBSqlSessionConf_TempViews_DEFAULT []*TDBSqlTempView

+ var TDBSqlTempView_Name_DEFAULT string

+ var TDBSqlTempView_Properties_DEFAULT map[string]string

+ var TDBSqlTempView_SqlStatement_DEFAULT string

+ var TDBSqlTempView_ViewSchema_DEFAULT string

+ var TDoubleValue_Value_DEFAULT float64

+ var TExecuteStatementReq_CanDecompressLZ4Result__DEFAULT bool

+ var TExecuteStatementReq_CanDownloadResult__DEFAULT bool

+ var TExecuteStatementReq_CanReadArrowResult__DEFAULT bool

+ var TExecuteStatementReq_ConfOverlay_DEFAULT map[string]string

+ var TExecuteStatementReq_EstimatedCost_DEFAULT float64

+ var TExecuteStatementReq_ExecutionVersion_DEFAULT int16

+ var TExecuteStatementReq_MaxBytesPerFile_DEFAULT int64

+ var TExecuteStatementReq_QueryTimeout_DEFAULT int64 = 0

+ var TExecuteStatementReq_RejectHighCostQueries_DEFAULT bool

+ var TExecuteStatementReq_RunAsync_DEFAULT bool = false

+ var TExecuteStatementResp_CurrentClusterLoad_DEFAULT float64

+ var TExecuteStatementResp_ExecutionRejected_DEFAULT bool

+ var TExecuteStatementResp_MaxClusterCapacity_DEFAULT float64

+ var TExecuteStatementResp_QueryCost_DEFAULT float64

+ var TExpressionInfo_Arguments_DEFAULT string

+ var TExpressionInfo_ClassName_DEFAULT string

+ var TExpressionInfo_Db_DEFAULT string

+ var TExpressionInfo_Deprecated_DEFAULT string

+ var TExpressionInfo_Examples_DEFAULT string

+ var TExpressionInfo_Extended_DEFAULT string

+ var TExpressionInfo_Group_DEFAULT string

+ var TExpressionInfo_Name_DEFAULT string

+ var TExpressionInfo_Note_DEFAULT string

+ var TExpressionInfo_Since_DEFAULT string

+ var TExpressionInfo_Source_DEFAULT string

+ var TExpressionInfo_Usage_DEFAULT string

+ var TFetchResultsReq_FetchType_DEFAULT int16 = 0

+ var TFetchResultsReq_IncludeResultSetMetadata_DEFAULT bool

+ var TFetchResultsReq_MaxBytes_DEFAULT int64

+ var TFetchResultsReq_StartRowOffset_DEFAULT int64

+ var TFetchResultsResp_HasMoreRows_DEFAULT bool

+ var TGetCatalogsReq_RunAsync_DEFAULT bool = false

+ var TGetColumnsReq_RunAsync_DEFAULT bool = false

+ var TGetCrossReferenceReq_RunAsync_DEFAULT bool = false

+ var TGetDelegationTokenResp_DelegationToken_DEFAULT string

+ var TGetFunctionsReq_RunAsync_DEFAULT bool = false

+ var TGetInfoValue_BinaryValue_DEFAULT int32

+ var TGetInfoValue_IntegerBitmask_DEFAULT int32

+ var TGetInfoValue_IntegerFlag_DEFAULT int32

+ var TGetInfoValue_LenValue_DEFAULT int64

+ var TGetInfoValue_SmallIntValue_DEFAULT int16

+ var TGetInfoValue_StringValue_DEFAULT string

+ var TGetOperationStatusReq_GetProgressUpdate_DEFAULT bool

+ var TGetOperationStatusResp_DiagnosticInfo_DEFAULT string

+ var TGetOperationStatusResp_DisplayMessage_DEFAULT string

+ var TGetOperationStatusResp_ErrorCode_DEFAULT int32

+ var TGetOperationStatusResp_ErrorMessage_DEFAULT string

+ var TGetOperationStatusResp_HasResultSet_DEFAULT bool

+ var TGetOperationStatusResp_NumModifiedRows_DEFAULT int64

+ var TGetOperationStatusResp_OperationCompleted_DEFAULT int64

+ var TGetOperationStatusResp_OperationStarted_DEFAULT int64

+ var TGetOperationStatusResp_SqlState_DEFAULT string

+ var TGetOperationStatusResp_TaskStatus_DEFAULT string

+ var TGetPrimaryKeysReq_RunAsync_DEFAULT bool = false

+ var TGetResultSetMetadataResp_ArrowSchema_DEFAULT []byte

+ var TGetResultSetMetadataResp_CompressedBytes_DEFAULT int64

+ var TGetResultSetMetadataResp_Lz4Compressed_DEFAULT bool

+ var TGetResultSetMetadataResp_UncompressedBytes_DEFAULT int64

+ var TGetSchemasReq_RunAsync_DEFAULT bool = false

+ var TGetTableTypesReq_RunAsync_DEFAULT bool = false

+ var TGetTablesReq_RunAsync_DEFAULT bool = false

+ var TGetTablesReq_TableTypes_DEFAULT []string

+ var TGetTypeInfoReq_RunAsync_DEFAULT bool = false

+ var TI16Value_Value_DEFAULT int16

+ var TI32Value_Value_DEFAULT int32

+ var TI64Value_Value_DEFAULT int64

+ var TOpenSessionReq_CanUseMultipleCatalogs_DEFAULT bool

+ var TOpenSessionReq_ClientProtocolI64_DEFAULT int64

+ var TOpenSessionReq_Configuration_DEFAULT map[string]string

+ var TOpenSessionReq_ConnectionProperties_DEFAULT map[string]string

+ var TOpenSessionReq_GetInfos_DEFAULT []TGetInfoType

+ var TOpenSessionReq_Password_DEFAULT string

+ var TOpenSessionReq_Username_DEFAULT string

+ var TOpenSessionResp_CanUseMultipleCatalogs_DEFAULT bool

+ var TOpenSessionResp_Configuration_DEFAULT map[string]string

+ var TOpenSessionResp_GetInfos_DEFAULT []*TGetInfoValue

+ var TOperationHandle_ModifiedRowCount_DEFAULT float64

+ var TRowSet_ArrowBatches_DEFAULT []*TSparkArrowBatch

+ var TRowSet_BinaryColumns_DEFAULT []byte

+ var TRowSet_ColumnCount_DEFAULT int32

+ var TRowSet_Columns_DEFAULT []*TColumn

+ var TRowSet_ResultLinks_DEFAULT []*TSparkArrowResultLink

+ var TSparkArrowTypes_ComplexTypesAsArrow_DEFAULT bool

+ var TSparkArrowTypes_DecimalAsArrow_DEFAULT bool

+ var TSparkArrowTypes_IntervalTypesAsArrow_DEFAULT bool

+ var TSparkArrowTypes_TimestampAsArrow_DEFAULT bool

+ var TSparkGetDirectResults_MaxBytes_DEFAULT int64

+ var TStatus_DisplayMessage_DEFAULT string

+ var TStatus_ErrorCode_DEFAULT int32

+ var TStatus_ErrorMessage_DEFAULT string

+ var TStatus_InfoMessages_DEFAULT []string

+ var TStatus_SqlState_DEFAULT string

+ var TStringValue_Value_DEFAULT string

+ var TTypeQualifierValue_I32Value_DEFAULT int32

+ var TTypeQualifierValue_StringValue_DEFAULT string

+ var TYPE_NAMES map[TTypeId]string

+ type TArrayTypeEntry struct

+ ObjectTypePtr TTypeEntryPtr

+ var TTypeEntry_ArrayEntry_DEFAULT *TArrayTypeEntry

+ func NewTArrayTypeEntry() *TArrayTypeEntry

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

+ func (p *TArrayTypeEntry) GetObjectTypePtr() TTypeEntryPtr

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

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

+ func (p *TArrayTypeEntry) String() string

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

+ type TBinaryColumn struct

+ Nulls []byte

+ Values [][]byte

+ var TColumn_BinaryVal_DEFAULT *TBinaryColumn

+ func NewTBinaryColumn() *TBinaryColumn

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

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

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

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

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

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

+ func (p *TBinaryColumn) String() string

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

+ type TBoolColumn struct

+ Nulls []byte

+ Values []bool

+ var TColumn_BoolVal_DEFAULT *TBoolColumn

+ func NewTBoolColumn() *TBoolColumn

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

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

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

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

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

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

+ func (p *TBoolColumn) String() string

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

+ type TBoolValue struct

+ Value *bool

+ var TColumnValue_BoolVal_DEFAULT *TBoolValue

+ func NewTBoolValue() *TBoolValue

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

+ func (p *TBoolValue) GetValue() bool

+ func (p *TBoolValue) IsSetValue() bool

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

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

+ func (p *TBoolValue) String() string

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

+ type TByteColumn struct

+ Nulls []byte

+ Values []int8

+ var TColumn_ByteVal_DEFAULT *TByteColumn

+ func NewTByteColumn() *TByteColumn

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

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

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

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

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

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

+ func (p *TByteColumn) String() string

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

+ type TByteValue struct

+ Value *int8

+ var TColumnValue_ByteVal_DEFAULT *TByteValue

+ func NewTByteValue() *TByteValue

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

+ func (p *TByteValue) GetValue() int8

+ func (p *TByteValue) IsSetValue() bool

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

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

+ func (p *TByteValue) String() string

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

+ type TCLIService interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type TCLIServiceCancelDelegationTokenArgs struct

+ Req *TCancelDelegationTokenReq

+ func NewTCLIServiceCancelDelegationTokenArgs() *TCLIServiceCancelDelegationTokenArgs

+ func (p *TCLIServiceCancelDelegationTokenArgs) GetReq() *TCancelDelegationTokenReq

+ func (p *TCLIServiceCancelDelegationTokenArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceCancelDelegationTokenArgs) String() string

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

+ type TCLIServiceCancelDelegationTokenResult struct

+ Success *TCancelDelegationTokenResp

+ func NewTCLIServiceCancelDelegationTokenResult() *TCLIServiceCancelDelegationTokenResult

+ func (p *TCLIServiceCancelDelegationTokenResult) GetSuccess() *TCancelDelegationTokenResp

+ func (p *TCLIServiceCancelDelegationTokenResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceCancelDelegationTokenResult) String() string

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

+ type TCLIServiceCancelOperationArgs struct

+ Req *TCancelOperationReq

+ func NewTCLIServiceCancelOperationArgs() *TCLIServiceCancelOperationArgs

+ func (p *TCLIServiceCancelOperationArgs) GetReq() *TCancelOperationReq

+ func (p *TCLIServiceCancelOperationArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceCancelOperationArgs) String() string

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

+ type TCLIServiceCancelOperationResult struct

+ Success *TCancelOperationResp

+ func NewTCLIServiceCancelOperationResult() *TCLIServiceCancelOperationResult

+ func (p *TCLIServiceCancelOperationResult) GetSuccess() *TCancelOperationResp

+ func (p *TCLIServiceCancelOperationResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceCancelOperationResult) String() string

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

+ type TCLIServiceClient struct

+ func NewTCLIServiceClient(c thrift.TClient) *TCLIServiceClient

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type TCLIServiceCloseOperationArgs struct

+ Req *TCloseOperationReq

+ func NewTCLIServiceCloseOperationArgs() *TCLIServiceCloseOperationArgs

+ func (p *TCLIServiceCloseOperationArgs) GetReq() *TCloseOperationReq

+ func (p *TCLIServiceCloseOperationArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceCloseOperationArgs) String() string

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

+ type TCLIServiceCloseOperationResult struct

+ Success *TCloseOperationResp

+ func NewTCLIServiceCloseOperationResult() *TCLIServiceCloseOperationResult

+ func (p *TCLIServiceCloseOperationResult) GetSuccess() *TCloseOperationResp

+ func (p *TCLIServiceCloseOperationResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceCloseOperationResult) String() string

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

+ type TCLIServiceCloseSessionArgs struct

+ Req *TCloseSessionReq

+ func NewTCLIServiceCloseSessionArgs() *TCLIServiceCloseSessionArgs

+ func (p *TCLIServiceCloseSessionArgs) GetReq() *TCloseSessionReq

+ func (p *TCLIServiceCloseSessionArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceCloseSessionArgs) String() string

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

+ type TCLIServiceCloseSessionResult struct

+ Success *TCloseSessionResp

+ func NewTCLIServiceCloseSessionResult() *TCLIServiceCloseSessionResult

+ func (p *TCLIServiceCloseSessionResult) GetSuccess() *TCloseSessionResp

+ func (p *TCLIServiceCloseSessionResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceCloseSessionResult) String() string

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

+ type TCLIServiceExecuteStatementArgs struct

+ Req *TExecuteStatementReq

+ func NewTCLIServiceExecuteStatementArgs() *TCLIServiceExecuteStatementArgs

+ func (p *TCLIServiceExecuteStatementArgs) GetReq() *TExecuteStatementReq

+ func (p *TCLIServiceExecuteStatementArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceExecuteStatementArgs) String() string

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

+ type TCLIServiceExecuteStatementResult struct

+ Success *TExecuteStatementResp

+ func NewTCLIServiceExecuteStatementResult() *TCLIServiceExecuteStatementResult

+ func (p *TCLIServiceExecuteStatementResult) GetSuccess() *TExecuteStatementResp

+ func (p *TCLIServiceExecuteStatementResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceExecuteStatementResult) String() string

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

+ type TCLIServiceFetchResultsArgs struct

+ Req *TFetchResultsReq

+ func NewTCLIServiceFetchResultsArgs() *TCLIServiceFetchResultsArgs

+ func (p *TCLIServiceFetchResultsArgs) GetReq() *TFetchResultsReq

+ func (p *TCLIServiceFetchResultsArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceFetchResultsArgs) String() string

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

+ type TCLIServiceFetchResultsResult struct

+ Success *TFetchResultsResp

+ func NewTCLIServiceFetchResultsResult() *TCLIServiceFetchResultsResult

+ func (p *TCLIServiceFetchResultsResult) GetSuccess() *TFetchResultsResp

+ func (p *TCLIServiceFetchResultsResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceFetchResultsResult) String() string

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

+ type TCLIServiceGetCatalogsArgs struct

+ Req *TGetCatalogsReq

+ func NewTCLIServiceGetCatalogsArgs() *TCLIServiceGetCatalogsArgs

+ func (p *TCLIServiceGetCatalogsArgs) GetReq() *TGetCatalogsReq

+ func (p *TCLIServiceGetCatalogsArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetCatalogsArgs) String() string

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

+ type TCLIServiceGetCatalogsResult struct

+ Success *TGetCatalogsResp

+ func NewTCLIServiceGetCatalogsResult() *TCLIServiceGetCatalogsResult

+ func (p *TCLIServiceGetCatalogsResult) GetSuccess() *TGetCatalogsResp

+ func (p *TCLIServiceGetCatalogsResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetCatalogsResult) String() string

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

+ type TCLIServiceGetColumnsArgs struct

+ Req *TGetColumnsReq

+ func NewTCLIServiceGetColumnsArgs() *TCLIServiceGetColumnsArgs

+ func (p *TCLIServiceGetColumnsArgs) GetReq() *TGetColumnsReq

+ func (p *TCLIServiceGetColumnsArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetColumnsArgs) String() string

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

+ type TCLIServiceGetColumnsResult struct

+ Success *TGetColumnsResp

+ func NewTCLIServiceGetColumnsResult() *TCLIServiceGetColumnsResult

+ func (p *TCLIServiceGetColumnsResult) GetSuccess() *TGetColumnsResp

+ func (p *TCLIServiceGetColumnsResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetColumnsResult) String() string

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

+ type TCLIServiceGetCrossReferenceArgs struct

+ Req *TGetCrossReferenceReq

+ func NewTCLIServiceGetCrossReferenceArgs() *TCLIServiceGetCrossReferenceArgs

+ func (p *TCLIServiceGetCrossReferenceArgs) GetReq() *TGetCrossReferenceReq

+ func (p *TCLIServiceGetCrossReferenceArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetCrossReferenceArgs) String() string

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

+ type TCLIServiceGetCrossReferenceResult struct

+ Success *TGetCrossReferenceResp

+ func NewTCLIServiceGetCrossReferenceResult() *TCLIServiceGetCrossReferenceResult

+ func (p *TCLIServiceGetCrossReferenceResult) GetSuccess() *TGetCrossReferenceResp

+ func (p *TCLIServiceGetCrossReferenceResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetCrossReferenceResult) String() string

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

+ type TCLIServiceGetDelegationTokenArgs struct

+ Req *TGetDelegationTokenReq

+ func NewTCLIServiceGetDelegationTokenArgs() *TCLIServiceGetDelegationTokenArgs

+ func (p *TCLIServiceGetDelegationTokenArgs) GetReq() *TGetDelegationTokenReq

+ func (p *TCLIServiceGetDelegationTokenArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetDelegationTokenArgs) String() string

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

+ type TCLIServiceGetDelegationTokenResult struct

+ Success *TGetDelegationTokenResp

+ func NewTCLIServiceGetDelegationTokenResult() *TCLIServiceGetDelegationTokenResult

+ func (p *TCLIServiceGetDelegationTokenResult) GetSuccess() *TGetDelegationTokenResp

+ func (p *TCLIServiceGetDelegationTokenResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetDelegationTokenResult) String() string

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

+ type TCLIServiceGetFunctionsArgs struct

+ Req *TGetFunctionsReq

+ func NewTCLIServiceGetFunctionsArgs() *TCLIServiceGetFunctionsArgs

+ func (p *TCLIServiceGetFunctionsArgs) GetReq() *TGetFunctionsReq

+ func (p *TCLIServiceGetFunctionsArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetFunctionsArgs) String() string

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

+ type TCLIServiceGetFunctionsResult struct

+ Success *TGetFunctionsResp

+ func NewTCLIServiceGetFunctionsResult() *TCLIServiceGetFunctionsResult

+ func (p *TCLIServiceGetFunctionsResult) GetSuccess() *TGetFunctionsResp

+ func (p *TCLIServiceGetFunctionsResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetFunctionsResult) String() string

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

+ type TCLIServiceGetInfoArgs struct

+ Req *TGetInfoReq

+ func NewTCLIServiceGetInfoArgs() *TCLIServiceGetInfoArgs

+ func (p *TCLIServiceGetInfoArgs) GetReq() *TGetInfoReq

+ func (p *TCLIServiceGetInfoArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetInfoArgs) String() string

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

+ type TCLIServiceGetInfoResult struct

+ Success *TGetInfoResp

+ func NewTCLIServiceGetInfoResult() *TCLIServiceGetInfoResult

+ func (p *TCLIServiceGetInfoResult) GetSuccess() *TGetInfoResp

+ func (p *TCLIServiceGetInfoResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetInfoResult) String() string

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

+ type TCLIServiceGetOperationStatusArgs struct

+ Req *TGetOperationStatusReq

+ func NewTCLIServiceGetOperationStatusArgs() *TCLIServiceGetOperationStatusArgs

+ func (p *TCLIServiceGetOperationStatusArgs) GetReq() *TGetOperationStatusReq

+ func (p *TCLIServiceGetOperationStatusArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetOperationStatusArgs) String() string

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

+ type TCLIServiceGetOperationStatusResult struct

+ Success *TGetOperationStatusResp

+ func NewTCLIServiceGetOperationStatusResult() *TCLIServiceGetOperationStatusResult

+ func (p *TCLIServiceGetOperationStatusResult) GetSuccess() *TGetOperationStatusResp

+ func (p *TCLIServiceGetOperationStatusResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetOperationStatusResult) String() string

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

+ type TCLIServiceGetPrimaryKeysArgs struct

+ Req *TGetPrimaryKeysReq

+ func NewTCLIServiceGetPrimaryKeysArgs() *TCLIServiceGetPrimaryKeysArgs

+ func (p *TCLIServiceGetPrimaryKeysArgs) GetReq() *TGetPrimaryKeysReq

+ func (p *TCLIServiceGetPrimaryKeysArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetPrimaryKeysArgs) String() string

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

+ type TCLIServiceGetPrimaryKeysResult struct

+ Success *TGetPrimaryKeysResp

+ func NewTCLIServiceGetPrimaryKeysResult() *TCLIServiceGetPrimaryKeysResult

+ func (p *TCLIServiceGetPrimaryKeysResult) GetSuccess() *TGetPrimaryKeysResp

+ func (p *TCLIServiceGetPrimaryKeysResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetPrimaryKeysResult) String() string

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

+ type TCLIServiceGetResultSetMetadataArgs struct

+ Req *TGetResultSetMetadataReq

+ func NewTCLIServiceGetResultSetMetadataArgs() *TCLIServiceGetResultSetMetadataArgs

+ func (p *TCLIServiceGetResultSetMetadataArgs) GetReq() *TGetResultSetMetadataReq

+ func (p *TCLIServiceGetResultSetMetadataArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetResultSetMetadataArgs) String() string

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

+ type TCLIServiceGetResultSetMetadataResult struct

+ Success *TGetResultSetMetadataResp

+ func NewTCLIServiceGetResultSetMetadataResult() *TCLIServiceGetResultSetMetadataResult

+ func (p *TCLIServiceGetResultSetMetadataResult) GetSuccess() *TGetResultSetMetadataResp

+ func (p *TCLIServiceGetResultSetMetadataResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetResultSetMetadataResult) String() string

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

+ type TCLIServiceGetSchemasArgs struct

+ Req *TGetSchemasReq

+ func NewTCLIServiceGetSchemasArgs() *TCLIServiceGetSchemasArgs

+ func (p *TCLIServiceGetSchemasArgs) GetReq() *TGetSchemasReq

+ func (p *TCLIServiceGetSchemasArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetSchemasArgs) String() string

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

+ type TCLIServiceGetSchemasResult struct

+ Success *TGetSchemasResp

+ func NewTCLIServiceGetSchemasResult() *TCLIServiceGetSchemasResult

+ func (p *TCLIServiceGetSchemasResult) GetSuccess() *TGetSchemasResp

+ func (p *TCLIServiceGetSchemasResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetSchemasResult) String() string

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

+ type TCLIServiceGetTableTypesArgs struct

+ Req *TGetTableTypesReq

+ func NewTCLIServiceGetTableTypesArgs() *TCLIServiceGetTableTypesArgs

+ func (p *TCLIServiceGetTableTypesArgs) GetReq() *TGetTableTypesReq

+ func (p *TCLIServiceGetTableTypesArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetTableTypesArgs) String() string

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

+ type TCLIServiceGetTableTypesResult struct

+ Success *TGetTableTypesResp

+ func NewTCLIServiceGetTableTypesResult() *TCLIServiceGetTableTypesResult

+ func (p *TCLIServiceGetTableTypesResult) GetSuccess() *TGetTableTypesResp

+ func (p *TCLIServiceGetTableTypesResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetTableTypesResult) String() string

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

+ type TCLIServiceGetTablesArgs struct

+ Req *TGetTablesReq

+ func NewTCLIServiceGetTablesArgs() *TCLIServiceGetTablesArgs

+ func (p *TCLIServiceGetTablesArgs) GetReq() *TGetTablesReq

+ func (p *TCLIServiceGetTablesArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetTablesArgs) String() string

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

+ type TCLIServiceGetTablesResult struct

+ Success *TGetTablesResp

+ func NewTCLIServiceGetTablesResult() *TCLIServiceGetTablesResult

+ func (p *TCLIServiceGetTablesResult) GetSuccess() *TGetTablesResp

+ func (p *TCLIServiceGetTablesResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetTablesResult) String() string

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

+ type TCLIServiceGetTypeInfoArgs struct

+ Req *TGetTypeInfoReq

+ func NewTCLIServiceGetTypeInfoArgs() *TCLIServiceGetTypeInfoArgs

+ func (p *TCLIServiceGetTypeInfoArgs) GetReq() *TGetTypeInfoReq

+ func (p *TCLIServiceGetTypeInfoArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceGetTypeInfoArgs) String() string

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

+ type TCLIServiceGetTypeInfoResult struct

+ Success *TGetTypeInfoResp

+ func NewTCLIServiceGetTypeInfoResult() *TCLIServiceGetTypeInfoResult

+ func (p *TCLIServiceGetTypeInfoResult) GetSuccess() *TGetTypeInfoResp

+ func (p *TCLIServiceGetTypeInfoResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceGetTypeInfoResult) String() string

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

+ type TCLIServiceOpenSessionArgs struct

+ Req *TOpenSessionReq

+ func NewTCLIServiceOpenSessionArgs() *TCLIServiceOpenSessionArgs

+ func (p *TCLIServiceOpenSessionArgs) GetReq() *TOpenSessionReq

+ func (p *TCLIServiceOpenSessionArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceOpenSessionArgs) String() string

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

+ type TCLIServiceOpenSessionResult struct

+ Success *TOpenSessionResp

+ func NewTCLIServiceOpenSessionResult() *TCLIServiceOpenSessionResult

+ func (p *TCLIServiceOpenSessionResult) GetSuccess() *TOpenSessionResp

+ func (p *TCLIServiceOpenSessionResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceOpenSessionResult) String() string

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

+ type TCLIServiceProcessor struct

+ func NewTCLIServiceProcessor(handler TCLIService) *TCLIServiceProcessor

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

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

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

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

+ type TCLIServiceRenewDelegationTokenArgs struct

+ Req *TRenewDelegationTokenReq

+ func NewTCLIServiceRenewDelegationTokenArgs() *TCLIServiceRenewDelegationTokenArgs

+ func (p *TCLIServiceRenewDelegationTokenArgs) GetReq() *TRenewDelegationTokenReq

+ func (p *TCLIServiceRenewDelegationTokenArgs) IsSetReq() bool

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

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

+ func (p *TCLIServiceRenewDelegationTokenArgs) String() string

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

+ type TCLIServiceRenewDelegationTokenResult struct

+ Success *TRenewDelegationTokenResp

+ func NewTCLIServiceRenewDelegationTokenResult() *TCLIServiceRenewDelegationTokenResult

+ func (p *TCLIServiceRenewDelegationTokenResult) GetSuccess() *TRenewDelegationTokenResp

+ func (p *TCLIServiceRenewDelegationTokenResult) IsSetSuccess() bool

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

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

+ func (p *TCLIServiceRenewDelegationTokenResult) String() string

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

+ type TCacheLookupResult_ int64

+ const TCacheLookupResult__CACHE_INELIGIBLE

+ const TCacheLookupResult__CACHE_MISS

+ const TCacheLookupResult__LOCAL_CACHE_HIT

+ const TCacheLookupResult__REMOTE_CACHE_HIT

+ var TGetResultSetMetadataResp_CacheLookupResult__DEFAULT TCacheLookupResult_

+ func TCacheLookupResult_FromString(s string) (TCacheLookupResult_, error)

+ func TCacheLookupResult_Ptr(v TCacheLookupResult_) *TCacheLookupResult_

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

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

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

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

+ func (p TCacheLookupResult_) String() string

+ type TCancelDelegationTokenReq struct

+ DelegationToken string

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceCancelDelegationTokenArgs_Req_DEFAULT *TCancelDelegationTokenReq

+ func NewTCancelDelegationTokenReq() *TCancelDelegationTokenReq

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

+ func (p *TCancelDelegationTokenReq) GetDelegationToken() string

+ func (p *TCancelDelegationTokenReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TCancelDelegationTokenReq) GetSessionHandle() *TSessionHandle

+ func (p *TCancelDelegationTokenReq) IsSetSessionConf() bool

+ func (p *TCancelDelegationTokenReq) IsSetSessionHandle() bool

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

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

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

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

+ func (p *TCancelDelegationTokenReq) String() string

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

+ type TCancelDelegationTokenResp struct

+ Status *TStatus

+ var TCLIServiceCancelDelegationTokenResult_Success_DEFAULT *TCancelDelegationTokenResp

+ func NewTCancelDelegationTokenResp() *TCancelDelegationTokenResp

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

+ func (p *TCancelDelegationTokenResp) GetStatus() *TStatus

+ func (p *TCancelDelegationTokenResp) IsSetStatus() bool

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

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

+ func (p *TCancelDelegationTokenResp) String() string

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

+ type TCancelOperationReq struct

+ ExecutionVersion *int16

+ OperationHandle *TOperationHandle

+ var TCLIServiceCancelOperationArgs_Req_DEFAULT *TCancelOperationReq

+ func NewTCancelOperationReq() *TCancelOperationReq

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

+ func (p *TCancelOperationReq) GetExecutionVersion() int16

+ func (p *TCancelOperationReq) GetOperationHandle() *TOperationHandle

+ func (p *TCancelOperationReq) IsSetExecutionVersion() bool

+ func (p *TCancelOperationReq) IsSetOperationHandle() bool

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

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

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

+ func (p *TCancelOperationReq) String() string

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

+ type TCancelOperationResp struct

+ Status *TStatus

+ var TCLIServiceCancelOperationResult_Success_DEFAULT *TCancelOperationResp

+ func NewTCancelOperationResp() *TCancelOperationResp

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

+ func (p *TCancelOperationResp) GetStatus() *TStatus

+ func (p *TCancelOperationResp) IsSetStatus() bool

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

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

+ func (p *TCancelOperationResp) String() string

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

+ type TCloseOperationReq struct

+ OperationHandle *TOperationHandle

+ var TCLIServiceCloseOperationArgs_Req_DEFAULT *TCloseOperationReq

+ func NewTCloseOperationReq() *TCloseOperationReq

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

+ func (p *TCloseOperationReq) GetOperationHandle() *TOperationHandle

+ func (p *TCloseOperationReq) IsSetOperationHandle() bool

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

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

+ func (p *TCloseOperationReq) String() string

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

+ type TCloseOperationResp struct

+ Status *TStatus

+ var TCLIServiceCloseOperationResult_Success_DEFAULT *TCloseOperationResp

+ var TSparkDirectResults_CloseOperation_DEFAULT *TCloseOperationResp

+ func NewTCloseOperationResp() *TCloseOperationResp

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

+ func (p *TCloseOperationResp) GetStatus() *TStatus

+ func (p *TCloseOperationResp) IsSetStatus() bool

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

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

+ func (p *TCloseOperationResp) String() string

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

+ type TCloseSessionReq struct

+ SessionHandle *TSessionHandle

+ var TCLIServiceCloseSessionArgs_Req_DEFAULT *TCloseSessionReq

+ func NewTCloseSessionReq() *TCloseSessionReq

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

+ func (p *TCloseSessionReq) GetSessionHandle() *TSessionHandle

+ func (p *TCloseSessionReq) IsSetSessionHandle() bool

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

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

+ func (p *TCloseSessionReq) String() string

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

+ type TCloseSessionResp struct

+ Status *TStatus

+ var TCLIServiceCloseSessionResult_Success_DEFAULT *TCloseSessionResp

+ func NewTCloseSessionResp() *TCloseSessionResp

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

+ func (p *TCloseSessionResp) GetStatus() *TStatus

+ func (p *TCloseSessionResp) IsSetStatus() bool

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

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

+ func (p *TCloseSessionResp) String() string

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

+ type TColumn struct

+ BinaryVal *TBinaryColumn

+ BoolVal *TBoolColumn

+ ByteVal *TByteColumn

+ DoubleVal *TDoubleColumn

+ I16Val *TI16Column

+ I32Val *TI32Column

+ I64Val *TI64Column

+ StringVal *TStringColumn

+ func NewTColumn() *TColumn

+ func (p *TColumn) CountSetFieldsTColumn() int

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

+ func (p *TColumn) GetBinaryVal() *TBinaryColumn

+ func (p *TColumn) GetBoolVal() *TBoolColumn

+ func (p *TColumn) GetByteVal() *TByteColumn

+ func (p *TColumn) GetDoubleVal() *TDoubleColumn

+ func (p *TColumn) GetI16Val() *TI16Column

+ func (p *TColumn) GetI32Val() *TI32Column

+ func (p *TColumn) GetI64Val() *TI64Column

+ func (p *TColumn) GetStringVal() *TStringColumn

+ func (p *TColumn) IsSetBinaryVal() bool

+ func (p *TColumn) IsSetBoolVal() bool

+ func (p *TColumn) IsSetByteVal() bool

+ func (p *TColumn) IsSetDoubleVal() bool

+ func (p *TColumn) IsSetI16Val() bool

+ func (p *TColumn) IsSetI32Val() bool

+ func (p *TColumn) IsSetI64Val() bool

+ func (p *TColumn) IsSetStringVal() bool

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

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

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

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

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

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

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

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

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

+ func (p *TColumn) String() string

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

+ type TColumnDesc struct

+ ColumnName string

+ Comment *string

+ Position int32

+ TypeDesc *TTypeDesc

+ func NewTColumnDesc() *TColumnDesc

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

+ func (p *TColumnDesc) GetColumnName() string

+ func (p *TColumnDesc) GetComment() string

+ func (p *TColumnDesc) GetPosition() int32

+ func (p *TColumnDesc) GetTypeDesc() *TTypeDesc

+ func (p *TColumnDesc) IsSetComment() bool

+ func (p *TColumnDesc) IsSetTypeDesc() bool

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

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

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

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

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

+ func (p *TColumnDesc) String() string

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

+ type TColumnValue struct

+ BoolVal *TBoolValue

+ ByteVal *TByteValue

+ DoubleVal *TDoubleValue

+ I16Val *TI16Value

+ I32Val *TI32Value

+ I64Val *TI64Value

+ StringVal *TStringValue

+ func NewTColumnValue() *TColumnValue

+ func (p *TColumnValue) CountSetFieldsTColumnValue() int

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

+ func (p *TColumnValue) GetBoolVal() *TBoolValue

+ func (p *TColumnValue) GetByteVal() *TByteValue

+ func (p *TColumnValue) GetDoubleVal() *TDoubleValue

+ func (p *TColumnValue) GetI16Val() *TI16Value

+ func (p *TColumnValue) GetI32Val() *TI32Value

+ func (p *TColumnValue) GetI64Val() *TI64Value

+ func (p *TColumnValue) GetStringVal() *TStringValue

+ func (p *TColumnValue) IsSetBoolVal() bool

+ func (p *TColumnValue) IsSetByteVal() bool

+ func (p *TColumnValue) IsSetDoubleVal() bool

+ func (p *TColumnValue) IsSetI16Val() bool

+ func (p *TColumnValue) IsSetI32Val() bool

+ func (p *TColumnValue) IsSetI64Val() bool

+ func (p *TColumnValue) IsSetStringVal() bool

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

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

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

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

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

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

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

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

+ func (p *TColumnValue) String() string

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

+ type TDBSqlSessionCapabilities struct

+ SupportsMultipleCatalogs *bool

+ var TDBSqlSessionConf_SessionCapabilities_DEFAULT *TDBSqlSessionCapabilities

+ func NewTDBSqlSessionCapabilities() *TDBSqlSessionCapabilities

+ func (p *TDBSqlSessionCapabilities) Equals(other *TDBSqlSessionCapabilities) bool

+ func (p *TDBSqlSessionCapabilities) GetSupportsMultipleCatalogs() bool

+ func (p *TDBSqlSessionCapabilities) IsSetSupportsMultipleCatalogs() bool

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

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

+ func (p *TDBSqlSessionCapabilities) String() string

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

+ type TDBSqlSessionConf struct

+ Confs map[string]string

+ CurrentCatalog *string

+ CurrentDatabase *string

+ ExpressionsInfos []*TExpressionInfo

+ InternalConfs map[string]string

+ SessionCapabilities *TDBSqlSessionCapabilities

+ TempViews []*TDBSqlTempView

+ var TCancelDelegationTokenReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TExecuteStatementReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TExecuteStatementResp_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetCatalogsReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetColumnsReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetCrossReferenceReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetDelegationTokenReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetFunctionsReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetInfoReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetPrimaryKeysReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetSchemasReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetTableTypesReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetTablesReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TGetTypeInfoReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ var TRenewDelegationTokenReq_SessionConf_DEFAULT *TDBSqlSessionConf

+ func NewTDBSqlSessionConf() *TDBSqlSessionConf

+ func (p *TDBSqlSessionConf) Equals(other *TDBSqlSessionConf) bool

+ func (p *TDBSqlSessionConf) GetConfs() map[string]string

+ func (p *TDBSqlSessionConf) GetCurrentCatalog() string

+ func (p *TDBSqlSessionConf) GetCurrentDatabase() string

+ func (p *TDBSqlSessionConf) GetExpressionsInfos() []*TExpressionInfo

+ func (p *TDBSqlSessionConf) GetInternalConfs() map[string]string

+ func (p *TDBSqlSessionConf) GetSessionCapabilities() *TDBSqlSessionCapabilities

+ func (p *TDBSqlSessionConf) GetTempViews() []*TDBSqlTempView

+ func (p *TDBSqlSessionConf) IsSetConfs() bool

+ func (p *TDBSqlSessionConf) IsSetCurrentCatalog() bool

+ func (p *TDBSqlSessionConf) IsSetCurrentDatabase() bool

+ func (p *TDBSqlSessionConf) IsSetExpressionsInfos() bool

+ func (p *TDBSqlSessionConf) IsSetInternalConfs() bool

+ func (p *TDBSqlSessionConf) IsSetSessionCapabilities() bool

+ func (p *TDBSqlSessionConf) IsSetTempViews() bool

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

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

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

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

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

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

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

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

+ func (p *TDBSqlSessionConf) String() string

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

+ type TDBSqlTempView struct

+ Name *string

+ Properties map[string]string

+ SqlStatement *string

+ ViewSchema *string

+ func NewTDBSqlTempView() *TDBSqlTempView

+ func (p *TDBSqlTempView) Equals(other *TDBSqlTempView) bool

+ func (p *TDBSqlTempView) GetName() string

+ func (p *TDBSqlTempView) GetProperties() map[string]string

+ func (p *TDBSqlTempView) GetSqlStatement() string

+ func (p *TDBSqlTempView) GetViewSchema() string

+ func (p *TDBSqlTempView) IsSetName() bool

+ func (p *TDBSqlTempView) IsSetProperties() bool

+ func (p *TDBSqlTempView) IsSetSqlStatement() bool

+ func (p *TDBSqlTempView) IsSetViewSchema() bool

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

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

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

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

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

+ func (p *TDBSqlTempView) String() string

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

+ type TDoubleColumn struct

+ Nulls []byte

+ Values []float64

+ var TColumn_DoubleVal_DEFAULT *TDoubleColumn

+ func NewTDoubleColumn() *TDoubleColumn

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

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

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

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

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

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

+ func (p *TDoubleColumn) String() string

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

+ type TDoubleValue struct

+ Value *float64

+ var TColumnValue_DoubleVal_DEFAULT *TDoubleValue

+ func NewTDoubleValue() *TDoubleValue

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

+ func (p *TDoubleValue) GetValue() float64

+ func (p *TDoubleValue) IsSetValue() bool

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

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

+ func (p *TDoubleValue) String() string

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

+ type TExecuteStatementReq struct

+ CanDecompressLZ4Result_ *bool

+ CanDownloadResult_ *bool

+ CanReadArrowResult_ *bool

+ ConfOverlay map[string]string

+ EstimatedCost *float64

+ ExecutionVersion *int16

+ GetDirectResults *TSparkGetDirectResults

+ MaxBytesPerFile *int64

+ OperationId *THandleIdentifier

+ QueryTimeout int64

+ RejectHighCostQueries *bool

+ RunAsync bool

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ Statement string

+ UseArrowNativeTypes *TSparkArrowTypes

+ var TCLIServiceExecuteStatementArgs_Req_DEFAULT *TExecuteStatementReq

+ func NewTExecuteStatementReq() *TExecuteStatementReq

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

+ func (p *TExecuteStatementReq) GetCanDecompressLZ4Result_() bool

+ func (p *TExecuteStatementReq) GetCanDownloadResult_() bool

+ func (p *TExecuteStatementReq) GetCanReadArrowResult_() bool

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

+ func (p *TExecuteStatementReq) GetEstimatedCost() float64

+ func (p *TExecuteStatementReq) GetExecutionVersion() int16

+ func (p *TExecuteStatementReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TExecuteStatementReq) GetMaxBytesPerFile() int64

+ func (p *TExecuteStatementReq) GetOperationId() *THandleIdentifier

+ func (p *TExecuteStatementReq) GetQueryTimeout() int64

+ func (p *TExecuteStatementReq) GetRejectHighCostQueries() bool

+ func (p *TExecuteStatementReq) GetRunAsync() bool

+ func (p *TExecuteStatementReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TExecuteStatementReq) GetSessionHandle() *TSessionHandle

+ func (p *TExecuteStatementReq) GetStatement() string

+ func (p *TExecuteStatementReq) GetUseArrowNativeTypes() *TSparkArrowTypes

+ func (p *TExecuteStatementReq) IsSetCanDecompressLZ4Result_() bool

+ func (p *TExecuteStatementReq) IsSetCanDownloadResult_() bool

+ func (p *TExecuteStatementReq) IsSetCanReadArrowResult_() bool

+ func (p *TExecuteStatementReq) IsSetConfOverlay() bool

+ func (p *TExecuteStatementReq) IsSetEstimatedCost() bool

+ func (p *TExecuteStatementReq) IsSetExecutionVersion() bool

+ func (p *TExecuteStatementReq) IsSetGetDirectResults() bool

+ func (p *TExecuteStatementReq) IsSetMaxBytesPerFile() bool

+ func (p *TExecuteStatementReq) IsSetOperationId() bool

+ func (p *TExecuteStatementReq) IsSetQueryTimeout() bool

+ func (p *TExecuteStatementReq) IsSetRejectHighCostQueries() bool

+ func (p *TExecuteStatementReq) IsSetRunAsync() bool

+ func (p *TExecuteStatementReq) IsSetSessionConf() bool

+ func (p *TExecuteStatementReq) IsSetSessionHandle() bool

+ func (p *TExecuteStatementReq) IsSetUseArrowNativeTypes() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TExecuteStatementReq) String() string

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

+ type TExecuteStatementResp struct

+ CurrentClusterLoad *float64

+ DirectResults *TSparkDirectResults

+ ExecutionRejected *bool

+ IdempotencyType *TOperationIdempotencyType

+ MaxClusterCapacity *float64

+ OperationHandle *TOperationHandle

+ QueryCost *float64

+ SessionConf *TDBSqlSessionConf

+ Status *TStatus

+ var TCLIServiceExecuteStatementResult_Success_DEFAULT *TExecuteStatementResp

+ func NewTExecuteStatementResp() *TExecuteStatementResp

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

+ func (p *TExecuteStatementResp) GetCurrentClusterLoad() float64

+ func (p *TExecuteStatementResp) GetDirectResults() *TSparkDirectResults

+ func (p *TExecuteStatementResp) GetExecutionRejected() bool

+ func (p *TExecuteStatementResp) GetIdempotencyType() TOperationIdempotencyType

+ func (p *TExecuteStatementResp) GetMaxClusterCapacity() float64

+ func (p *TExecuteStatementResp) GetOperationHandle() *TOperationHandle

+ func (p *TExecuteStatementResp) GetQueryCost() float64

+ func (p *TExecuteStatementResp) GetSessionConf() *TDBSqlSessionConf

+ func (p *TExecuteStatementResp) GetStatus() *TStatus

+ func (p *TExecuteStatementResp) IsSetCurrentClusterLoad() bool

+ func (p *TExecuteStatementResp) IsSetDirectResults() bool

+ func (p *TExecuteStatementResp) IsSetExecutionRejected() bool

+ func (p *TExecuteStatementResp) IsSetIdempotencyType() bool

+ func (p *TExecuteStatementResp) IsSetMaxClusterCapacity() bool

+ func (p *TExecuteStatementResp) IsSetOperationHandle() bool

+ func (p *TExecuteStatementResp) IsSetQueryCost() bool

+ func (p *TExecuteStatementResp) IsSetSessionConf() bool

+ func (p *TExecuteStatementResp) IsSetStatus() bool

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

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

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

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

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

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

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

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

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

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

+ func (p *TExecuteStatementResp) String() string

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

+ type TExpressionInfo struct

+ Arguments *string

+ ClassName *string

+ Db *string

+ Deprecated *string

+ Examples *string

+ Extended *string

+ Group *string

+ Name *string

+ Note *string

+ Since *string

+ Source *string

+ Usage *string

+ func NewTExpressionInfo() *TExpressionInfo

+ func (p *TExpressionInfo) Equals(other *TExpressionInfo) bool

+ func (p *TExpressionInfo) GetArguments() string

+ func (p *TExpressionInfo) GetClassName() string

+ func (p *TExpressionInfo) GetDb() string

+ func (p *TExpressionInfo) GetDeprecated() string

+ func (p *TExpressionInfo) GetExamples() string

+ func (p *TExpressionInfo) GetExtended() string

+ func (p *TExpressionInfo) GetGroup() string

+ func (p *TExpressionInfo) GetName() string

+ func (p *TExpressionInfo) GetNote() string

+ func (p *TExpressionInfo) GetSince() string

+ func (p *TExpressionInfo) GetSource() string

+ func (p *TExpressionInfo) GetUsage() string

+ func (p *TExpressionInfo) IsSetArguments() bool

+ func (p *TExpressionInfo) IsSetClassName() bool

+ func (p *TExpressionInfo) IsSetDb() bool

+ func (p *TExpressionInfo) IsSetDeprecated() bool

+ func (p *TExpressionInfo) IsSetExamples() bool

+ func (p *TExpressionInfo) IsSetExtended() bool

+ func (p *TExpressionInfo) IsSetGroup() bool

+ func (p *TExpressionInfo) IsSetName() bool

+ func (p *TExpressionInfo) IsSetNote() bool

+ func (p *TExpressionInfo) IsSetSince() bool

+ func (p *TExpressionInfo) IsSetSource() bool

+ func (p *TExpressionInfo) IsSetUsage() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TExpressionInfo) String() string

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

+ type TFetchOrientation int64

+ const TFetchOrientation_FETCH_ABSOLUTE

+ const TFetchOrientation_FETCH_FIRST

+ const TFetchOrientation_FETCH_LAST

+ const TFetchOrientation_FETCH_NEXT

+ const TFetchOrientation_FETCH_PRIOR

+ const TFetchOrientation_FETCH_RELATIVE

+ func TFetchOrientationFromString(s string) (TFetchOrientation, error)

+ func TFetchOrientationPtr(v TFetchOrientation) *TFetchOrientation

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

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

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

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

+ func (p TFetchOrientation) String() string

+ type TFetchResultsReq struct

+ FetchType int16

+ IncludeResultSetMetadata *bool

+ MaxBytes *int64

+ MaxRows int64

+ OperationHandle *TOperationHandle

+ Orientation TFetchOrientation

+ StartRowOffset *int64

+ var TCLIServiceFetchResultsArgs_Req_DEFAULT *TFetchResultsReq

+ func NewTFetchResultsReq() *TFetchResultsReq

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

+ func (p *TFetchResultsReq) GetFetchType() int16

+ func (p *TFetchResultsReq) GetIncludeResultSetMetadata() bool

+ func (p *TFetchResultsReq) GetMaxBytes() int64

+ func (p *TFetchResultsReq) GetMaxRows() int64

+ func (p *TFetchResultsReq) GetOperationHandle() *TOperationHandle

+ func (p *TFetchResultsReq) GetOrientation() TFetchOrientation

+ func (p *TFetchResultsReq) GetStartRowOffset() int64

+ func (p *TFetchResultsReq) IsSetFetchType() bool

+ func (p *TFetchResultsReq) IsSetIncludeResultSetMetadata() bool

+ func (p *TFetchResultsReq) IsSetMaxBytes() bool

+ func (p *TFetchResultsReq) IsSetOperationHandle() bool

+ func (p *TFetchResultsReq) IsSetStartRowOffset() bool

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

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

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

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

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

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

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

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

+ func (p *TFetchResultsReq) String() string

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

+ type TFetchResultsResp struct

+ HasMoreRows *bool

+ ResultSetMetadata *TGetResultSetMetadataResp

+ Results *TRowSet

+ Status *TStatus

+ var TCLIServiceFetchResultsResult_Success_DEFAULT *TFetchResultsResp

+ var TSparkDirectResults_ResultSet_DEFAULT *TFetchResultsResp

+ func NewTFetchResultsResp() *TFetchResultsResp

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

+ func (p *TFetchResultsResp) GetHasMoreRows() bool

+ func (p *TFetchResultsResp) GetResultSetMetadata() *TGetResultSetMetadataResp

+ func (p *TFetchResultsResp) GetResults() *TRowSet

+ func (p *TFetchResultsResp) GetStatus() *TStatus

+ func (p *TFetchResultsResp) IsSetHasMoreRows() bool

+ func (p *TFetchResultsResp) IsSetResultSetMetadata() bool

+ func (p *TFetchResultsResp) IsSetResults() bool

+ func (p *TFetchResultsResp) IsSetStatus() bool

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

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

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

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

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

+ func (p *TFetchResultsResp) String() string

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

+ type TGetCatalogsReq struct

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetCatalogsArgs_Req_DEFAULT *TGetCatalogsReq

+ func NewTGetCatalogsReq() *TGetCatalogsReq

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

+ func (p *TGetCatalogsReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetCatalogsReq) GetOperationId() *THandleIdentifier

+ func (p *TGetCatalogsReq) GetRunAsync() bool

+ func (p *TGetCatalogsReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetCatalogsReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetCatalogsReq) IsSetGetDirectResults() bool

+ func (p *TGetCatalogsReq) IsSetOperationId() bool

+ func (p *TGetCatalogsReq) IsSetRunAsync() bool

+ func (p *TGetCatalogsReq) IsSetSessionConf() bool

+ func (p *TGetCatalogsReq) IsSetSessionHandle() bool

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

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

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

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

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

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

+ func (p *TGetCatalogsReq) String() string

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

+ type TGetCatalogsResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetCatalogsResult_Success_DEFAULT *TGetCatalogsResp

+ func NewTGetCatalogsResp() *TGetCatalogsResp

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

+ func (p *TGetCatalogsResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetCatalogsResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetCatalogsResp) GetStatus() *TStatus

+ func (p *TGetCatalogsResp) IsSetDirectResults() bool

+ func (p *TGetCatalogsResp) IsSetOperationHandle() bool

+ func (p *TGetCatalogsResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetCatalogsResp) String() string

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

+ type TGetColumnsReq struct

+ CatalogName *TIdentifier

+ ColumnName *TPatternOrIdentifier

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SchemaName *TPatternOrIdentifier

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ TableName *TPatternOrIdentifier

+ var TCLIServiceGetColumnsArgs_Req_DEFAULT *TGetColumnsReq

+ func NewTGetColumnsReq() *TGetColumnsReq

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

+ func (p *TGetColumnsReq) GetCatalogName() TIdentifier

+ func (p *TGetColumnsReq) GetColumnName() TPatternOrIdentifier

+ func (p *TGetColumnsReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetColumnsReq) GetOperationId() *THandleIdentifier

+ func (p *TGetColumnsReq) GetRunAsync() bool

+ func (p *TGetColumnsReq) GetSchemaName() TPatternOrIdentifier

+ func (p *TGetColumnsReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetColumnsReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetColumnsReq) GetTableName() TPatternOrIdentifier

+ func (p *TGetColumnsReq) IsSetCatalogName() bool

+ func (p *TGetColumnsReq) IsSetColumnName() bool

+ func (p *TGetColumnsReq) IsSetGetDirectResults() bool

+ func (p *TGetColumnsReq) IsSetOperationId() bool

+ func (p *TGetColumnsReq) IsSetRunAsync() bool

+ func (p *TGetColumnsReq) IsSetSchemaName() bool

+ func (p *TGetColumnsReq) IsSetSessionConf() bool

+ func (p *TGetColumnsReq) IsSetSessionHandle() bool

+ func (p *TGetColumnsReq) IsSetTableName() bool

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

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

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

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

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

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

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

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

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

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

+ func (p *TGetColumnsReq) String() string

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

+ type TGetColumnsResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetColumnsResult_Success_DEFAULT *TGetColumnsResp

+ func NewTGetColumnsResp() *TGetColumnsResp

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

+ func (p *TGetColumnsResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetColumnsResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetColumnsResp) GetStatus() *TStatus

+ func (p *TGetColumnsResp) IsSetDirectResults() bool

+ func (p *TGetColumnsResp) IsSetOperationHandle() bool

+ func (p *TGetColumnsResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetColumnsResp) String() string

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

+ type TGetCrossReferenceReq struct

+ ForeignCatalogName *TIdentifier

+ ForeignSchemaName *TIdentifier

+ ForeignTableName *TIdentifier

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ ParentCatalogName *TIdentifier

+ ParentSchemaName *TIdentifier

+ ParentTableName *TIdentifier

+ RunAsync bool

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetCrossReferenceArgs_Req_DEFAULT *TGetCrossReferenceReq

+ func NewTGetCrossReferenceReq() *TGetCrossReferenceReq

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

+ func (p *TGetCrossReferenceReq) GetForeignCatalogName() TIdentifier

+ func (p *TGetCrossReferenceReq) GetForeignSchemaName() TIdentifier

+ func (p *TGetCrossReferenceReq) GetForeignTableName() TIdentifier

+ func (p *TGetCrossReferenceReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetCrossReferenceReq) GetOperationId() *THandleIdentifier

+ func (p *TGetCrossReferenceReq) GetParentCatalogName() TIdentifier

+ func (p *TGetCrossReferenceReq) GetParentSchemaName() TIdentifier

+ func (p *TGetCrossReferenceReq) GetParentTableName() TIdentifier

+ func (p *TGetCrossReferenceReq) GetRunAsync() bool

+ func (p *TGetCrossReferenceReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetCrossReferenceReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetCrossReferenceReq) IsSetForeignCatalogName() bool

+ func (p *TGetCrossReferenceReq) IsSetForeignSchemaName() bool

+ func (p *TGetCrossReferenceReq) IsSetForeignTableName() bool

+ func (p *TGetCrossReferenceReq) IsSetGetDirectResults() bool

+ func (p *TGetCrossReferenceReq) IsSetOperationId() bool

+ func (p *TGetCrossReferenceReq) IsSetParentCatalogName() bool

+ func (p *TGetCrossReferenceReq) IsSetParentSchemaName() bool

+ func (p *TGetCrossReferenceReq) IsSetParentTableName() bool

+ func (p *TGetCrossReferenceReq) IsSetRunAsync() bool

+ func (p *TGetCrossReferenceReq) IsSetSessionConf() bool

+ func (p *TGetCrossReferenceReq) IsSetSessionHandle() bool

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TGetCrossReferenceReq) String() string

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

+ type TGetCrossReferenceResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetCrossReferenceResult_Success_DEFAULT *TGetCrossReferenceResp

+ func NewTGetCrossReferenceResp() *TGetCrossReferenceResp

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

+ func (p *TGetCrossReferenceResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetCrossReferenceResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetCrossReferenceResp) GetStatus() *TStatus

+ func (p *TGetCrossReferenceResp) IsSetDirectResults() bool

+ func (p *TGetCrossReferenceResp) IsSetOperationHandle() bool

+ func (p *TGetCrossReferenceResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetCrossReferenceResp) String() string

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

+ type TGetDelegationTokenReq struct

+ Owner string

+ Renewer string

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetDelegationTokenArgs_Req_DEFAULT *TGetDelegationTokenReq

+ func NewTGetDelegationTokenReq() *TGetDelegationTokenReq

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

+ func (p *TGetDelegationTokenReq) GetOwner() string

+ func (p *TGetDelegationTokenReq) GetRenewer() string

+ func (p *TGetDelegationTokenReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetDelegationTokenReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetDelegationTokenReq) IsSetSessionConf() bool

+ func (p *TGetDelegationTokenReq) IsSetSessionHandle() bool

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

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

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

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

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

+ func (p *TGetDelegationTokenReq) String() string

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

+ type TGetDelegationTokenResp struct

+ DelegationToken *string

+ Status *TStatus

+ var TCLIServiceGetDelegationTokenResult_Success_DEFAULT *TGetDelegationTokenResp

+ func NewTGetDelegationTokenResp() *TGetDelegationTokenResp

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

+ func (p *TGetDelegationTokenResp) GetDelegationToken() string

+ func (p *TGetDelegationTokenResp) GetStatus() *TStatus

+ func (p *TGetDelegationTokenResp) IsSetDelegationToken() bool

+ func (p *TGetDelegationTokenResp) IsSetStatus() bool

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

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

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

+ func (p *TGetDelegationTokenResp) String() string

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

+ type TGetFunctionsReq struct

+ CatalogName *TIdentifier

+ FunctionName TPatternOrIdentifier

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SchemaName *TPatternOrIdentifier

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetFunctionsArgs_Req_DEFAULT *TGetFunctionsReq

+ func NewTGetFunctionsReq() *TGetFunctionsReq

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

+ func (p *TGetFunctionsReq) GetCatalogName() TIdentifier

+ func (p *TGetFunctionsReq) GetFunctionName() TPatternOrIdentifier

+ func (p *TGetFunctionsReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetFunctionsReq) GetOperationId() *THandleIdentifier

+ func (p *TGetFunctionsReq) GetRunAsync() bool

+ func (p *TGetFunctionsReq) GetSchemaName() TPatternOrIdentifier

+ func (p *TGetFunctionsReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetFunctionsReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetFunctionsReq) IsSetCatalogName() bool

+ func (p *TGetFunctionsReq) IsSetGetDirectResults() bool

+ func (p *TGetFunctionsReq) IsSetOperationId() bool

+ func (p *TGetFunctionsReq) IsSetRunAsync() bool

+ func (p *TGetFunctionsReq) IsSetSchemaName() bool

+ func (p *TGetFunctionsReq) IsSetSessionConf() bool

+ func (p *TGetFunctionsReq) IsSetSessionHandle() bool

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

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

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

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

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

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

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

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

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

+ func (p *TGetFunctionsReq) String() string

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

+ type TGetFunctionsResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetFunctionsResult_Success_DEFAULT *TGetFunctionsResp

+ func NewTGetFunctionsResp() *TGetFunctionsResp

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

+ func (p *TGetFunctionsResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetFunctionsResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetFunctionsResp) GetStatus() *TStatus

+ func (p *TGetFunctionsResp) IsSetDirectResults() bool

+ func (p *TGetFunctionsResp) IsSetOperationHandle() bool

+ func (p *TGetFunctionsResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetFunctionsResp) String() string

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

+ type TGetInfoReq struct

+ InfoType TGetInfoType

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetInfoArgs_Req_DEFAULT *TGetInfoReq

+ func NewTGetInfoReq() *TGetInfoReq

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

+ func (p *TGetInfoReq) GetInfoType() TGetInfoType

+ func (p *TGetInfoReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetInfoReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetInfoReq) IsSetSessionConf() bool

+ func (p *TGetInfoReq) IsSetSessionHandle() bool

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

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

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

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

+ func (p *TGetInfoReq) String() string

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

+ type TGetInfoResp struct

+ InfoValue *TGetInfoValue

+ Status *TStatus

+ var TCLIServiceGetInfoResult_Success_DEFAULT *TGetInfoResp

+ func NewTGetInfoResp() *TGetInfoResp

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

+ func (p *TGetInfoResp) GetInfoValue() *TGetInfoValue

+ func (p *TGetInfoResp) GetStatus() *TStatus

+ func (p *TGetInfoResp) IsSetInfoValue() bool

+ func (p *TGetInfoResp) IsSetStatus() bool

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

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

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

+ func (p *TGetInfoResp) String() string

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

+ type TGetInfoType int64

+ const TGetInfoType_CLI_ACCESSIBLE_PROCEDURES

+ const TGetInfoType_CLI_ACCESSIBLE_TABLES

+ const TGetInfoType_CLI_ALTER_TABLE

+ const TGetInfoType_CLI_CATALOG_NAME

+ const TGetInfoType_CLI_COLLATION_SEQ

+ const TGetInfoType_CLI_CURSOR_COMMIT_BEHAVIOR

+ const TGetInfoType_CLI_CURSOR_SENSITIVITY

+ const TGetInfoType_CLI_DATA_SOURCE_NAME

+ const TGetInfoType_CLI_DATA_SOURCE_READ_ONLY

+ const TGetInfoType_CLI_DBMS_NAME

+ const TGetInfoType_CLI_DBMS_VER

+ const TGetInfoType_CLI_DEFAULT_TXN_ISOLATION

+ const TGetInfoType_CLI_DESCRIBE_PARAMETER

+ const TGetInfoType_CLI_FETCH_DIRECTION

+ const TGetInfoType_CLI_GETDATA_EXTENSIONS

+ const TGetInfoType_CLI_IDENTIFIER_CASE

+ const TGetInfoType_CLI_IDENTIFIER_QUOTE_CHAR

+ const TGetInfoType_CLI_INTEGRITY

+ const TGetInfoType_CLI_MAX_CATALOG_NAME_LEN

+ const TGetInfoType_CLI_MAX_COLUMNS_IN_GROUP_BY

+ const TGetInfoType_CLI_MAX_COLUMNS_IN_INDEX

+ const TGetInfoType_CLI_MAX_COLUMNS_IN_ORDER_BY

+ const TGetInfoType_CLI_MAX_COLUMNS_IN_SELECT

+ const TGetInfoType_CLI_MAX_COLUMNS_IN_TABLE

+ const TGetInfoType_CLI_MAX_COLUMN_NAME_LEN

+ const TGetInfoType_CLI_MAX_CONCURRENT_ACTIVITIES

+ const TGetInfoType_CLI_MAX_CURSOR_NAME_LEN

+ const TGetInfoType_CLI_MAX_DRIVER_CONNECTIONS

+ const TGetInfoType_CLI_MAX_IDENTIFIER_LEN

+ const TGetInfoType_CLI_MAX_INDEX_SIZE

+ const TGetInfoType_CLI_MAX_ROW_SIZE

+ const TGetInfoType_CLI_MAX_SCHEMA_NAME_LEN

+ const TGetInfoType_CLI_MAX_STATEMENT_LEN

+ const TGetInfoType_CLI_MAX_TABLES_IN_SELECT

+ const TGetInfoType_CLI_MAX_TABLE_NAME_LEN

+ const TGetInfoType_CLI_MAX_USER_NAME_LEN

+ const TGetInfoType_CLI_NULL_COLLATION

+ const TGetInfoType_CLI_OJ_CAPABILITIES

+ const TGetInfoType_CLI_ORDER_BY_COLUMNS_IN_SELECT

+ const TGetInfoType_CLI_SCROLL_CONCURRENCY

+ const TGetInfoType_CLI_SEARCH_PATTERN_ESCAPE

+ const TGetInfoType_CLI_SERVER_NAME

+ const TGetInfoType_CLI_SPECIAL_CHARACTERS

+ const TGetInfoType_CLI_TXN_CAPABLE

+ const TGetInfoType_CLI_TXN_ISOLATION_OPTION

+ const TGetInfoType_CLI_USER_NAME

+ const TGetInfoType_CLI_XOPEN_CLI_YEAR

+ func TGetInfoTypeFromString(s string) (TGetInfoType, error)

+ func TGetInfoTypePtr(v TGetInfoType) *TGetInfoType

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

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

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

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

+ func (p TGetInfoType) String() string

+ type TGetInfoValue struct

+ BinaryValue *int32

+ IntegerBitmask *int32

+ IntegerFlag *int32

+ LenValue *int64

+ SmallIntValue *int16

+ StringValue *string

+ var TGetInfoResp_InfoValue_DEFAULT *TGetInfoValue

+ func NewTGetInfoValue() *TGetInfoValue

+ func (p *TGetInfoValue) CountSetFieldsTGetInfoValue() int

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

+ func (p *TGetInfoValue) GetBinaryValue() int32

+ func (p *TGetInfoValue) GetIntegerBitmask() int32

+ func (p *TGetInfoValue) GetIntegerFlag() int32

+ func (p *TGetInfoValue) GetLenValue() int64

+ func (p *TGetInfoValue) GetSmallIntValue() int16

+ func (p *TGetInfoValue) GetStringValue() string

+ func (p *TGetInfoValue) IsSetBinaryValue() bool

+ func (p *TGetInfoValue) IsSetIntegerBitmask() bool

+ func (p *TGetInfoValue) IsSetIntegerFlag() bool

+ func (p *TGetInfoValue) IsSetLenValue() bool

+ func (p *TGetInfoValue) IsSetSmallIntValue() bool

+ func (p *TGetInfoValue) IsSetStringValue() bool

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

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

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

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

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

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

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

+ func (p *TGetInfoValue) String() string

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

+ type TGetOperationStatusReq struct

+ GetProgressUpdate *bool

+ OperationHandle *TOperationHandle

+ var TCLIServiceGetOperationStatusArgs_Req_DEFAULT *TGetOperationStatusReq

+ func NewTGetOperationStatusReq() *TGetOperationStatusReq

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

+ func (p *TGetOperationStatusReq) GetGetProgressUpdate() bool

+ func (p *TGetOperationStatusReq) GetOperationHandle() *TOperationHandle

+ func (p *TGetOperationStatusReq) IsSetGetProgressUpdate() bool

+ func (p *TGetOperationStatusReq) IsSetOperationHandle() bool

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

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

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

+ func (p *TGetOperationStatusReq) String() string

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

+ type TGetOperationStatusResp struct

+ DiagnosticInfo *string

+ DisplayMessage *string

+ ErrorCode *int32

+ ErrorMessage *string

+ HasResultSet *bool

+ NumModifiedRows *int64

+ OperationCompleted *int64

+ OperationStarted *int64

+ OperationState *TOperationState

+ ProgressUpdateResponse *TProgressUpdateResp

+ SqlState *string

+ Status *TStatus

+ TaskStatus *string

+ var TCLIServiceGetOperationStatusResult_Success_DEFAULT *TGetOperationStatusResp

+ var TSparkDirectResults_OperationStatus_DEFAULT *TGetOperationStatusResp

+ func NewTGetOperationStatusResp() *TGetOperationStatusResp

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

+ func (p *TGetOperationStatusResp) GetDiagnosticInfo() string

+ func (p *TGetOperationStatusResp) GetDisplayMessage() string

+ func (p *TGetOperationStatusResp) GetErrorCode() int32

+ func (p *TGetOperationStatusResp) GetErrorMessage() string

+ func (p *TGetOperationStatusResp) GetHasResultSet() bool

+ func (p *TGetOperationStatusResp) GetNumModifiedRows() int64

+ func (p *TGetOperationStatusResp) GetOperationCompleted() int64

+ func (p *TGetOperationStatusResp) GetOperationStarted() int64

+ func (p *TGetOperationStatusResp) GetOperationState() TOperationState

+ func (p *TGetOperationStatusResp) GetProgressUpdateResponse() *TProgressUpdateResp

+ func (p *TGetOperationStatusResp) GetSqlState() string

+ func (p *TGetOperationStatusResp) GetStatus() *TStatus

+ func (p *TGetOperationStatusResp) GetTaskStatus() string

+ func (p *TGetOperationStatusResp) IsSetDiagnosticInfo() bool

+ func (p *TGetOperationStatusResp) IsSetDisplayMessage() bool

+ func (p *TGetOperationStatusResp) IsSetErrorCode() bool

+ func (p *TGetOperationStatusResp) IsSetErrorMessage() bool

+ func (p *TGetOperationStatusResp) IsSetHasResultSet() bool

+ func (p *TGetOperationStatusResp) IsSetNumModifiedRows() bool

+ func (p *TGetOperationStatusResp) IsSetOperationCompleted() bool

+ func (p *TGetOperationStatusResp) IsSetOperationStarted() bool

+ func (p *TGetOperationStatusResp) IsSetOperationState() bool

+ func (p *TGetOperationStatusResp) IsSetProgressUpdateResponse() bool

+ func (p *TGetOperationStatusResp) IsSetSqlState() bool

+ func (p *TGetOperationStatusResp) IsSetStatus() bool

+ func (p *TGetOperationStatusResp) IsSetTaskStatus() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TGetOperationStatusResp) String() string

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

+ type TGetPrimaryKeysReq struct

+ CatalogName *TIdentifier

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SchemaName *TIdentifier

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ TableName *TIdentifier

+ var TCLIServiceGetPrimaryKeysArgs_Req_DEFAULT *TGetPrimaryKeysReq

+ func NewTGetPrimaryKeysReq() *TGetPrimaryKeysReq

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

+ func (p *TGetPrimaryKeysReq) GetCatalogName() TIdentifier

+ func (p *TGetPrimaryKeysReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetPrimaryKeysReq) GetOperationId() *THandleIdentifier

+ func (p *TGetPrimaryKeysReq) GetRunAsync() bool

+ func (p *TGetPrimaryKeysReq) GetSchemaName() TIdentifier

+ func (p *TGetPrimaryKeysReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetPrimaryKeysReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetPrimaryKeysReq) GetTableName() TIdentifier

+ func (p *TGetPrimaryKeysReq) IsSetCatalogName() bool

+ func (p *TGetPrimaryKeysReq) IsSetGetDirectResults() bool

+ func (p *TGetPrimaryKeysReq) IsSetOperationId() bool

+ func (p *TGetPrimaryKeysReq) IsSetRunAsync() bool

+ func (p *TGetPrimaryKeysReq) IsSetSchemaName() bool

+ func (p *TGetPrimaryKeysReq) IsSetSessionConf() bool

+ func (p *TGetPrimaryKeysReq) IsSetSessionHandle() bool

+ func (p *TGetPrimaryKeysReq) IsSetTableName() bool

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

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

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

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

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

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

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

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

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

+ func (p *TGetPrimaryKeysReq) String() string

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

+ type TGetPrimaryKeysResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetPrimaryKeysResult_Success_DEFAULT *TGetPrimaryKeysResp

+ func NewTGetPrimaryKeysResp() *TGetPrimaryKeysResp

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

+ func (p *TGetPrimaryKeysResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetPrimaryKeysResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetPrimaryKeysResp) GetStatus() *TStatus

+ func (p *TGetPrimaryKeysResp) IsSetDirectResults() bool

+ func (p *TGetPrimaryKeysResp) IsSetOperationHandle() bool

+ func (p *TGetPrimaryKeysResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetPrimaryKeysResp) String() string

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

+ type TGetResultSetMetadataReq struct

+ OperationHandle *TOperationHandle

+ var TCLIServiceGetResultSetMetadataArgs_Req_DEFAULT *TGetResultSetMetadataReq

+ func NewTGetResultSetMetadataReq() *TGetResultSetMetadataReq

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

+ func (p *TGetResultSetMetadataReq) GetOperationHandle() *TOperationHandle

+ func (p *TGetResultSetMetadataReq) IsSetOperationHandle() bool

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

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

+ func (p *TGetResultSetMetadataReq) String() string

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

+ type TGetResultSetMetadataResp struct

+ ArrowSchema []byte

+ CacheLookupResult_ *TCacheLookupResult_

+ CompressedBytes *int64

+ Lz4Compressed *bool

+ ResultFormat *TSparkRowSetType

+ Schema *TTableSchema

+ Status *TStatus

+ UncompressedBytes *int64

+ var TCLIServiceGetResultSetMetadataResult_Success_DEFAULT *TGetResultSetMetadataResp

+ var TFetchResultsResp_ResultSetMetadata_DEFAULT *TGetResultSetMetadataResp

+ var TSparkDirectResults_ResultSetMetadata_DEFAULT *TGetResultSetMetadataResp

+ func NewTGetResultSetMetadataResp() *TGetResultSetMetadataResp

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

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

+ func (p *TGetResultSetMetadataResp) GetCacheLookupResult_() TCacheLookupResult_

+ func (p *TGetResultSetMetadataResp) GetCompressedBytes() int64

+ func (p *TGetResultSetMetadataResp) GetLz4Compressed() bool

+ func (p *TGetResultSetMetadataResp) GetResultFormat() TSparkRowSetType

+ func (p *TGetResultSetMetadataResp) GetSchema() *TTableSchema

+ func (p *TGetResultSetMetadataResp) GetStatus() *TStatus

+ func (p *TGetResultSetMetadataResp) GetUncompressedBytes() int64

+ func (p *TGetResultSetMetadataResp) IsSetArrowSchema() bool

+ func (p *TGetResultSetMetadataResp) IsSetCacheLookupResult_() bool

+ func (p *TGetResultSetMetadataResp) IsSetCompressedBytes() bool

+ func (p *TGetResultSetMetadataResp) IsSetLz4Compressed() bool

+ func (p *TGetResultSetMetadataResp) IsSetResultFormat() bool

+ func (p *TGetResultSetMetadataResp) IsSetSchema() bool

+ func (p *TGetResultSetMetadataResp) IsSetStatus() bool

+ func (p *TGetResultSetMetadataResp) IsSetUncompressedBytes() bool

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

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

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

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

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

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

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

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

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

+ func (p *TGetResultSetMetadataResp) String() string

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

+ type TGetSchemasReq struct

+ CatalogName *TIdentifier

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SchemaName *TPatternOrIdentifier

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetSchemasArgs_Req_DEFAULT *TGetSchemasReq

+ func NewTGetSchemasReq() *TGetSchemasReq

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

+ func (p *TGetSchemasReq) GetCatalogName() TIdentifier

+ func (p *TGetSchemasReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetSchemasReq) GetOperationId() *THandleIdentifier

+ func (p *TGetSchemasReq) GetRunAsync() bool

+ func (p *TGetSchemasReq) GetSchemaName() TPatternOrIdentifier

+ func (p *TGetSchemasReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetSchemasReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetSchemasReq) IsSetCatalogName() bool

+ func (p *TGetSchemasReq) IsSetGetDirectResults() bool

+ func (p *TGetSchemasReq) IsSetOperationId() bool

+ func (p *TGetSchemasReq) IsSetRunAsync() bool

+ func (p *TGetSchemasReq) IsSetSchemaName() bool

+ func (p *TGetSchemasReq) IsSetSessionConf() bool

+ func (p *TGetSchemasReq) IsSetSessionHandle() bool

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

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

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

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

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

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

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

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

+ func (p *TGetSchemasReq) String() string

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

+ type TGetSchemasResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetSchemasResult_Success_DEFAULT *TGetSchemasResp

+ func NewTGetSchemasResp() *TGetSchemasResp

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

+ func (p *TGetSchemasResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetSchemasResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetSchemasResp) GetStatus() *TStatus

+ func (p *TGetSchemasResp) IsSetDirectResults() bool

+ func (p *TGetSchemasResp) IsSetOperationHandle() bool

+ func (p *TGetSchemasResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetSchemasResp) String() string

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

+ type TGetTableTypesReq struct

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetTableTypesArgs_Req_DEFAULT *TGetTableTypesReq

+ func NewTGetTableTypesReq() *TGetTableTypesReq

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

+ func (p *TGetTableTypesReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetTableTypesReq) GetOperationId() *THandleIdentifier

+ func (p *TGetTableTypesReq) GetRunAsync() bool

+ func (p *TGetTableTypesReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetTableTypesReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetTableTypesReq) IsSetGetDirectResults() bool

+ func (p *TGetTableTypesReq) IsSetOperationId() bool

+ func (p *TGetTableTypesReq) IsSetRunAsync() bool

+ func (p *TGetTableTypesReq) IsSetSessionConf() bool

+ func (p *TGetTableTypesReq) IsSetSessionHandle() bool

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

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

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

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

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

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

+ func (p *TGetTableTypesReq) String() string

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

+ type TGetTableTypesResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetTableTypesResult_Success_DEFAULT *TGetTableTypesResp

+ func NewTGetTableTypesResp() *TGetTableTypesResp

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

+ func (p *TGetTableTypesResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetTableTypesResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetTableTypesResp) GetStatus() *TStatus

+ func (p *TGetTableTypesResp) IsSetDirectResults() bool

+ func (p *TGetTableTypesResp) IsSetOperationHandle() bool

+ func (p *TGetTableTypesResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetTableTypesResp) String() string

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

+ type TGetTablesReq struct

+ CatalogName *TPatternOrIdentifier

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SchemaName *TPatternOrIdentifier

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ TableName *TPatternOrIdentifier

+ TableTypes []string

+ var TCLIServiceGetTablesArgs_Req_DEFAULT *TGetTablesReq

+ func NewTGetTablesReq() *TGetTablesReq

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

+ func (p *TGetTablesReq) GetCatalogName() TPatternOrIdentifier

+ func (p *TGetTablesReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetTablesReq) GetOperationId() *THandleIdentifier

+ func (p *TGetTablesReq) GetRunAsync() bool

+ func (p *TGetTablesReq) GetSchemaName() TPatternOrIdentifier

+ func (p *TGetTablesReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetTablesReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetTablesReq) GetTableName() TPatternOrIdentifier

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

+ func (p *TGetTablesReq) IsSetCatalogName() bool

+ func (p *TGetTablesReq) IsSetGetDirectResults() bool

+ func (p *TGetTablesReq) IsSetOperationId() bool

+ func (p *TGetTablesReq) IsSetRunAsync() bool

+ func (p *TGetTablesReq) IsSetSchemaName() bool

+ func (p *TGetTablesReq) IsSetSessionConf() bool

+ func (p *TGetTablesReq) IsSetSessionHandle() bool

+ func (p *TGetTablesReq) IsSetTableName() bool

+ func (p *TGetTablesReq) IsSetTableTypes() bool

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

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

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

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

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

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

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

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

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

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

+ func (p *TGetTablesReq) String() string

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

+ type TGetTablesResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetTablesResult_Success_DEFAULT *TGetTablesResp

+ func NewTGetTablesResp() *TGetTablesResp

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

+ func (p *TGetTablesResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetTablesResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetTablesResp) GetStatus() *TStatus

+ func (p *TGetTablesResp) IsSetDirectResults() bool

+ func (p *TGetTablesResp) IsSetOperationHandle() bool

+ func (p *TGetTablesResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetTablesResp) String() string

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

+ type TGetTypeInfoReq struct

+ GetDirectResults *TSparkGetDirectResults

+ OperationId *THandleIdentifier

+ RunAsync bool

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceGetTypeInfoArgs_Req_DEFAULT *TGetTypeInfoReq

+ func NewTGetTypeInfoReq() *TGetTypeInfoReq

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

+ func (p *TGetTypeInfoReq) GetGetDirectResults() *TSparkGetDirectResults

+ func (p *TGetTypeInfoReq) GetOperationId() *THandleIdentifier

+ func (p *TGetTypeInfoReq) GetRunAsync() bool

+ func (p *TGetTypeInfoReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TGetTypeInfoReq) GetSessionHandle() *TSessionHandle

+ func (p *TGetTypeInfoReq) IsSetGetDirectResults() bool

+ func (p *TGetTypeInfoReq) IsSetOperationId() bool

+ func (p *TGetTypeInfoReq) IsSetRunAsync() bool

+ func (p *TGetTypeInfoReq) IsSetSessionConf() bool

+ func (p *TGetTypeInfoReq) IsSetSessionHandle() bool

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

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

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

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

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

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

+ func (p *TGetTypeInfoReq) String() string

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

+ type TGetTypeInfoResp struct

+ DirectResults *TSparkDirectResults

+ OperationHandle *TOperationHandle

+ Status *TStatus

+ var TCLIServiceGetTypeInfoResult_Success_DEFAULT *TGetTypeInfoResp

+ func NewTGetTypeInfoResp() *TGetTypeInfoResp

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

+ func (p *TGetTypeInfoResp) GetDirectResults() *TSparkDirectResults

+ func (p *TGetTypeInfoResp) GetOperationHandle() *TOperationHandle

+ func (p *TGetTypeInfoResp) GetStatus() *TStatus

+ func (p *TGetTypeInfoResp) IsSetDirectResults() bool

+ func (p *TGetTypeInfoResp) IsSetOperationHandle() bool

+ func (p *TGetTypeInfoResp) IsSetStatus() bool

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

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

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

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

+ func (p *TGetTypeInfoResp) String() string

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

+ type THandleIdentifier struct

+ GUID []byte

+ Secret []byte

+ var TExecuteStatementReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetCatalogsReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetColumnsReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetCrossReferenceReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetFunctionsReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetPrimaryKeysReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetSchemasReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetTableTypesReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetTablesReq_OperationId_DEFAULT *THandleIdentifier

+ var TGetTypeInfoReq_OperationId_DEFAULT *THandleIdentifier

+ var TOpenSessionReq_SessionId_DEFAULT *THandleIdentifier

+ var TOperationHandle_OperationId_DEFAULT *THandleIdentifier

+ var TSessionHandle_SessionId_DEFAULT *THandleIdentifier

+ func NewTHandleIdentifier() *THandleIdentifier

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

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

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

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

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

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

+ func (p *THandleIdentifier) String() string

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

+ type TI16Column struct

+ Nulls []byte

+ Values []int16

+ var TColumn_I16Val_DEFAULT *TI16Column

+ func NewTI16Column() *TI16Column

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

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

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

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

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

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

+ func (p *TI16Column) String() string

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

+ type TI16Value struct

+ Value *int16

+ var TColumnValue_I16Val_DEFAULT *TI16Value

+ func NewTI16Value() *TI16Value

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

+ func (p *TI16Value) GetValue() int16

+ func (p *TI16Value) IsSetValue() bool

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

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

+ func (p *TI16Value) String() string

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

+ type TI32Column struct

+ Nulls []byte

+ Values []int32

+ var TColumn_I32Val_DEFAULT *TI32Column

+ func NewTI32Column() *TI32Column

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

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

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

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

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

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

+ func (p *TI32Column) String() string

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

+ type TI32Value struct

+ Value *int32

+ var TColumnValue_I32Val_DEFAULT *TI32Value

+ func NewTI32Value() *TI32Value

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

+ func (p *TI32Value) GetValue() int32

+ func (p *TI32Value) IsSetValue() bool

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

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

+ func (p *TI32Value) String() string

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

+ type TI64Column struct

+ Nulls []byte

+ Values []int64

+ var TColumn_I64Val_DEFAULT *TI64Column

+ func NewTI64Column() *TI64Column

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

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

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

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

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

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

+ func (p *TI64Column) String() string

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

+ type TI64Value struct

+ Value *int64

+ var TColumnValue_I64Val_DEFAULT *TI64Value

+ func NewTI64Value() *TI64Value

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

+ func (p *TI64Value) GetValue() int64

+ func (p *TI64Value) IsSetValue() bool

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

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

+ func (p *TI64Value) String() string

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

+ 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(v TIdentifier) *TIdentifier

+ type TJobExecutionStatus int64

+ const TJobExecutionStatus_COMPLETE

+ const TJobExecutionStatus_IN_PROGRESS

+ const TJobExecutionStatus_NOT_AVAILABLE

+ func TJobExecutionStatusFromString(s string) (TJobExecutionStatus, error)

+ func TJobExecutionStatusPtr(v TJobExecutionStatus) *TJobExecutionStatus

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

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

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

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

+ func (p TJobExecutionStatus) String() string

+ type TMapTypeEntry struct

+ KeyTypePtr TTypeEntryPtr

+ ValueTypePtr TTypeEntryPtr

+ var TTypeEntry_MapEntry_DEFAULT *TMapTypeEntry

+ func NewTMapTypeEntry() *TMapTypeEntry

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

+ func (p *TMapTypeEntry) GetKeyTypePtr() TTypeEntryPtr

+ func (p *TMapTypeEntry) GetValueTypePtr() TTypeEntryPtr

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

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

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

+ func (p *TMapTypeEntry) String() string

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

+ type TNamespace struct

+ CatalogName *TIdentifier

+ SchemaName *TIdentifier

+ var TOpenSessionReq_InitialNamespace_DEFAULT *TNamespace

+ var TOpenSessionResp_InitialNamespace_DEFAULT *TNamespace

+ func NewTNamespace() *TNamespace

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

+ func (p *TNamespace) GetCatalogName() TIdentifier

+ func (p *TNamespace) GetSchemaName() TIdentifier

+ func (p *TNamespace) IsSetCatalogName() bool

+ func (p *TNamespace) IsSetSchemaName() bool

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

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

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

+ func (p *TNamespace) String() string

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

+ type TOpenSessionReq struct

+ CanUseMultipleCatalogs *bool

+ ClientProtocol TProtocolVersion

+ ClientProtocolI64 *int64

+ Configuration map[string]string

+ ConnectionProperties map[string]string

+ GetInfos []TGetInfoType

+ InitialNamespace *TNamespace

+ Password *string

+ SessionId *THandleIdentifier

+ Username *string

+ var TCLIServiceOpenSessionArgs_Req_DEFAULT *TOpenSessionReq

+ func NewTOpenSessionReq() *TOpenSessionReq

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

+ func (p *TOpenSessionReq) GetCanUseMultipleCatalogs() bool

+ func (p *TOpenSessionReq) GetClientProtocol() TProtocolVersion

+ func (p *TOpenSessionReq) GetClientProtocolI64() int64

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

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

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

+ func (p *TOpenSessionReq) GetInitialNamespace() *TNamespace

+ func (p *TOpenSessionReq) GetPassword() string

+ func (p *TOpenSessionReq) GetSessionId() *THandleIdentifier

+ func (p *TOpenSessionReq) GetUsername() string

+ func (p *TOpenSessionReq) IsSetCanUseMultipleCatalogs() bool

+ func (p *TOpenSessionReq) IsSetClientProtocol() bool

+ func (p *TOpenSessionReq) IsSetClientProtocolI64() bool

+ func (p *TOpenSessionReq) IsSetConfiguration() bool

+ func (p *TOpenSessionReq) IsSetConnectionProperties() bool

+ func (p *TOpenSessionReq) IsSetGetInfos() bool

+ func (p *TOpenSessionReq) IsSetInitialNamespace() bool

+ func (p *TOpenSessionReq) IsSetPassword() bool

+ func (p *TOpenSessionReq) IsSetSessionId() bool

+ func (p *TOpenSessionReq) IsSetUsername() bool

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

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

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

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

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

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

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

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

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

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

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

+ func (p *TOpenSessionReq) String() string

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

+ type TOpenSessionResp struct

+ CanUseMultipleCatalogs *bool

+ Configuration map[string]string

+ GetInfos []*TGetInfoValue

+ InitialNamespace *TNamespace

+ ServerProtocolVersion TProtocolVersion

+ SessionHandle *TSessionHandle

+ Status *TStatus

+ var TCLIServiceOpenSessionResult_Success_DEFAULT *TOpenSessionResp

+ func NewTOpenSessionResp() *TOpenSessionResp

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

+ func (p *TOpenSessionResp) GetCanUseMultipleCatalogs() bool

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

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

+ func (p *TOpenSessionResp) GetInitialNamespace() *TNamespace

+ func (p *TOpenSessionResp) GetServerProtocolVersion() TProtocolVersion

+ func (p *TOpenSessionResp) GetSessionHandle() *TSessionHandle

+ func (p *TOpenSessionResp) GetStatus() *TStatus

+ func (p *TOpenSessionResp) IsSetCanUseMultipleCatalogs() bool

+ func (p *TOpenSessionResp) IsSetConfiguration() bool

+ func (p *TOpenSessionResp) IsSetGetInfos() bool

+ func (p *TOpenSessionResp) IsSetInitialNamespace() bool

+ func (p *TOpenSessionResp) IsSetSessionHandle() bool

+ func (p *TOpenSessionResp) IsSetStatus() bool

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

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

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

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

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

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

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

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

+ func (p *TOpenSessionResp) String() string

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

+ type TOperationHandle struct

+ HasResultSet bool

+ ModifiedRowCount *float64

+ OperationId *THandleIdentifier

+ OperationType TOperationType

+ 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() *TOperationHandle

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

+ func (p *TOperationHandle) GetHasResultSet() bool

+ func (p *TOperationHandle) GetModifiedRowCount() float64

+ func (p *TOperationHandle) GetOperationId() *THandleIdentifier

+ func (p *TOperationHandle) GetOperationType() TOperationType

+ func (p *TOperationHandle) IsSetModifiedRowCount() bool

+ func (p *TOperationHandle) IsSetOperationId() bool

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

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

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

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

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

+ func (p *TOperationHandle) String() string

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

+ type TOperationIdempotencyType int64

+ const TOperationIdempotencyType_IDEMPOTENT

+ const TOperationIdempotencyType_NON_IDEMPOTENT

+ const TOperationIdempotencyType_UNKNOWN

+ var TExecuteStatementResp_IdempotencyType_DEFAULT TOperationIdempotencyType

+ func TOperationIdempotencyTypeFromString(s string) (TOperationIdempotencyType, error)

+ func TOperationIdempotencyTypePtr(v TOperationIdempotencyType) *TOperationIdempotencyType

+ func (p *TOperationIdempotencyType) Scan(value interface{}) error

+ func (p *TOperationIdempotencyType) UnmarshalText(text []byte) error

+ func (p *TOperationIdempotencyType) Value() (driver.Value, error)

+ func (p TOperationIdempotencyType) MarshalText() ([]byte, error)

+ func (p TOperationIdempotencyType) String() string

+ type TOperationState int64

+ const TOperationState_CANCELED_STATE

+ const TOperationState_CLOSED_STATE

+ const TOperationState_ERROR_STATE

+ const TOperationState_FINISHED_STATE

+ const TOperationState_INITIALIZED_STATE

+ const TOperationState_PENDING_STATE

+ const TOperationState_RUNNING_STATE

+ const TOperationState_TIMEDOUT_STATE

+ const TOperationState_UKNOWN_STATE

+ var TGetOperationStatusResp_OperationState_DEFAULT TOperationState

+ func TOperationStateFromString(s string) (TOperationState, error)

+ func TOperationStatePtr(v TOperationState) *TOperationState

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

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

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

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

+ func (p TOperationState) String() string

+ type TOperationType int64

+ const TOperationType_EXECUTE_STATEMENT

+ const TOperationType_GET_CATALOGS

+ const TOperationType_GET_COLUMNS

+ const TOperationType_GET_FUNCTIONS

+ const TOperationType_GET_SCHEMAS

+ const TOperationType_GET_TABLES

+ const TOperationType_GET_TABLE_TYPES

+ const TOperationType_GET_TYPE_INFO

+ const TOperationType_UNKNOWN

+ func TOperationTypeFromString(s string) (TOperationType, error)

+ func TOperationTypePtr(v TOperationType) *TOperationType

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

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

+ func (p *TOperationType) Value() (driver.Value, error)

+ func (p TOperationType) MarshalText() ([]byte, error)

+ func (p TOperationType) String() string

+ type TPattern string

+ func TPatternPtr(v TPattern) *TPattern

+ 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(v TPatternOrIdentifier) *TPatternOrIdentifier

+ type TPrimitiveTypeEntry struct

+ Type TTypeId

+ TypeQualifiers *TTypeQualifiers

+ var TTypeEntry_PrimitiveEntry_DEFAULT *TPrimitiveTypeEntry

+ func NewTPrimitiveTypeEntry() *TPrimitiveTypeEntry

+ func (p *TPrimitiveTypeEntry) Equals(other *TPrimitiveTypeEntry) bool

+ func (p *TPrimitiveTypeEntry) GetType() TTypeId

+ func (p *TPrimitiveTypeEntry) GetTypeQualifiers() *TTypeQualifiers

+ func (p *TPrimitiveTypeEntry) IsSetTypeQualifiers() bool

+ func (p *TPrimitiveTypeEntry) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TPrimitiveTypeEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TPrimitiveTypeEntry) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TPrimitiveTypeEntry) String() string

+ func (p *TPrimitiveTypeEntry) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TProgressUpdateResp struct

+ FooterSummary string

+ HeaderNames []string

+ ProgressedPercentage float64

+ Rows [][]string

+ StartTime int64

+ Status TJobExecutionStatus

+ var TGetOperationStatusResp_ProgressUpdateResponse_DEFAULT *TProgressUpdateResp

+ func NewTProgressUpdateResp() *TProgressUpdateResp

+ func (p *TProgressUpdateResp) Equals(other *TProgressUpdateResp) bool

+ func (p *TProgressUpdateResp) GetFooterSummary() string

+ func (p *TProgressUpdateResp) GetHeaderNames() []string

+ func (p *TProgressUpdateResp) GetProgressedPercentage() float64

+ func (p *TProgressUpdateResp) GetRows() [][]string

+ func (p *TProgressUpdateResp) GetStartTime() int64

+ func (p *TProgressUpdateResp) GetStatus() TJobExecutionStatus

+ func (p *TProgressUpdateResp) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TProgressUpdateResp) String() string

+ func (p *TProgressUpdateResp) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TProtocolVersion int64

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V1

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V10

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V2

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V3

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V4

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V5

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V6

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V7

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V8

+ const TProtocolVersion_HIVE_CLI_SERVICE_PROTOCOL_V9

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V1

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V2

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V3

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V4

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V5

+ const TProtocolVersion_SPARK_CLI_SERVICE_PROTOCOL_V6

+ const TProtocolVersion___HIVE_JDBC_WORKAROUND

+ const TProtocolVersion___TEST_PROTOCOL_VERSION

+ var TOpenSessionReq_ClientProtocol_DEFAULT TProtocolVersion = -7

+ var TSessionHandle_ServerProtocolVersion_DEFAULT TProtocolVersion

+ func TProtocolVersionFromString(s string) (TProtocolVersion, error)

+ func TProtocolVersionPtr(v TProtocolVersion) *TProtocolVersion

+ func (p *TProtocolVersion) Scan(value interface{}) error

+ func (p *TProtocolVersion) UnmarshalText(text []byte) error

+ func (p *TProtocolVersion) Value() (driver.Value, error)

+ func (p TProtocolVersion) MarshalText() ([]byte, error)

+ func (p TProtocolVersion) String() string

+ type TRenewDelegationTokenReq struct

+ DelegationToken string

+ SessionConf *TDBSqlSessionConf

+ SessionHandle *TSessionHandle

+ var TCLIServiceRenewDelegationTokenArgs_Req_DEFAULT *TRenewDelegationTokenReq

+ func NewTRenewDelegationTokenReq() *TRenewDelegationTokenReq

+ func (p *TRenewDelegationTokenReq) Equals(other *TRenewDelegationTokenReq) bool

+ func (p *TRenewDelegationTokenReq) GetDelegationToken() string

+ func (p *TRenewDelegationTokenReq) GetSessionConf() *TDBSqlSessionConf

+ func (p *TRenewDelegationTokenReq) GetSessionHandle() *TSessionHandle

+ func (p *TRenewDelegationTokenReq) IsSetSessionConf() bool

+ func (p *TRenewDelegationTokenReq) IsSetSessionHandle() bool

+ func (p *TRenewDelegationTokenReq) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRenewDelegationTokenReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRenewDelegationTokenReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRenewDelegationTokenReq) ReadField3329(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRenewDelegationTokenReq) String() string

+ func (p *TRenewDelegationTokenReq) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TRenewDelegationTokenResp struct

+ Status *TStatus

+ var TCLIServiceRenewDelegationTokenResult_Success_DEFAULT *TRenewDelegationTokenResp

+ func NewTRenewDelegationTokenResp() *TRenewDelegationTokenResp

+ func (p *TRenewDelegationTokenResp) Equals(other *TRenewDelegationTokenResp) bool

+ func (p *TRenewDelegationTokenResp) GetStatus() *TStatus

+ func (p *TRenewDelegationTokenResp) IsSetStatus() bool

+ func (p *TRenewDelegationTokenResp) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRenewDelegationTokenResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRenewDelegationTokenResp) String() string

+ func (p *TRenewDelegationTokenResp) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TRow struct

+ ColVals []*TColumnValue

+ func NewTRow() *TRow

+ func (p *TRow) Equals(other *TRow) bool

+ func (p *TRow) GetColVals() []*TColumnValue

+ func (p *TRow) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRow) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRow) String() string

+ func (p *TRow) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TRowSet struct

+ ArrowBatches []*TSparkArrowBatch

+ BinaryColumns []byte

+ ColumnCount *int32

+ Columns []*TColumn

+ ResultLinks []*TSparkArrowResultLink

+ Rows []*TRow

+ StartRowOffset int64

+ var TFetchResultsResp_Results_DEFAULT *TRowSet

+ func NewTRowSet() *TRowSet

+ func (p *TRowSet) Equals(other *TRowSet) bool

+ func (p *TRowSet) GetArrowBatches() []*TSparkArrowBatch

+ func (p *TRowSet) GetBinaryColumns() []byte

+ func (p *TRowSet) GetColumnCount() int32

+ func (p *TRowSet) GetColumns() []*TColumn

+ func (p *TRowSet) GetResultLinks() []*TSparkArrowResultLink

+ func (p *TRowSet) GetRows() []*TRow

+ func (p *TRowSet) GetStartRowOffset() int64

+ func (p *TRowSet) IsSetArrowBatches() bool

+ func (p *TRowSet) IsSetBinaryColumns() bool

+ func (p *TRowSet) IsSetColumnCount() bool

+ func (p *TRowSet) IsSetColumns() bool

+ func (p *TRowSet) IsSetResultLinks() bool

+ func (p *TRowSet) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField1281(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField1282(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TRowSet) String() string

+ func (p *TRowSet) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSessionHandle struct

+ ServerProtocolVersion *TProtocolVersion

+ SessionId *THandleIdentifier

+ 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() *TSessionHandle

+ func (p *TSessionHandle) Equals(other *TSessionHandle) bool

+ func (p *TSessionHandle) GetServerProtocolVersion() TProtocolVersion

+ func (p *TSessionHandle) GetSessionId() *THandleIdentifier

+ func (p *TSessionHandle) IsSetServerProtocolVersion() bool

+ func (p *TSessionHandle) IsSetSessionId() bool

+ func (p *TSessionHandle) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSessionHandle) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSessionHandle) ReadField3329(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSessionHandle) String() string

+ func (p *TSessionHandle) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSparkArrowBatch struct

+ Batch []byte

+ RowCount int64

+ func NewTSparkArrowBatch() *TSparkArrowBatch

+ func (p *TSparkArrowBatch) Equals(other *TSparkArrowBatch) bool

+ func (p *TSparkArrowBatch) GetBatch() []byte

+ func (p *TSparkArrowBatch) GetRowCount() int64

+ func (p *TSparkArrowBatch) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowBatch) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowBatch) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowBatch) String() string

+ func (p *TSparkArrowBatch) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSparkArrowResultLink struct

+ BytesNum int64

+ ExpiryTime int64

+ FileLink string

+ RowCount int64

+ StartRowOffset int64

+ func NewTSparkArrowResultLink() *TSparkArrowResultLink

+ func (p *TSparkArrowResultLink) Equals(other *TSparkArrowResultLink) bool

+ func (p *TSparkArrowResultLink) GetBytesNum() int64

+ func (p *TSparkArrowResultLink) GetExpiryTime() int64

+ func (p *TSparkArrowResultLink) GetFileLink() string

+ func (p *TSparkArrowResultLink) GetRowCount() int64

+ func (p *TSparkArrowResultLink) GetStartRowOffset() int64

+ func (p *TSparkArrowResultLink) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowResultLink) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowResultLink) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowResultLink) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowResultLink) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowResultLink) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowResultLink) String() string

+ func (p *TSparkArrowResultLink) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSparkArrowTypes struct

+ ComplexTypesAsArrow *bool

+ DecimalAsArrow *bool

+ IntervalTypesAsArrow *bool

+ TimestampAsArrow *bool

+ var TExecuteStatementReq_UseArrowNativeTypes_DEFAULT *TSparkArrowTypes

+ func NewTSparkArrowTypes() *TSparkArrowTypes

+ func (p *TSparkArrowTypes) Equals(other *TSparkArrowTypes) bool

+ func (p *TSparkArrowTypes) GetComplexTypesAsArrow() bool

+ func (p *TSparkArrowTypes) GetDecimalAsArrow() bool

+ func (p *TSparkArrowTypes) GetIntervalTypesAsArrow() bool

+ func (p *TSparkArrowTypes) GetTimestampAsArrow() bool

+ func (p *TSparkArrowTypes) IsSetComplexTypesAsArrow() bool

+ func (p *TSparkArrowTypes) IsSetDecimalAsArrow() bool

+ func (p *TSparkArrowTypes) IsSetIntervalTypesAsArrow() bool

+ func (p *TSparkArrowTypes) IsSetTimestampAsArrow() bool

+ func (p *TSparkArrowTypes) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowTypes) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowTypes) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowTypes) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowTypes) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkArrowTypes) String() string

+ func (p *TSparkArrowTypes) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSparkDirectResults struct

+ CloseOperation *TCloseOperationResp

+ OperationStatus *TGetOperationStatusResp

+ ResultSet *TFetchResultsResp

+ ResultSetMetadata *TGetResultSetMetadataResp

+ 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() *TSparkDirectResults

+ func (p *TSparkDirectResults) Equals(other *TSparkDirectResults) bool

+ func (p *TSparkDirectResults) GetCloseOperation() *TCloseOperationResp

+ func (p *TSparkDirectResults) GetOperationStatus() *TGetOperationStatusResp

+ func (p *TSparkDirectResults) GetResultSet() *TFetchResultsResp

+ func (p *TSparkDirectResults) GetResultSetMetadata() *TGetResultSetMetadataResp

+ func (p *TSparkDirectResults) IsSetCloseOperation() bool

+ func (p *TSparkDirectResults) IsSetOperationStatus() bool

+ func (p *TSparkDirectResults) IsSetResultSet() bool

+ func (p *TSparkDirectResults) IsSetResultSetMetadata() bool

+ func (p *TSparkDirectResults) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkDirectResults) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkDirectResults) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkDirectResults) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkDirectResults) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkDirectResults) String() string

+ func (p *TSparkDirectResults) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSparkGetDirectResults struct

+ MaxBytes *int64

+ MaxRows int64

+ 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() *TSparkGetDirectResults

+ func (p *TSparkGetDirectResults) Equals(other *TSparkGetDirectResults) bool

+ func (p *TSparkGetDirectResults) GetMaxBytes() int64

+ func (p *TSparkGetDirectResults) GetMaxRows() int64

+ func (p *TSparkGetDirectResults) IsSetMaxBytes() bool

+ func (p *TSparkGetDirectResults) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkGetDirectResults) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkGetDirectResults) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSparkGetDirectResults) String() string

+ func (p *TSparkGetDirectResults) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TSparkRowSetType int64

+ const TSparkRowSetType_ARROW_BASED_SET

+ const TSparkRowSetType_COLUMN_BASED_SET

+ const TSparkRowSetType_ROW_BASED_SET

+ const TSparkRowSetType_URL_BASED_SET

+ var TGetResultSetMetadataResp_ResultFormat_DEFAULT TSparkRowSetType

+ func TSparkRowSetTypeFromString(s string) (TSparkRowSetType, error)

+ func TSparkRowSetTypePtr(v TSparkRowSetType) *TSparkRowSetType

+ func (p *TSparkRowSetType) Scan(value interface{}) error

+ func (p *TSparkRowSetType) UnmarshalText(text []byte) error

+ func (p *TSparkRowSetType) Value() (driver.Value, error)

+ func (p TSparkRowSetType) MarshalText() ([]byte, error)

+ func (p TSparkRowSetType) String() string

+ type TStatus struct

+ DisplayMessage *string

+ ErrorCode *int32

+ ErrorMessage *string

+ InfoMessages []string

+ SqlState *string

+ StatusCode TStatusCode

+ 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() *TStatus

+ func (p *TStatus) Equals(other *TStatus) bool

+ func (p *TStatus) GetDisplayMessage() string

+ func (p *TStatus) GetErrorCode() int32

+ func (p *TStatus) GetErrorMessage() string

+ func (p *TStatus) GetInfoMessages() []string

+ func (p *TStatus) GetSqlState() string

+ func (p *TStatus) GetStatusCode() TStatusCode

+ func (p *TStatus) IsSetDisplayMessage() bool

+ func (p *TStatus) IsSetErrorCode() bool

+ func (p *TStatus) IsSetErrorMessage() bool

+ func (p *TStatus) IsSetInfoMessages() bool

+ func (p *TStatus) IsSetSqlState() bool

+ func (p *TStatus) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStatus) String() string

+ func (p *TStatus) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TStatusCode int64

+ const TStatusCode_ERROR_STATUS

+ const TStatusCode_INVALID_HANDLE_STATUS

+ const TStatusCode_STILL_EXECUTING_STATUS

+ const TStatusCode_SUCCESS_STATUS

+ const TStatusCode_SUCCESS_WITH_INFO_STATUS

+ func TStatusCodeFromString(s string) (TStatusCode, error)

+ func TStatusCodePtr(v TStatusCode) *TStatusCode

+ func (p *TStatusCode) Scan(value interface{}) error

+ func (p *TStatusCode) UnmarshalText(text []byte) error

+ func (p *TStatusCode) Value() (driver.Value, error)

+ func (p TStatusCode) MarshalText() ([]byte, error)

+ func (p TStatusCode) String() string

+ type TStringColumn struct

+ Nulls []byte

+ Values []string

+ var TColumn_StringVal_DEFAULT *TStringColumn

+ func NewTStringColumn() *TStringColumn

+ func (p *TStringColumn) Equals(other *TStringColumn) bool

+ func (p *TStringColumn) GetNulls() []byte

+ func (p *TStringColumn) GetValues() []string

+ func (p *TStringColumn) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStringColumn) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStringColumn) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStringColumn) String() string

+ func (p *TStringColumn) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TStringValue struct

+ Value *string

+ var TColumnValue_StringVal_DEFAULT *TStringValue

+ func NewTStringValue() *TStringValue

+ func (p *TStringValue) Equals(other *TStringValue) bool

+ func (p *TStringValue) GetValue() string

+ func (p *TStringValue) IsSetValue() bool

+ func (p *TStringValue) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStringValue) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStringValue) String() string

+ func (p *TStringValue) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TStructTypeEntry struct

+ NameToTypePtr map[string]TTypeEntryPtr

+ var TTypeEntry_StructEntry_DEFAULT *TStructTypeEntry

+ func NewTStructTypeEntry() *TStructTypeEntry

+ func (p *TStructTypeEntry) Equals(other *TStructTypeEntry) bool

+ func (p *TStructTypeEntry) GetNameToTypePtr() map[string]TTypeEntryPtr

+ func (p *TStructTypeEntry) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStructTypeEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TStructTypeEntry) String() string

+ func (p *TStructTypeEntry) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TTableSchema struct

+ Columns []*TColumnDesc

+ var TGetResultSetMetadataResp_Schema_DEFAULT *TTableSchema

+ func NewTTableSchema() *TTableSchema

+ func (p *TTableSchema) Equals(other *TTableSchema) bool

+ func (p *TTableSchema) GetColumns() []*TColumnDesc

+ func (p *TTableSchema) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTableSchema) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTableSchema) String() string

+ func (p *TTableSchema) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TTypeDesc struct

+ Types []*TTypeEntry

+ var TColumnDesc_TypeDesc_DEFAULT *TTypeDesc

+ func NewTTypeDesc() *TTypeDesc

+ func (p *TTypeDesc) Equals(other *TTypeDesc) bool

+ func (p *TTypeDesc) GetTypes() []*TTypeEntry

+ func (p *TTypeDesc) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeDesc) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeDesc) String() string

+ func (p *TTypeDesc) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TTypeEntry struct

+ ArrayEntry *TArrayTypeEntry

+ MapEntry *TMapTypeEntry

+ PrimitiveEntry *TPrimitiveTypeEntry

+ StructEntry *TStructTypeEntry

+ UnionEntry *TUnionTypeEntry

+ UserDefinedTypeEntry *TUserDefinedTypeEntry

+ func NewTTypeEntry() *TTypeEntry

+ func (p *TTypeEntry) CountSetFieldsTTypeEntry() int

+ func (p *TTypeEntry) Equals(other *TTypeEntry) bool

+ func (p *TTypeEntry) GetArrayEntry() *TArrayTypeEntry

+ func (p *TTypeEntry) GetMapEntry() *TMapTypeEntry

+ func (p *TTypeEntry) GetPrimitiveEntry() *TPrimitiveTypeEntry

+ func (p *TTypeEntry) GetStructEntry() *TStructTypeEntry

+ func (p *TTypeEntry) GetUnionEntry() *TUnionTypeEntry

+ func (p *TTypeEntry) GetUserDefinedTypeEntry() *TUserDefinedTypeEntry

+ func (p *TTypeEntry) IsSetArrayEntry() bool

+ func (p *TTypeEntry) IsSetMapEntry() bool

+ func (p *TTypeEntry) IsSetPrimitiveEntry() bool

+ func (p *TTypeEntry) IsSetStructEntry() bool

+ func (p *TTypeEntry) IsSetUnionEntry() bool

+ func (p *TTypeEntry) IsSetUserDefinedTypeEntry() bool

+ func (p *TTypeEntry) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeEntry) String() string

+ func (p *TTypeEntry) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TTypeEntryPtr int32

+ func TTypeEntryPtrPtr(v TTypeEntryPtr) *TTypeEntryPtr

+ type TTypeId int64

+ const TTypeId_ARRAY_TYPE

+ const TTypeId_BIGINT_TYPE

+ const TTypeId_BINARY_TYPE

+ const TTypeId_BOOLEAN_TYPE

+ const TTypeId_CHAR_TYPE

+ const TTypeId_DATE_TYPE

+ const TTypeId_DECIMAL_TYPE

+ const TTypeId_DOUBLE_TYPE

+ const TTypeId_FLOAT_TYPE

+ const TTypeId_INTERVAL_DAY_TIME_TYPE

+ const TTypeId_INTERVAL_YEAR_MONTH_TYPE

+ const TTypeId_INT_TYPE

+ const TTypeId_MAP_TYPE

+ const TTypeId_NULL_TYPE

+ const TTypeId_SMALLINT_TYPE

+ const TTypeId_STRING_TYPE

+ const TTypeId_STRUCT_TYPE

+ const TTypeId_TIMESTAMP_TYPE

+ const TTypeId_TINYINT_TYPE

+ const TTypeId_UNION_TYPE

+ const TTypeId_USER_DEFINED_TYPE

+ const TTypeId_VARCHAR_TYPE

+ func TTypeIdFromString(s string) (TTypeId, error)

+ func TTypeIdPtr(v TTypeId) *TTypeId

+ func (p *TTypeId) Scan(value interface{}) error

+ func (p *TTypeId) UnmarshalText(text []byte) error

+ func (p *TTypeId) Value() (driver.Value, error)

+ func (p TTypeId) MarshalText() ([]byte, error)

+ func (p TTypeId) String() string

+ type TTypeQualifierValue struct

+ I32Value *int32

+ StringValue *string

+ func NewTTypeQualifierValue() *TTypeQualifierValue

+ func (p *TTypeQualifierValue) CountSetFieldsTTypeQualifierValue() int

+ func (p *TTypeQualifierValue) Equals(other *TTypeQualifierValue) bool

+ func (p *TTypeQualifierValue) GetI32Value() int32

+ func (p *TTypeQualifierValue) GetStringValue() string

+ func (p *TTypeQualifierValue) IsSetI32Value() bool

+ func (p *TTypeQualifierValue) IsSetStringValue() bool

+ func (p *TTypeQualifierValue) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeQualifierValue) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeQualifierValue) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeQualifierValue) String() string

+ func (p *TTypeQualifierValue) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TTypeQualifiers struct

+ Qualifiers map[string]*TTypeQualifierValue

+ var TPrimitiveTypeEntry_TypeQualifiers_DEFAULT *TTypeQualifiers

+ func NewTTypeQualifiers() *TTypeQualifiers

+ func (p *TTypeQualifiers) Equals(other *TTypeQualifiers) bool

+ func (p *TTypeQualifiers) GetQualifiers() map[string]*TTypeQualifierValue

+ func (p *TTypeQualifiers) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeQualifiers) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TTypeQualifiers) String() string

+ func (p *TTypeQualifiers) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TUnionTypeEntry struct

+ NameToTypePtr map[string]TTypeEntryPtr

+ var TTypeEntry_UnionEntry_DEFAULT *TUnionTypeEntry

+ func NewTUnionTypeEntry() *TUnionTypeEntry

+ func (p *TUnionTypeEntry) Equals(other *TUnionTypeEntry) bool

+ func (p *TUnionTypeEntry) GetNameToTypePtr() map[string]TTypeEntryPtr

+ func (p *TUnionTypeEntry) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TUnionTypeEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TUnionTypeEntry) String() string

+ func (p *TUnionTypeEntry) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TUserDefinedTypeEntry struct

+ TypeClassName string

+ var TTypeEntry_UserDefinedTypeEntry_DEFAULT *TUserDefinedTypeEntry

+ func NewTUserDefinedTypeEntry() *TUserDefinedTypeEntry

+ func (p *TUserDefinedTypeEntry) Equals(other *TUserDefinedTypeEntry) bool

+ func (p *TUserDefinedTypeEntry) GetTypeClassName() string

+ func (p *TUserDefinedTypeEntry) Read(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TUserDefinedTypeEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TUserDefinedTypeEntry) String() string

+ func (p *TUserDefinedTypeEntry) Write(ctx context.Context, oprot thrift.TProtocol) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL