Documentation
¶
Index ¶
- Variables
- type TBinaryPredicate
- func (p *TBinaryPredicate) Equals(other *TBinaryPredicate) bool
- func (p *TBinaryPredicate) GetCol() *TColumnDesc
- func (p *TBinaryPredicate) GetOp() TComparisonOp
- func (p *TBinaryPredicate) GetValue() *data.TColumnValue
- func (p *TBinaryPredicate) IsSetCol() bool
- func (p *TBinaryPredicate) IsSetOp() bool
- func (p *TBinaryPredicate) IsSetValue() bool
- func (p *TBinaryPredicate) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TBinaryPredicate) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TBinaryPredicate) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TBinaryPredicate) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TBinaryPredicate) String() string
- func (p *TBinaryPredicate) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TCloseParams
- func (p *TCloseParams) Equals(other *TCloseParams) bool
- func (p *TCloseParams) GetScanHandle() string
- func (p *TCloseParams) IsSetScanHandle() bool
- func (p *TCloseParams) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TCloseParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TCloseParams) String() string
- func (p *TCloseParams) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TCloseResult_
- func (p *TCloseResult_) Equals(other *TCloseResult_) bool
- func (p *TCloseResult_) GetStatus() *status.TStatus
- func (p *TCloseResult_) IsSetStatus() bool
- func (p *TCloseResult_) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TCloseResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TCloseResult_) String() string
- func (p *TCloseResult_) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TColumnDesc
- func (p *TColumnDesc) Equals(other *TColumnDesc) bool
- func (p *TColumnDesc) GetName() string
- func (p *TColumnDesc) GetType() *types.TColumnType
- func (p *TColumnDesc) IsSetName() bool
- func (p *TColumnDesc) IsSetType() 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) String() string
- func (p *TColumnDesc) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TComparisonOp
- type TGetNextParams
- func (p *TGetNextParams) Equals(other *TGetNextParams) bool
- func (p *TGetNextParams) GetScanHandle() string
- func (p *TGetNextParams) IsSetScanHandle() bool
- func (p *TGetNextParams) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TGetNextParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TGetNextParams) String() string
- func (p *TGetNextParams) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TGetNextResult_
- func (p *TGetNextResult_) Equals(other *TGetNextResult_) bool
- func (p *TGetNextResult_) GetEos() bool
- func (p *TGetNextResult_) GetRows() *TRowBatch
- func (p *TGetNextResult_) GetStatus() *status.TStatus
- func (p *TGetNextResult_) IsSetEos() bool
- func (p *TGetNextResult_) IsSetRows() bool
- func (p *TGetNextResult_) IsSetStatus() bool
- func (p *TGetNextResult_) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TGetNextResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TGetNextResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TGetNextResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TGetNextResult_) String() string
- func (p *TGetNextResult_) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TOpenParams
- func (p *TOpenParams) Equals(other *TOpenParams) bool
- func (p *TOpenParams) GetAuthenticatedUserName() string
- func (p *TOpenParams) GetBatchSize() int32
- func (p *TOpenParams) GetInitString() string
- func (p *TOpenParams) GetLimit() int64
- func (p *TOpenParams) GetPredicates() [][]*TBinaryPredicate
- func (p *TOpenParams) GetQueryID() *types.TUniqueId
- func (p *TOpenParams) GetRowSchema() *TTableSchema
- func (p *TOpenParams) GetTableName() string
- func (p *TOpenParams) IsSetAuthenticatedUserName() bool
- func (p *TOpenParams) IsSetBatchSize() bool
- func (p *TOpenParams) IsSetInitString() bool
- func (p *TOpenParams) IsSetLimit() bool
- func (p *TOpenParams) IsSetPredicates() bool
- func (p *TOpenParams) IsSetQueryID() bool
- func (p *TOpenParams) IsSetRowSchema() bool
- func (p *TOpenParams) IsSetTableName() bool
- func (p *TOpenParams) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField4(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField5(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField6(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField7(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) ReadField8(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenParams) String() string
- func (p *TOpenParams) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TOpenResult_
- func (p *TOpenResult_) Equals(other *TOpenResult_) bool
- func (p *TOpenResult_) GetScanHandle() string
- func (p *TOpenResult_) GetStatus() *status.TStatus
- func (p *TOpenResult_) IsSetScanHandle() bool
- func (p *TOpenResult_) IsSetStatus() bool
- func (p *TOpenResult_) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TOpenResult_) String() string
- func (p *TOpenResult_) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TPrepareParams
- func (p *TPrepareParams) Equals(other *TPrepareParams) bool
- func (p *TPrepareParams) GetInitString() string
- func (p *TPrepareParams) GetPredicates() [][]*TBinaryPredicate
- func (p *TPrepareParams) GetTableName() string
- func (p *TPrepareParams) IsSetInitString() bool
- func (p *TPrepareParams) IsSetPredicates() bool
- func (p *TPrepareParams) IsSetTableName() bool
- func (p *TPrepareParams) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareParams) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareParams) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareParams) String() string
- func (p *TPrepareParams) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TPrepareResult_
- func (p *TPrepareResult_) Equals(other *TPrepareResult_) bool
- func (p *TPrepareResult_) GetAcceptedConjuncts() []int32
- func (p *TPrepareResult_) GetNumRowsEstimate() int64
- func (p *TPrepareResult_) GetStatus() *status.TStatus
- func (p *TPrepareResult_) IsSetAcceptedConjuncts() bool
- func (p *TPrepareResult_) IsSetNumRowsEstimate() bool
- func (p *TPrepareResult_) IsSetStatus() bool
- func (p *TPrepareResult_) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TPrepareResult_) String() string
- func (p *TPrepareResult_) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TRowBatch
- func (p *TRowBatch) Equals(other *TRowBatch) bool
- func (p *TRowBatch) GetCols() []*data.TColumnData
- func (p *TRowBatch) GetNumRows() int64
- func (p *TRowBatch) IsSetCols() bool
- func (p *TRowBatch) IsSetNumRows() bool
- func (p *TRowBatch) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TRowBatch) ReadField1(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TRowBatch) ReadField2(ctx context.Context, iprot thrift.TProtocol) error
- func (p *TRowBatch) String() string
- func (p *TRowBatch) Write(ctx context.Context, oprot thrift.TProtocol) error
- type TTableSchema
- func (p *TTableSchema) Equals(other *TTableSchema) bool
- func (p *TTableSchema) GetCols() []*TColumnDesc
- func (p *TTableSchema) IsSetCols() bool
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var GoUnusedProtection__ int
View Source
var TBinaryPredicate_Value_DEFAULT *data.TColumnValue
View Source
var TCloseParams_ScanHandle_DEFAULT string
View Source
var TCloseResult__Status_DEFAULT *status.TStatus
View Source
var TColumnDesc_Name_DEFAULT string
View Source
var TColumnDesc_Type_DEFAULT *types.TColumnType
View Source
var TGetNextParams_ScanHandle_DEFAULT string
View Source
var TGetNextResult__Eos_DEFAULT bool
View Source
var TGetNextResult__Status_DEFAULT *status.TStatus
View Source
var TOpenParams_AuthenticatedUserName_DEFAULT string
View Source
var TOpenParams_BatchSize_DEFAULT int32
View Source
var TOpenParams_InitString_DEFAULT string
View Source
var TOpenParams_Limit_DEFAULT int64
View Source
var TOpenParams_Predicates_DEFAULT [][]*TBinaryPredicate
View Source
var TOpenParams_QueryID_DEFAULT *types.TUniqueId
View Source
var TOpenParams_TableName_DEFAULT string
View Source
var TOpenResult__ScanHandle_DEFAULT string
View Source
var TOpenResult__Status_DEFAULT *status.TStatus
View Source
var TPrepareParams_InitString_DEFAULT string
View Source
var TPrepareParams_Predicates_DEFAULT [][]*TBinaryPredicate
View Source
var TPrepareParams_TableName_DEFAULT string
View Source
var TPrepareResult__AcceptedConjuncts_DEFAULT []int32
View Source
var TPrepareResult__NumRowsEstimate_DEFAULT int64
View Source
var TPrepareResult__Status_DEFAULT *status.TStatus
View Source
var TRowBatch_Cols_DEFAULT []*data.TColumnData
View Source
var TRowBatch_NumRows_DEFAULT int64
View Source
var TTableSchema_Cols_DEFAULT []*TColumnDesc
Functions ¶
This section is empty.
Types ¶
type TBinaryPredicate ¶
type TBinaryPredicate struct { Col *TColumnDesc `thrift:"col,1" db:"col" json:"col,omitempty"` Op *TComparisonOp `thrift:"op,2" db:"op" json:"op,omitempty"` Value *data.TColumnValue `thrift:"value,3" db:"value" json:"value,omitempty"` }
Attributes:
- Col
- Op
- Value
func NewTBinaryPredicate ¶
func NewTBinaryPredicate() *TBinaryPredicate
func (*TBinaryPredicate) Equals ¶ added in v0.16.0
func (p *TBinaryPredicate) Equals(other *TBinaryPredicate) bool
func (*TBinaryPredicate) GetCol ¶
func (p *TBinaryPredicate) GetCol() *TColumnDesc
func (*TBinaryPredicate) GetOp ¶
func (p *TBinaryPredicate) GetOp() TComparisonOp
func (*TBinaryPredicate) GetValue ¶
func (p *TBinaryPredicate) GetValue() *data.TColumnValue
func (*TBinaryPredicate) IsSetCol ¶
func (p *TBinaryPredicate) IsSetCol() bool
func (*TBinaryPredicate) IsSetOp ¶
func (p *TBinaryPredicate) IsSetOp() bool
func (*TBinaryPredicate) IsSetValue ¶
func (p *TBinaryPredicate) IsSetValue() bool
func (*TBinaryPredicate) ReadField1 ¶
func (*TBinaryPredicate) ReadField2 ¶
func (*TBinaryPredicate) ReadField3 ¶
func (*TBinaryPredicate) String ¶
func (p *TBinaryPredicate) String() string
type TCloseParams ¶
type TCloseParams struct {
ScanHandle *string `thrift:"scan_handle,1" db:"scan_handle" json:"scan_handle,omitempty"`
}
Attributes:
- ScanHandle
func NewTCloseParams ¶
func NewTCloseParams() *TCloseParams
func (*TCloseParams) Equals ¶ added in v0.16.0
func (p *TCloseParams) Equals(other *TCloseParams) bool
func (*TCloseParams) GetScanHandle ¶
func (p *TCloseParams) GetScanHandle() string
func (*TCloseParams) IsSetScanHandle ¶
func (p *TCloseParams) IsSetScanHandle() bool
func (*TCloseParams) ReadField1 ¶
func (*TCloseParams) String ¶
func (p *TCloseParams) String() string
type TCloseResult_ ¶
type TCloseResult_ struct {
Status *status.TStatus `thrift:"status,1,required" db:"status" json:"status"`
}
Attributes:
- Status
func NewTCloseResult_ ¶
func NewTCloseResult_() *TCloseResult_
func (*TCloseResult_) Equals ¶ added in v0.16.0
func (p *TCloseResult_) Equals(other *TCloseResult_) bool
func (*TCloseResult_) GetStatus ¶
func (p *TCloseResult_) GetStatus() *status.TStatus
func (*TCloseResult_) IsSetStatus ¶
func (p *TCloseResult_) IsSetStatus() bool
func (*TCloseResult_) ReadField1 ¶
func (*TCloseResult_) String ¶
func (p *TCloseResult_) String() string
type TColumnDesc ¶
type TColumnDesc struct { Name *string `thrift:"name,1" db:"name" json:"name,omitempty"` Type *types.TColumnType `thrift:"type,2" db:"type" json:"type,omitempty"` }
Attributes:
- Name
- Type
var TBinaryPredicate_Col_DEFAULT *TColumnDesc
func NewTColumnDesc ¶
func NewTColumnDesc() *TColumnDesc
func (*TColumnDesc) Equals ¶ added in v0.16.0
func (p *TColumnDesc) Equals(other *TColumnDesc) bool
func (*TColumnDesc) GetName ¶
func (p *TColumnDesc) GetName() string
func (*TColumnDesc) GetType ¶
func (p *TColumnDesc) GetType() *types.TColumnType
func (*TColumnDesc) IsSetName ¶
func (p *TColumnDesc) IsSetName() bool
func (*TColumnDesc) IsSetType ¶
func (p *TColumnDesc) IsSetType() bool
func (*TColumnDesc) ReadField1 ¶
func (*TColumnDesc) ReadField2 ¶
func (*TColumnDesc) String ¶
func (p *TColumnDesc) String() string
type TComparisonOp ¶
type TComparisonOp int64
const ( TComparisonOp_LT TComparisonOp = 0 TComparisonOp_LE TComparisonOp = 1 TComparisonOp_EQ TComparisonOp = 2 TComparisonOp_NE TComparisonOp = 3 TComparisonOp_GE TComparisonOp = 4 TComparisonOp_GT TComparisonOp = 5 TComparisonOp_DISTINCT_FROM TComparisonOp = 6 TComparisonOp_NOT_DISTINCT TComparisonOp = 7 )
var TBinaryPredicate_Op_DEFAULT TComparisonOp
func TComparisonOpFromString ¶
func TComparisonOpFromString(s string) (TComparisonOp, error)
func TComparisonOpPtr ¶
func TComparisonOpPtr(v TComparisonOp) *TComparisonOp
func (TComparisonOp) MarshalText ¶
func (p TComparisonOp) MarshalText() ([]byte, error)
func (*TComparisonOp) Scan ¶
func (p *TComparisonOp) Scan(value interface{}) error
func (TComparisonOp) String ¶
func (p TComparisonOp) String() string
func (*TComparisonOp) UnmarshalText ¶
func (p *TComparisonOp) UnmarshalText(text []byte) error
type TGetNextParams ¶
type TGetNextParams struct {
ScanHandle *string `thrift:"scan_handle,1" db:"scan_handle" json:"scan_handle,omitempty"`
}
Attributes:
- ScanHandle
func NewTGetNextParams ¶
func NewTGetNextParams() *TGetNextParams
func (*TGetNextParams) Equals ¶ added in v0.16.0
func (p *TGetNextParams) Equals(other *TGetNextParams) bool
func (*TGetNextParams) GetScanHandle ¶
func (p *TGetNextParams) GetScanHandle() string
func (*TGetNextParams) IsSetScanHandle ¶
func (p *TGetNextParams) IsSetScanHandle() bool
func (*TGetNextParams) ReadField1 ¶
func (*TGetNextParams) String ¶
func (p *TGetNextParams) String() string
type TGetNextResult_ ¶
type TGetNextResult_ struct { Status *status.TStatus `thrift:"status,1,required" db:"status" json:"status"` Eos *bool `thrift:"eos,2" db:"eos" json:"eos,omitempty"` Rows *TRowBatch `thrift:"rows,3" db:"rows" json:"rows,omitempty"` }
Attributes:
- Status
- Eos
- Rows
func NewTGetNextResult_ ¶
func NewTGetNextResult_() *TGetNextResult_
func (*TGetNextResult_) Equals ¶ added in v0.16.0
func (p *TGetNextResult_) Equals(other *TGetNextResult_) bool
func (*TGetNextResult_) GetEos ¶
func (p *TGetNextResult_) GetEos() bool
func (*TGetNextResult_) GetRows ¶
func (p *TGetNextResult_) GetRows() *TRowBatch
func (*TGetNextResult_) GetStatus ¶
func (p *TGetNextResult_) GetStatus() *status.TStatus
func (*TGetNextResult_) IsSetEos ¶
func (p *TGetNextResult_) IsSetEos() bool
func (*TGetNextResult_) IsSetRows ¶
func (p *TGetNextResult_) IsSetRows() bool
func (*TGetNextResult_) IsSetStatus ¶
func (p *TGetNextResult_) IsSetStatus() bool
func (*TGetNextResult_) ReadField1 ¶
func (*TGetNextResult_) ReadField2 ¶
func (*TGetNextResult_) ReadField3 ¶
func (*TGetNextResult_) String ¶
func (p *TGetNextResult_) String() string
type TOpenParams ¶
type TOpenParams struct { QueryID *types.TUniqueId `thrift:"query_id,1" db:"query_id" json:"query_id,omitempty"` TableName *string `thrift:"table_name,2" db:"table_name" json:"table_name,omitempty"` InitString *string `thrift:"init_string,3" db:"init_string" json:"init_string,omitempty"` AuthenticatedUserName *string `thrift:"authenticated_user_name,4" db:"authenticated_user_name" json:"authenticated_user_name,omitempty"` RowSchema *TTableSchema `thrift:"row_schema,5" db:"row_schema" json:"row_schema,omitempty"` BatchSize *int32 `thrift:"batch_size,6" db:"batch_size" json:"batch_size,omitempty"` Predicates [][]*TBinaryPredicate `thrift:"predicates,7" db:"predicates" json:"predicates,omitempty"` Limit *int64 `thrift:"limit,8" db:"limit" json:"limit,omitempty"` }
Attributes:
- QueryID
- TableName
- InitString
- AuthenticatedUserName
- RowSchema
- BatchSize
- Predicates
- Limit
func NewTOpenParams ¶
func NewTOpenParams() *TOpenParams
func (*TOpenParams) Equals ¶ added in v0.16.0
func (p *TOpenParams) Equals(other *TOpenParams) bool
func (*TOpenParams) GetAuthenticatedUserName ¶
func (p *TOpenParams) GetAuthenticatedUserName() string
func (*TOpenParams) GetBatchSize ¶
func (p *TOpenParams) GetBatchSize() int32
func (*TOpenParams) GetInitString ¶
func (p *TOpenParams) GetInitString() string
func (*TOpenParams) GetLimit ¶
func (p *TOpenParams) GetLimit() int64
func (*TOpenParams) GetPredicates ¶
func (p *TOpenParams) GetPredicates() [][]*TBinaryPredicate
func (*TOpenParams) GetQueryID ¶
func (p *TOpenParams) GetQueryID() *types.TUniqueId
func (*TOpenParams) GetRowSchema ¶
func (p *TOpenParams) GetRowSchema() *TTableSchema
func (*TOpenParams) GetTableName ¶
func (p *TOpenParams) GetTableName() string
func (*TOpenParams) IsSetAuthenticatedUserName ¶
func (p *TOpenParams) IsSetAuthenticatedUserName() bool
func (*TOpenParams) IsSetBatchSize ¶
func (p *TOpenParams) IsSetBatchSize() bool
func (*TOpenParams) IsSetInitString ¶
func (p *TOpenParams) IsSetInitString() bool
func (*TOpenParams) IsSetLimit ¶
func (p *TOpenParams) IsSetLimit() bool
func (*TOpenParams) IsSetPredicates ¶
func (p *TOpenParams) IsSetPredicates() bool
func (*TOpenParams) IsSetQueryID ¶
func (p *TOpenParams) IsSetQueryID() bool
func (*TOpenParams) IsSetRowSchema ¶
func (p *TOpenParams) IsSetRowSchema() bool
func (*TOpenParams) IsSetTableName ¶
func (p *TOpenParams) IsSetTableName() bool
func (*TOpenParams) ReadField1 ¶
func (*TOpenParams) ReadField2 ¶
func (*TOpenParams) ReadField3 ¶
func (*TOpenParams) ReadField4 ¶
func (*TOpenParams) ReadField5 ¶
func (*TOpenParams) ReadField6 ¶
func (*TOpenParams) ReadField7 ¶
func (*TOpenParams) ReadField8 ¶
func (*TOpenParams) String ¶
func (p *TOpenParams) String() string
type TOpenResult_ ¶
type TOpenResult_ struct { Status *status.TStatus `thrift:"status,1,required" db:"status" json:"status"` ScanHandle *string `thrift:"scan_handle,2" db:"scan_handle" json:"scan_handle,omitempty"` }
Attributes:
- Status
- ScanHandle
func NewTOpenResult_ ¶
func NewTOpenResult_() *TOpenResult_
func (*TOpenResult_) Equals ¶ added in v0.16.0
func (p *TOpenResult_) Equals(other *TOpenResult_) bool
func (*TOpenResult_) GetScanHandle ¶
func (p *TOpenResult_) GetScanHandle() string
func (*TOpenResult_) GetStatus ¶
func (p *TOpenResult_) GetStatus() *status.TStatus
func (*TOpenResult_) IsSetScanHandle ¶
func (p *TOpenResult_) IsSetScanHandle() bool
func (*TOpenResult_) IsSetStatus ¶
func (p *TOpenResult_) IsSetStatus() bool
func (*TOpenResult_) ReadField1 ¶
func (*TOpenResult_) ReadField2 ¶
func (*TOpenResult_) String ¶
func (p *TOpenResult_) String() string
type TPrepareParams ¶
type TPrepareParams struct { TableName *string `thrift:"table_name,1" db:"table_name" json:"table_name,omitempty"` InitString *string `thrift:"init_string,2" db:"init_string" json:"init_string,omitempty"` Predicates [][]*TBinaryPredicate `thrift:"predicates,3" db:"predicates" json:"predicates,omitempty"` }
Attributes:
- TableName
- InitString
- Predicates
func NewTPrepareParams ¶
func NewTPrepareParams() *TPrepareParams
func (*TPrepareParams) Equals ¶ added in v0.16.0
func (p *TPrepareParams) Equals(other *TPrepareParams) bool
func (*TPrepareParams) GetInitString ¶
func (p *TPrepareParams) GetInitString() string
func (*TPrepareParams) GetPredicates ¶
func (p *TPrepareParams) GetPredicates() [][]*TBinaryPredicate
func (*TPrepareParams) GetTableName ¶
func (p *TPrepareParams) GetTableName() string
func (*TPrepareParams) IsSetInitString ¶
func (p *TPrepareParams) IsSetInitString() bool
func (*TPrepareParams) IsSetPredicates ¶
func (p *TPrepareParams) IsSetPredicates() bool
func (*TPrepareParams) IsSetTableName ¶
func (p *TPrepareParams) IsSetTableName() bool
func (*TPrepareParams) ReadField1 ¶
func (*TPrepareParams) ReadField2 ¶
func (*TPrepareParams) ReadField3 ¶
func (*TPrepareParams) String ¶
func (p *TPrepareParams) String() string
type TPrepareResult_ ¶
type TPrepareResult_ struct { Status *status.TStatus `thrift:"status,1,required" db:"status" json:"status"` NumRowsEstimate *int64 `thrift:"num_rows_estimate,2" db:"num_rows_estimate" json:"num_rows_estimate,omitempty"` AcceptedConjuncts []int32 `thrift:"accepted_conjuncts,3" db:"accepted_conjuncts" json:"accepted_conjuncts,omitempty"` }
Attributes:
- Status
- NumRowsEstimate
- AcceptedConjuncts
func NewTPrepareResult_ ¶
func NewTPrepareResult_() *TPrepareResult_
func (*TPrepareResult_) Equals ¶ added in v0.16.0
func (p *TPrepareResult_) Equals(other *TPrepareResult_) bool
func (*TPrepareResult_) GetAcceptedConjuncts ¶
func (p *TPrepareResult_) GetAcceptedConjuncts() []int32
func (*TPrepareResult_) GetNumRowsEstimate ¶
func (p *TPrepareResult_) GetNumRowsEstimate() int64
func (*TPrepareResult_) GetStatus ¶
func (p *TPrepareResult_) GetStatus() *status.TStatus
func (*TPrepareResult_) IsSetAcceptedConjuncts ¶
func (p *TPrepareResult_) IsSetAcceptedConjuncts() bool
func (*TPrepareResult_) IsSetNumRowsEstimate ¶
func (p *TPrepareResult_) IsSetNumRowsEstimate() bool
func (*TPrepareResult_) IsSetStatus ¶
func (p *TPrepareResult_) IsSetStatus() bool
func (*TPrepareResult_) ReadField1 ¶
func (*TPrepareResult_) ReadField2 ¶
func (*TPrepareResult_) ReadField3 ¶
func (*TPrepareResult_) String ¶
func (p *TPrepareResult_) String() string
type TRowBatch ¶
type TRowBatch struct { Cols []*data.TColumnData `thrift:"cols,1" db:"cols" json:"cols,omitempty"` NumRows *int64 `thrift:"num_rows,2" db:"num_rows" json:"num_rows,omitempty"` }
Attributes:
- Cols
- NumRows
var TGetNextResult__Rows_DEFAULT *TRowBatch
func NewTRowBatch ¶
func NewTRowBatch() *TRowBatch
func (*TRowBatch) GetCols ¶
func (p *TRowBatch) GetCols() []*data.TColumnData
func (*TRowBatch) GetNumRows ¶
func (*TRowBatch) IsSetNumRows ¶
func (*TRowBatch) ReadField1 ¶
func (*TRowBatch) ReadField2 ¶
type TTableSchema ¶
type TTableSchema struct {
Cols []*TColumnDesc `thrift:"cols,1" db:"cols" json:"cols,omitempty"`
}
Attributes:
- Cols
var TOpenParams_RowSchema_DEFAULT *TTableSchema
func NewTTableSchema ¶
func NewTTableSchema() *TTableSchema
func (*TTableSchema) Equals ¶ added in v0.16.0
func (p *TTableSchema) Equals(other *TTableSchema) bool
func (*TTableSchema) GetCols ¶
func (p *TTableSchema) GetCols() []*TColumnDesc
func (*TTableSchema) IsSetCols ¶
func (p *TTableSchema) IsSetCols() bool
func (*TTableSchema) ReadField1 ¶
func (*TTableSchema) String ¶
func (p *TTableSchema) String() string
Click to show internal directories.
Click to hide internal directories.