hbase

package
v0.1.4-alpha Latest Latest
Warning

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

Go to latest
Published: Mar 23, 2022 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int
View Source
var TAccessControlEntity_NsName_DEFAULT string
View Source
var TAccessControlEntity_TableName_DEFAULT string
View Source
var TAppend_Attributes_DEFAULT map[string][]byte
View Source
var TAppend_ReturnResults_DEFAULT bool
View Source
var TAuthorization_Labels_DEFAULT []string
View Source
var TCellVisibility_Expression_DEFAULT string
View Source
var TColumnFamilyDescriptor_Attributes_DEFAULT map[string][]byte
View Source
var TColumnFamilyDescriptor_BlockCacheEnabled_DEFAULT bool
View Source
var TColumnFamilyDescriptor_BlockSize_DEFAULT int32
View Source
var TColumnFamilyDescriptor_CacheBloomsOnWrite_DEFAULT bool
View Source
var TColumnFamilyDescriptor_CacheDataOnWrite_DEFAULT bool
View Source
var TColumnFamilyDescriptor_CacheIndexesOnWrite_DEFAULT bool
View Source
var TColumnFamilyDescriptor_CompressTags_DEFAULT bool
View Source
var TColumnFamilyDescriptor_Configuration_DEFAULT map[string]string
View Source
var TColumnFamilyDescriptor_DfsReplication_DEFAULT int16
View Source
var TColumnFamilyDescriptor_EvictBlocksOnClose_DEFAULT bool
View Source
var TColumnFamilyDescriptor_InMemory_DEFAULT bool
View Source
var TColumnFamilyDescriptor_MaxVersions_DEFAULT int32
View Source
var TColumnFamilyDescriptor_MinVersions_DEFAULT int32
View Source
var TColumnFamilyDescriptor_Scope_DEFAULT int32
View Source
var TColumnFamilyDescriptor_TimeToLive_DEFAULT int32
View Source
var TColumnIncrement_Amount_DEFAULT int64 = 1
View Source
var TColumnValue_Tags_DEFAULT []byte
View Source
var TColumnValue_Timestamp_DEFAULT int64
View Source
var TColumnValue_Type_DEFAULT int8
View Source
var TColumn_Qualifier_DEFAULT []byte
View Source
var TColumn_Timestamp_DEFAULT int64
View Source
var TDelete_Attributes_DEFAULT map[string][]byte
View Source
var TDelete_Columns_DEFAULT []*TColumn
View Source
var TDelete_Timestamp_DEFAULT int64
View Source
var TGet_Attributes_DEFAULT map[string][]byte
View Source
var TGet_CacheBlocks_DEFAULT bool
View Source
var TGet_Columns_DEFAULT []*TColumn
View Source
var TGet_ExistenceOnly_DEFAULT bool
View Source
var TGet_FilterBytes_DEFAULT []byte
View Source
var TGet_FilterString_DEFAULT []byte
View Source
var TGet_MaxVersions_DEFAULT int32
View Source
var TGet_StoreLimit_DEFAULT int32
View Source
var TGet_StoreOffset_DEFAULT int32
View Source
var TGet_TargetReplicaId_DEFAULT int32
View Source
var TGet_Timestamp_DEFAULT int64
View Source
var THBaseServiceCheckAndDeleteResult_Success_DEFAULT bool
View Source
var THBaseServiceCheckAndMutateResult_Success_DEFAULT bool
View Source
var THBaseServiceCheckAndPutResult_Success_DEFAULT bool
View Source
var THBaseServiceClearSlowLogResponsesResult_Success_DEFAULT []bool
View Source
var THBaseServiceDeleteMultipleResult_Success_DEFAULT []*TDelete
View Source
var THBaseServiceExistsAllResult_Success_DEFAULT []bool
View Source
var THBaseServiceExistsResult_Success_DEFAULT bool
View Source
var THBaseServiceGetAllRegionLocationsResult_Success_DEFAULT []*THRegionLocation
View Source
var THBaseServiceGetClusterIdResult_Success_DEFAULT string
View Source
var THBaseServiceGetMultipleResult_Success_DEFAULT []*TResult_
View Source
var THBaseServiceGetScannerResultsResult_Success_DEFAULT []*TResult_
View Source
var THBaseServiceGetScannerRowsResult_Success_DEFAULT []*TResult_
View Source
var THBaseServiceGetSlowLogResponsesResult_Success_DEFAULT []*TOnlineLogRecord
View Source
var THBaseServiceGetTableDescriptorsByNamespaceResult_Success_DEFAULT []*TTableDescriptor
View Source
var THBaseServiceGetTableDescriptorsByPatternResult_Success_DEFAULT []*TTableDescriptor
View Source
var THBaseServiceGetTableDescriptorsResult_Success_DEFAULT []*TTableDescriptor
View Source
var THBaseServiceGetTableNamesByNamespaceResult_Success_DEFAULT []*TTableName
View Source
var THBaseServiceGetTableNamesByPatternResult_Success_DEFAULT []*TTableName
View Source
var THBaseServiceGrantResult_Success_DEFAULT bool
View Source
var THBaseServiceIsTableAvailableResult_Success_DEFAULT bool
View Source
var THBaseServiceIsTableAvailableWithSplitResult_Success_DEFAULT bool
View Source
var THBaseServiceIsTableDisabledResult_Success_DEFAULT bool
View Source
var THBaseServiceIsTableEnabledResult_Success_DEFAULT bool
View Source
var THBaseServiceListNamespaceDescriptorsResult_Success_DEFAULT []*TNamespaceDescriptor
View Source
var THBaseServiceListNamespacesResult_Success_DEFAULT []string
View Source
var THBaseServiceOpenScannerResult_Success_DEFAULT int32
View Source
var THBaseServiceRevokeResult_Success_DEFAULT bool
View Source
var THBaseServiceTableExistsResult_Success_DEFAULT bool
View Source
var THRegionInfo_EndKey_DEFAULT []byte
View Source
var THRegionInfo_Offline_DEFAULT bool
View Source
var THRegionInfo_ReplicaId_DEFAULT int32
View Source
var THRegionInfo_Split_DEFAULT bool
View Source
var THRegionInfo_StartKey_DEFAULT []byte
View Source
var TIOError_CanRetry_DEFAULT bool
View Source
var TIOError_Message_DEFAULT string
View Source
var TIllegalArgument_Message_DEFAULT string
View Source
var TIncrement_Attributes_DEFAULT map[string][]byte
View Source
var TIncrement_ReturnResults_DEFAULT bool
View Source
var TLogQueryFilter_ClientAddress_DEFAULT string
View Source
var TLogQueryFilter_Limit_DEFAULT int32 = 10
View Source
var TLogQueryFilter_RegionName_DEFAULT string
View Source
var TLogQueryFilter_TableName_DEFAULT string
View Source
var TLogQueryFilter_UserName_DEFAULT string
View Source
var TNamespaceDescriptor_Configuration_DEFAULT map[string]string
View Source
var TOnlineLogRecord_RegionName_DEFAULT string
View Source
var TPut_Attributes_DEFAULT map[string][]byte
View Source
var TPut_Timestamp_DEFAULT int64
View Source
var TResult__Partial_DEFAULT bool = false
View Source
var TResult__Row_DEFAULT []byte
View Source
var TResult__Stale_DEFAULT bool = false
View Source
var TScan_Attributes_DEFAULT map[string][]byte
View Source
var TScan_BatchSize_DEFAULT int32
View Source
var TScan_CacheBlocks_DEFAULT bool
View Source
var TScan_Caching_DEFAULT int32
View Source
var TScan_ColFamTimeRangeMap_DEFAULT map[string]*TTimeRange
View Source
var TScan_Columns_DEFAULT []*TColumn
View Source
var TScan_FilterBytes_DEFAULT []byte
View Source
var TScan_FilterString_DEFAULT []byte
View Source
var TScan_Limit_DEFAULT int32
View Source
var TScan_MaxVersions_DEFAULT int32 = 1
View Source
var TScan_Reversed_DEFAULT bool
View Source
var TScan_StartRow_DEFAULT []byte
View Source
var TScan_StopRow_DEFAULT []byte
View Source
var TScan_TargetReplicaId_DEFAULT int32
View Source
var TServerName_Port_DEFAULT int32
View Source
var TServerName_StartCode_DEFAULT int64
View Source
var TTableDescriptor_Attributes_DEFAULT map[string][]byte
View Source
var TTableDescriptor_Columns_DEFAULT []*TColumnFamilyDescriptor
View Source
var TTableName_Ns_DEFAULT []byte

Functions

This section is empty.

Types

type TAccessControlEntity

type TAccessControlEntity struct {
	Username string           `thrift:"username,1,required" db:"username" json:"username"`
	Scope    TPermissionScope `thrift:"scope,2,required" db:"scope" json:"scope"`
	// unused field # 3
	Actions   string  `thrift:"actions,4,required" db:"actions" json:"actions"`
	TableName *string `thrift:"tableName,5" db:"tableName" json:"tableName,omitempty"`
	NsName    *string `thrift:"nsName,6" db:"nsName" json:"nsName,omitempty"`
}

TAccessControlEntity for permission control

Attributes:

  • Username
  • Scope
  • Actions
  • TableName
  • NsName
var THBaseServiceGrantArgs_Info_DEFAULT *TAccessControlEntity
var THBaseServiceRevokeArgs_Info_DEFAULT *TAccessControlEntity

func NewTAccessControlEntity

func NewTAccessControlEntity() *TAccessControlEntity

func (*TAccessControlEntity) Equals

func (*TAccessControlEntity) GetActions

func (p *TAccessControlEntity) GetActions() string

func (*TAccessControlEntity) GetNsName

func (p *TAccessControlEntity) GetNsName() string

func (*TAccessControlEntity) GetScope

func (p *TAccessControlEntity) GetScope() TPermissionScope

func (*TAccessControlEntity) GetTableName

func (p *TAccessControlEntity) GetTableName() string

func (*TAccessControlEntity) GetUsername

func (p *TAccessControlEntity) GetUsername() string

func (*TAccessControlEntity) IsSetNsName

func (p *TAccessControlEntity) IsSetNsName() bool

func (*TAccessControlEntity) IsSetTableName

func (p *TAccessControlEntity) IsSetTableName() bool

func (*TAccessControlEntity) Read

func (*TAccessControlEntity) ReadField1

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

func (*TAccessControlEntity) ReadField2

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

func (*TAccessControlEntity) ReadField4

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

func (*TAccessControlEntity) ReadField5

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

func (*TAccessControlEntity) ReadField6

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

func (*TAccessControlEntity) String

func (p *TAccessControlEntity) String() string

func (*TAccessControlEntity) Write

type TAppend

type TAppend struct {
	Row            []byte            `thrift:"row,1,required" db:"row" json:"row"`
	Columns        []*TColumnValue   `thrift:"columns,2,required" db:"columns" json:"columns"`
	Attributes     map[string][]byte `thrift:"attributes,3" db:"attributes" json:"attributes,omitempty"`
	Durability     *TDurability      `thrift:"durability,4" db:"durability" json:"durability,omitempty"`
	CellVisibility *TCellVisibility  `thrift:"cellVisibility,5" db:"cellVisibility" json:"cellVisibility,omitempty"`
	ReturnResults  *bool             `thrift:"returnResults,6" db:"returnResults" json:"returnResults,omitempty"`
}

Attributes:

  • Row
  • Columns
  • Attributes
  • Durability
  • CellVisibility
  • ReturnResults
var THBaseServiceAppendArgs_Tappend_DEFAULT *TAppend

func NewTAppend

func NewTAppend() *TAppend

func (*TAppend) Equals

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

func (*TAppend) GetAttributes

func (p *TAppend) GetAttributes() map[string][]byte

func (*TAppend) GetCellVisibility

func (p *TAppend) GetCellVisibility() *TCellVisibility

func (*TAppend) GetColumns

func (p *TAppend) GetColumns() []*TColumnValue

func (*TAppend) GetDurability

func (p *TAppend) GetDurability() TDurability

func (*TAppend) GetReturnResults

func (p *TAppend) GetReturnResults() bool

func (*TAppend) GetRow

func (p *TAppend) GetRow() []byte

func (*TAppend) IsSetAttributes

func (p *TAppend) IsSetAttributes() bool

func (*TAppend) IsSetCellVisibility

func (p *TAppend) IsSetCellVisibility() bool

func (*TAppend) IsSetDurability

func (p *TAppend) IsSetDurability() bool

func (*TAppend) IsSetReturnResults

func (p *TAppend) IsSetReturnResults() bool

func (*TAppend) Read

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

func (*TAppend) ReadField1

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

func (*TAppend) ReadField2

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

func (*TAppend) ReadField3

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

func (*TAppend) ReadField4

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

func (*TAppend) ReadField5

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

func (*TAppend) ReadField6

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

func (*TAppend) String

func (p *TAppend) String() string

func (*TAppend) Write

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

type TAuthorization

type TAuthorization struct {
	Labels []string `thrift:"labels,1" db:"labels" json:"labels,omitempty"`
}

Attributes:

  • Labels
var TGet_Authorizations_DEFAULT *TAuthorization
var TScan_Authorizations_DEFAULT *TAuthorization

func NewTAuthorization

func NewTAuthorization() *TAuthorization

func (*TAuthorization) Equals

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

func (*TAuthorization) GetLabels

func (p *TAuthorization) GetLabels() []string

func (*TAuthorization) IsSetLabels

func (p *TAuthorization) IsSetLabels() bool

func (*TAuthorization) Read

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

func (*TAuthorization) ReadField1

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

func (*TAuthorization) String

func (p *TAuthorization) String() string

func (*TAuthorization) Write

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

type TBloomFilterType

type TBloomFilterType int64

Thrift wrapper around org.apache.hadoop.hbase.regionserver.BloomType

const (
	TBloomFilterType_NONE                   TBloomFilterType = 0
	TBloomFilterType_ROW                    TBloomFilterType = 1
	TBloomFilterType_ROWCOL                 TBloomFilterType = 2
	TBloomFilterType_ROWPREFIX_FIXED_LENGTH TBloomFilterType = 3
)
var TColumnFamilyDescriptor_BloomnFilterType_DEFAULT TBloomFilterType

func TBloomFilterTypeFromString

func TBloomFilterTypeFromString(s string) (TBloomFilterType, error)

func TBloomFilterTypePtr

func TBloomFilterTypePtr(v TBloomFilterType) *TBloomFilterType

func (TBloomFilterType) MarshalText

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

func (*TBloomFilterType) Scan

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

func (TBloomFilterType) String

func (p TBloomFilterType) String() string

func (*TBloomFilterType) UnmarshalText

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

func (*TBloomFilterType) Value

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

type TCellVisibility

type TCellVisibility struct {
	Expression *string `thrift:"expression,1" db:"expression" json:"expression,omitempty"`
}

Attributes:

  • Expression
var TAppend_CellVisibility_DEFAULT *TCellVisibility
var TIncrement_CellVisibility_DEFAULT *TCellVisibility
var TPut_CellVisibility_DEFAULT *TCellVisibility

func NewTCellVisibility

func NewTCellVisibility() *TCellVisibility

func (*TCellVisibility) Equals

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

func (*TCellVisibility) GetExpression

func (p *TCellVisibility) GetExpression() string

func (*TCellVisibility) IsSetExpression

func (p *TCellVisibility) IsSetExpression() bool

func (*TCellVisibility) Read

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

func (*TCellVisibility) ReadField1

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

func (*TCellVisibility) String

func (p *TCellVisibility) String() string

func (*TCellVisibility) Write

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

type TColumn

type TColumn struct {
	Family    []byte `thrift:"family,1,required" db:"family" json:"family"`
	Qualifier []byte `thrift:"qualifier,2" db:"qualifier" json:"qualifier,omitempty"`
	Timestamp *int64 `thrift:"timestamp,3" db:"timestamp" json:"timestamp,omitempty"`
}

Addresses a single cell or multiple cells in a HBase table by column family and optionally a column qualifier and timestamp

Attributes:

  • Family
  • Qualifier
  • Timestamp

func NewTColumn

func NewTColumn() *TColumn

func (*TColumn) Equals

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

func (*TColumn) GetFamily

func (p *TColumn) GetFamily() []byte

func (*TColumn) GetQualifier

func (p *TColumn) GetQualifier() []byte

func (*TColumn) GetTimestamp

func (p *TColumn) GetTimestamp() int64

func (*TColumn) IsSetQualifier

func (p *TColumn) IsSetQualifier() bool

func (*TColumn) IsSetTimestamp

func (p *TColumn) IsSetTimestamp() bool

func (*TColumn) Read

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

func (*TColumn) ReadField1

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

func (*TColumn) ReadField2

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

func (*TColumn) ReadField3

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

func (*TColumn) String

func (p *TColumn) String() string

func (*TColumn) Write

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

type TColumnFamilyDescriptor

type TColumnFamilyDescriptor struct {
	Name                []byte                 `thrift:"name,1,required" db:"name" json:"name"`
	Attributes          map[string][]byte      `thrift:"attributes,2" db:"attributes" json:"attributes,omitempty"`
	Configuration       map[string]string      `thrift:"configuration,3" db:"configuration" json:"configuration,omitempty"`
	BlockSize           *int32                 `thrift:"blockSize,4" db:"blockSize" json:"blockSize,omitempty"`
	BloomnFilterType    *TBloomFilterType      `thrift:"bloomnFilterType,5" db:"bloomnFilterType" json:"bloomnFilterType,omitempty"`
	CompressionType     *TCompressionAlgorithm `thrift:"compressionType,6" db:"compressionType" json:"compressionType,omitempty"`
	DfsReplication      *int16                 `thrift:"dfsReplication,7" db:"dfsReplication" json:"dfsReplication,omitempty"`
	DataBlockEncoding   *TDataBlockEncoding    `thrift:"dataBlockEncoding,8" db:"dataBlockEncoding" json:"dataBlockEncoding,omitempty"`
	KeepDeletedCells    *TKeepDeletedCells     `thrift:"keepDeletedCells,9" db:"keepDeletedCells" json:"keepDeletedCells,omitempty"`
	MaxVersions         *int32                 `thrift:"maxVersions,10" db:"maxVersions" json:"maxVersions,omitempty"`
	MinVersions         *int32                 `thrift:"minVersions,11" db:"minVersions" json:"minVersions,omitempty"`
	Scope               *int32                 `thrift:"scope,12" db:"scope" json:"scope,omitempty"`
	TimeToLive          *int32                 `thrift:"timeToLive,13" db:"timeToLive" json:"timeToLive,omitempty"`
	BlockCacheEnabled   *bool                  `thrift:"blockCacheEnabled,14" db:"blockCacheEnabled" json:"blockCacheEnabled,omitempty"`
	CacheBloomsOnWrite  *bool                  `thrift:"cacheBloomsOnWrite,15" db:"cacheBloomsOnWrite" json:"cacheBloomsOnWrite,omitempty"`
	CacheDataOnWrite    *bool                  `thrift:"cacheDataOnWrite,16" db:"cacheDataOnWrite" json:"cacheDataOnWrite,omitempty"`
	CacheIndexesOnWrite *bool                  `thrift:"cacheIndexesOnWrite,17" db:"cacheIndexesOnWrite" json:"cacheIndexesOnWrite,omitempty"`
	CompressTags        *bool                  `thrift:"compressTags,18" db:"compressTags" json:"compressTags,omitempty"`
	EvictBlocksOnClose  *bool                  `thrift:"evictBlocksOnClose,19" db:"evictBlocksOnClose" json:"evictBlocksOnClose,omitempty"`
	InMemory            *bool                  `thrift:"inMemory,20" db:"inMemory" json:"inMemory,omitempty"`
}

Thrift wrapper around org.apache.hadoop.hbase.client.ColumnFamilyDescriptor

Attributes:

  • Name
  • Attributes
  • Configuration
  • BlockSize
  • BloomnFilterType
  • CompressionType
  • DfsReplication
  • DataBlockEncoding
  • KeepDeletedCells
  • MaxVersions
  • MinVersions
  • Scope
  • TimeToLive
  • BlockCacheEnabled
  • CacheBloomsOnWrite
  • CacheDataOnWrite
  • CacheIndexesOnWrite
  • CompressTags
  • EvictBlocksOnClose
  • InMemory
var THBaseServiceAddColumnFamilyArgs_Column_DEFAULT *TColumnFamilyDescriptor
var THBaseServiceModifyColumnFamilyArgs_Column_DEFAULT *TColumnFamilyDescriptor

func NewTColumnFamilyDescriptor

func NewTColumnFamilyDescriptor() *TColumnFamilyDescriptor

func (*TColumnFamilyDescriptor) Equals

func (*TColumnFamilyDescriptor) GetAttributes

func (p *TColumnFamilyDescriptor) GetAttributes() map[string][]byte

func (*TColumnFamilyDescriptor) GetBlockCacheEnabled

func (p *TColumnFamilyDescriptor) GetBlockCacheEnabled() bool

func (*TColumnFamilyDescriptor) GetBlockSize

func (p *TColumnFamilyDescriptor) GetBlockSize() int32

func (*TColumnFamilyDescriptor) GetBloomnFilterType

func (p *TColumnFamilyDescriptor) GetBloomnFilterType() TBloomFilterType

func (*TColumnFamilyDescriptor) GetCacheBloomsOnWrite

func (p *TColumnFamilyDescriptor) GetCacheBloomsOnWrite() bool

func (*TColumnFamilyDescriptor) GetCacheDataOnWrite

func (p *TColumnFamilyDescriptor) GetCacheDataOnWrite() bool

func (*TColumnFamilyDescriptor) GetCacheIndexesOnWrite

func (p *TColumnFamilyDescriptor) GetCacheIndexesOnWrite() bool

func (*TColumnFamilyDescriptor) GetCompressTags

func (p *TColumnFamilyDescriptor) GetCompressTags() bool

func (*TColumnFamilyDescriptor) GetCompressionType

func (p *TColumnFamilyDescriptor) GetCompressionType() TCompressionAlgorithm

func (*TColumnFamilyDescriptor) GetConfiguration

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

func (*TColumnFamilyDescriptor) GetDataBlockEncoding

func (p *TColumnFamilyDescriptor) GetDataBlockEncoding() TDataBlockEncoding

func (*TColumnFamilyDescriptor) GetDfsReplication

func (p *TColumnFamilyDescriptor) GetDfsReplication() int16

func (*TColumnFamilyDescriptor) GetEvictBlocksOnClose

func (p *TColumnFamilyDescriptor) GetEvictBlocksOnClose() bool

func (*TColumnFamilyDescriptor) GetInMemory

func (p *TColumnFamilyDescriptor) GetInMemory() bool

func (*TColumnFamilyDescriptor) GetKeepDeletedCells

func (p *TColumnFamilyDescriptor) GetKeepDeletedCells() TKeepDeletedCells

func (*TColumnFamilyDescriptor) GetMaxVersions

func (p *TColumnFamilyDescriptor) GetMaxVersions() int32

func (*TColumnFamilyDescriptor) GetMinVersions

func (p *TColumnFamilyDescriptor) GetMinVersions() int32

func (*TColumnFamilyDescriptor) GetName

func (p *TColumnFamilyDescriptor) GetName() []byte

func (*TColumnFamilyDescriptor) GetScope

func (p *TColumnFamilyDescriptor) GetScope() int32

func (*TColumnFamilyDescriptor) GetTimeToLive

func (p *TColumnFamilyDescriptor) GetTimeToLive() int32

func (*TColumnFamilyDescriptor) IsSetAttributes

func (p *TColumnFamilyDescriptor) IsSetAttributes() bool

func (*TColumnFamilyDescriptor) IsSetBlockCacheEnabled

func (p *TColumnFamilyDescriptor) IsSetBlockCacheEnabled() bool

func (*TColumnFamilyDescriptor) IsSetBlockSize

func (p *TColumnFamilyDescriptor) IsSetBlockSize() bool

func (*TColumnFamilyDescriptor) IsSetBloomnFilterType

func (p *TColumnFamilyDescriptor) IsSetBloomnFilterType() bool

func (*TColumnFamilyDescriptor) IsSetCacheBloomsOnWrite

func (p *TColumnFamilyDescriptor) IsSetCacheBloomsOnWrite() bool

func (*TColumnFamilyDescriptor) IsSetCacheDataOnWrite

func (p *TColumnFamilyDescriptor) IsSetCacheDataOnWrite() bool

func (*TColumnFamilyDescriptor) IsSetCacheIndexesOnWrite

func (p *TColumnFamilyDescriptor) IsSetCacheIndexesOnWrite() bool

func (*TColumnFamilyDescriptor) IsSetCompressTags

func (p *TColumnFamilyDescriptor) IsSetCompressTags() bool

func (*TColumnFamilyDescriptor) IsSetCompressionType

func (p *TColumnFamilyDescriptor) IsSetCompressionType() bool

func (*TColumnFamilyDescriptor) IsSetConfiguration

func (p *TColumnFamilyDescriptor) IsSetConfiguration() bool

func (*TColumnFamilyDescriptor) IsSetDataBlockEncoding

func (p *TColumnFamilyDescriptor) IsSetDataBlockEncoding() bool

func (*TColumnFamilyDescriptor) IsSetDfsReplication

func (p *TColumnFamilyDescriptor) IsSetDfsReplication() bool

func (*TColumnFamilyDescriptor) IsSetEvictBlocksOnClose

func (p *TColumnFamilyDescriptor) IsSetEvictBlocksOnClose() bool

func (*TColumnFamilyDescriptor) IsSetInMemory

func (p *TColumnFamilyDescriptor) IsSetInMemory() bool

func (*TColumnFamilyDescriptor) IsSetKeepDeletedCells

func (p *TColumnFamilyDescriptor) IsSetKeepDeletedCells() bool

func (*TColumnFamilyDescriptor) IsSetMaxVersions

func (p *TColumnFamilyDescriptor) IsSetMaxVersions() bool

func (*TColumnFamilyDescriptor) IsSetMinVersions

func (p *TColumnFamilyDescriptor) IsSetMinVersions() bool

func (*TColumnFamilyDescriptor) IsSetScope

func (p *TColumnFamilyDescriptor) IsSetScope() bool

func (*TColumnFamilyDescriptor) IsSetTimeToLive

func (p *TColumnFamilyDescriptor) IsSetTimeToLive() bool

func (*TColumnFamilyDescriptor) Read

func (*TColumnFamilyDescriptor) ReadField1

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

func (*TColumnFamilyDescriptor) ReadField10

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

func (*TColumnFamilyDescriptor) ReadField11

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

func (*TColumnFamilyDescriptor) ReadField12

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

func (*TColumnFamilyDescriptor) ReadField13

func (p *TColumnFamilyDescriptor) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField14

func (p *TColumnFamilyDescriptor) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField15

func (p *TColumnFamilyDescriptor) ReadField15(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField16

func (p *TColumnFamilyDescriptor) ReadField16(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField17

func (p *TColumnFamilyDescriptor) ReadField17(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField18

func (p *TColumnFamilyDescriptor) ReadField18(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField19

func (p *TColumnFamilyDescriptor) ReadField19(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField2

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

func (*TColumnFamilyDescriptor) ReadField20

func (p *TColumnFamilyDescriptor) ReadField20(ctx context.Context, iprot thrift.TProtocol) error

func (*TColumnFamilyDescriptor) ReadField3

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

func (*TColumnFamilyDescriptor) ReadField4

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

func (*TColumnFamilyDescriptor) ReadField5

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

func (*TColumnFamilyDescriptor) ReadField6

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

func (*TColumnFamilyDescriptor) ReadField7

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

func (*TColumnFamilyDescriptor) ReadField8

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

func (*TColumnFamilyDescriptor) ReadField9

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

func (*TColumnFamilyDescriptor) String

func (p *TColumnFamilyDescriptor) String() string

func (*TColumnFamilyDescriptor) Write

type TColumnIncrement

type TColumnIncrement struct {
	Family    []byte `thrift:"family,1,required" db:"family" json:"family"`
	Qualifier []byte `thrift:"qualifier,2,required" db:"qualifier" json:"qualifier"`
	Amount    int64  `thrift:"amount,3" db:"amount" json:"amount"`
}

Represents a single cell and the amount to increment it by

Attributes:

  • Family
  • Qualifier
  • Amount

func NewTColumnIncrement

func NewTColumnIncrement() *TColumnIncrement

func (*TColumnIncrement) Equals

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

func (*TColumnIncrement) GetAmount

func (p *TColumnIncrement) GetAmount() int64

func (*TColumnIncrement) GetFamily

func (p *TColumnIncrement) GetFamily() []byte

func (*TColumnIncrement) GetQualifier

func (p *TColumnIncrement) GetQualifier() []byte

func (*TColumnIncrement) IsSetAmount

func (p *TColumnIncrement) IsSetAmount() bool

func (*TColumnIncrement) Read

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

func (*TColumnIncrement) ReadField1

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

func (*TColumnIncrement) ReadField2

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

func (*TColumnIncrement) ReadField3

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

func (*TColumnIncrement) String

func (p *TColumnIncrement) String() string

func (*TColumnIncrement) Write

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

type TColumnValue

type TColumnValue struct {
	Family    []byte `thrift:"family,1,required" db:"family" json:"family"`
	Qualifier []byte `thrift:"qualifier,2,required" db:"qualifier" json:"qualifier"`
	Value     []byte `thrift:"value,3,required" db:"value" json:"value"`
	Timestamp *int64 `thrift:"timestamp,4" db:"timestamp" json:"timestamp,omitempty"`
	Tags      []byte `thrift:"tags,5" db:"tags" json:"tags,omitempty"`
	Type      *int8  `thrift:"type,6" db:"type" json:"type,omitempty"`
}

Represents a single cell and its value.

Attributes:

  • Family
  • Qualifier
  • Value
  • Timestamp
  • Tags
  • Type

func NewTColumnValue

func NewTColumnValue() *TColumnValue

func (*TColumnValue) Equals

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

func (*TColumnValue) GetFamily

func (p *TColumnValue) GetFamily() []byte

func (*TColumnValue) GetQualifier

func (p *TColumnValue) GetQualifier() []byte

func (*TColumnValue) GetTags

func (p *TColumnValue) GetTags() []byte

func (*TColumnValue) GetTimestamp

func (p *TColumnValue) GetTimestamp() int64

func (*TColumnValue) GetType

func (p *TColumnValue) GetType() int8

func (*TColumnValue) GetValue

func (p *TColumnValue) GetValue() []byte

func (*TColumnValue) IsSetTags

func (p *TColumnValue) IsSetTags() bool

func (*TColumnValue) IsSetTimestamp

func (p *TColumnValue) IsSetTimestamp() bool

func (*TColumnValue) IsSetType

func (p *TColumnValue) IsSetType() bool

func (*TColumnValue) Read

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

func (*TColumnValue) ReadField1

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

func (*TColumnValue) ReadField2

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

func (*TColumnValue) ReadField3

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

func (*TColumnValue) ReadField4

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

func (*TColumnValue) ReadField5

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

func (*TColumnValue) ReadField6

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

func (*TColumnValue) String

func (p *TColumnValue) String() string

func (*TColumnValue) Write

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

type TCompareOperator

type TCompareOperator int64

Thrift wrapper around org.apache.hadoop.hbase.CompareOperator.

const (
	TCompareOperator_LESS             TCompareOperator = 0
	TCompareOperator_LESS_OR_EQUAL    TCompareOperator = 1
	TCompareOperator_EQUAL            TCompareOperator = 2
	TCompareOperator_NOT_EQUAL        TCompareOperator = 3
	TCompareOperator_GREATER_OR_EQUAL TCompareOperator = 4
	TCompareOperator_GREATER          TCompareOperator = 5
	TCompareOperator_NO_OP            TCompareOperator = 6
)

func TCompareOperatorFromString

func TCompareOperatorFromString(s string) (TCompareOperator, error)

func TCompareOperatorPtr

func TCompareOperatorPtr(v TCompareOperator) *TCompareOperator

func (TCompareOperator) MarshalText

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

func (*TCompareOperator) Scan

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

func (TCompareOperator) String

func (p TCompareOperator) String() string

func (*TCompareOperator) UnmarshalText

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

func (*TCompareOperator) Value

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

type TCompressionAlgorithm

type TCompressionAlgorithm int64

Thrift wrapper around org.apache.hadoop.hbase.io.compress.Algorithm

const (
	TCompressionAlgorithm_LZO    TCompressionAlgorithm = 0
	TCompressionAlgorithm_GZ     TCompressionAlgorithm = 1
	TCompressionAlgorithm_NONE   TCompressionAlgorithm = 2
	TCompressionAlgorithm_SNAPPY TCompressionAlgorithm = 3
	TCompressionAlgorithm_LZ4    TCompressionAlgorithm = 4
	TCompressionAlgorithm_BZIP2  TCompressionAlgorithm = 5
	TCompressionAlgorithm_ZSTD   TCompressionAlgorithm = 6
)
var TColumnFamilyDescriptor_CompressionType_DEFAULT TCompressionAlgorithm

func TCompressionAlgorithmFromString

func TCompressionAlgorithmFromString(s string) (TCompressionAlgorithm, error)

func (TCompressionAlgorithm) MarshalText

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

func (*TCompressionAlgorithm) Scan

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

func (TCompressionAlgorithm) String

func (p TCompressionAlgorithm) String() string

func (*TCompressionAlgorithm) UnmarshalText

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

func (*TCompressionAlgorithm) Value

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

type TConsistency

type TConsistency int64

Specify Consistency: - STRONG means reads only from primary region - TIMELINE means reads might return values from secondary region replicas

const (
	TConsistency_STRONG   TConsistency = 1
	TConsistency_TIMELINE TConsistency = 2
)
var TGet_Consistency_DEFAULT TConsistency
var TScan_Consistency_DEFAULT TConsistency

func TConsistencyFromString

func TConsistencyFromString(s string) (TConsistency, error)

func TConsistencyPtr

func TConsistencyPtr(v TConsistency) *TConsistency

func (TConsistency) MarshalText

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

func (*TConsistency) Scan

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

func (TConsistency) String

func (p TConsistency) String() string

func (*TConsistency) UnmarshalText

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

func (*TConsistency) Value

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

type TDataBlockEncoding

type TDataBlockEncoding int64

Thrift wrapper around org.apache.hadoop.hbase.io.encoding.DataBlockEncoding

const (
	TDataBlockEncoding_NONE         TDataBlockEncoding = 0
	TDataBlockEncoding_PREFIX       TDataBlockEncoding = 2
	TDataBlockEncoding_DIFF         TDataBlockEncoding = 3
	TDataBlockEncoding_FAST_DIFF    TDataBlockEncoding = 4
	TDataBlockEncoding_ROW_INDEX_V1 TDataBlockEncoding = 7
)
var TColumnFamilyDescriptor_DataBlockEncoding_DEFAULT TDataBlockEncoding

func TDataBlockEncodingFromString

func TDataBlockEncodingFromString(s string) (TDataBlockEncoding, error)

func TDataBlockEncodingPtr

func TDataBlockEncodingPtr(v TDataBlockEncoding) *TDataBlockEncoding

func (TDataBlockEncoding) MarshalText

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

func (*TDataBlockEncoding) Scan

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

func (TDataBlockEncoding) String

func (p TDataBlockEncoding) String() string

func (*TDataBlockEncoding) UnmarshalText

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

func (*TDataBlockEncoding) Value

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

type TDelete

type TDelete struct {
	Row        []byte      `thrift:"row,1,required" db:"row" json:"row"`
	Columns    []*TColumn  `thrift:"columns,2" db:"columns" json:"columns,omitempty"`
	Timestamp  *int64      `thrift:"timestamp,3" db:"timestamp" json:"timestamp,omitempty"`
	DeleteType TDeleteType `thrift:"deleteType,4" db:"deleteType" json:"deleteType"`
	// unused field # 5
	Attributes map[string][]byte `thrift:"attributes,6" db:"attributes" json:"attributes,omitempty"`
	Durability *TDurability      `thrift:"durability,7" db:"durability" json:"durability,omitempty"`
}

Used to perform Delete operations on a single row.

The scope can be further narrowed down by specifying a list of columns or column families as TColumns.

Specifying only a family in a TColumn will delete the whole family. If a timestamp is specified all versions with a timestamp less than or equal to this will be deleted. If no timestamp is specified the current time will be used.

Specifying a family and a column qualifier in a TColumn will delete only this qualifier. If a timestamp is specified only versions equal to this timestamp will be deleted. If no timestamp is specified the most recent version will be deleted. To delete all previous versions, specify the DELETE_COLUMNS TDeleteType.

The top level timestamp is only used if a complete row should be deleted (i.e. no columns are passed) and if it is specified it works the same way as if you had added a TColumn for every column family and this timestamp (i.e. all versions older than or equal in all column families will be deleted)

You can specify how this Delete should be written to the write-ahead Log (WAL) by changing the durability. If you don't provide durability, it defaults to column family's default setting for durability.

Attributes:

  • Row
  • Columns
  • Timestamp
  • DeleteType
  • Attributes
  • Durability
var THBaseServiceCheckAndDeleteArgs_Tdelete_DEFAULT *TDelete
var THBaseServiceDeleteSingleArgs_Tdelete_DEFAULT *TDelete
var TMutation_DeleteSingle_DEFAULT *TDelete

func NewTDelete

func NewTDelete() *TDelete

func (*TDelete) Equals

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

func (*TDelete) GetAttributes

func (p *TDelete) GetAttributes() map[string][]byte

func (*TDelete) GetColumns

func (p *TDelete) GetColumns() []*TColumn

func (*TDelete) GetDeleteType

func (p *TDelete) GetDeleteType() TDeleteType

func (*TDelete) GetDurability

func (p *TDelete) GetDurability() TDurability

func (*TDelete) GetRow

func (p *TDelete) GetRow() []byte

func (*TDelete) GetTimestamp

func (p *TDelete) GetTimestamp() int64

func (*TDelete) IsSetAttributes

func (p *TDelete) IsSetAttributes() bool

func (*TDelete) IsSetColumns

func (p *TDelete) IsSetColumns() bool

func (*TDelete) IsSetDeleteType

func (p *TDelete) IsSetDeleteType() bool

func (*TDelete) IsSetDurability

func (p *TDelete) IsSetDurability() bool

func (*TDelete) IsSetTimestamp

func (p *TDelete) IsSetTimestamp() bool

func (*TDelete) Read

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

func (*TDelete) ReadField1

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

func (*TDelete) ReadField2

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

func (*TDelete) ReadField3

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

func (*TDelete) ReadField4

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

func (*TDelete) ReadField6

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

func (*TDelete) ReadField7

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

func (*TDelete) String

func (p *TDelete) String() string

func (*TDelete) Write

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

type TDeleteType

type TDeleteType int64

Specify type of delete: - DELETE_COLUMN means exactly one version will be removed, - DELETE_COLUMNS means previous versions will also be removed.

const (
	TDeleteType_DELETE_COLUMN         TDeleteType = 0
	TDeleteType_DELETE_COLUMNS        TDeleteType = 1
	TDeleteType_DELETE_FAMILY         TDeleteType = 2
	TDeleteType_DELETE_FAMILY_VERSION TDeleteType = 3
)
var TDelete_DeleteType_DEFAULT TDeleteType = 1

func TDeleteTypeFromString

func TDeleteTypeFromString(s string) (TDeleteType, error)

func TDeleteTypePtr

func TDeleteTypePtr(v TDeleteType) *TDeleteType

func (TDeleteType) MarshalText

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

func (*TDeleteType) Scan

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

func (TDeleteType) String

func (p TDeleteType) String() string

func (*TDeleteType) UnmarshalText

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

func (*TDeleteType) Value

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

type TDurability

type TDurability int64

Specify Durability: - SKIP_WAL means do not write the Mutation to the WAL. - ASYNC_WAL means write the Mutation to the WAL asynchronously, - SYNC_WAL means write the Mutation to the WAL synchronously, - FSYNC_WAL means Write the Mutation to the WAL synchronously and force the entries to disk.

const (
	TDurability_USE_DEFAULT TDurability = 0
	TDurability_SKIP_WAL    TDurability = 1
	TDurability_ASYNC_WAL   TDurability = 2
	TDurability_SYNC_WAL    TDurability = 3
	TDurability_FSYNC_WAL   TDurability = 4
)
var TAppend_Durability_DEFAULT TDurability
var TDelete_Durability_DEFAULT TDurability
var TIncrement_Durability_DEFAULT TDurability
var TPut_Durability_DEFAULT TDurability
var TTableDescriptor_Durability_DEFAULT TDurability

func TDurabilityFromString

func TDurabilityFromString(s string) (TDurability, error)

func TDurabilityPtr

func TDurabilityPtr(v TDurability) *TDurability

func (TDurability) MarshalText

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

func (*TDurability) Scan

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

func (TDurability) String

func (p TDurability) String() string

func (*TDurability) UnmarshalText

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

func (*TDurability) Value

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

type TFilterByOperator

type TFilterByOperator int64
const (
	TFilterByOperator_AND TFilterByOperator = 0
	TFilterByOperator_OR  TFilterByOperator = 1
)
var TLogQueryFilter_FilterByOperator_DEFAULT TFilterByOperator = 1

func TFilterByOperatorFromString

func TFilterByOperatorFromString(s string) (TFilterByOperator, error)

func TFilterByOperatorPtr

func TFilterByOperatorPtr(v TFilterByOperator) *TFilterByOperator

func (TFilterByOperator) MarshalText

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

func (*TFilterByOperator) Scan

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

func (TFilterByOperator) String

func (p TFilterByOperator) String() string

func (*TFilterByOperator) UnmarshalText

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

func (*TFilterByOperator) Value

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

type TGet

type TGet struct {
	Row             []byte            `thrift:"row,1,required" db:"row" json:"row"`
	Columns         []*TColumn        `thrift:"columns,2" db:"columns" json:"columns,omitempty"`
	Timestamp       *int64            `thrift:"timestamp,3" db:"timestamp" json:"timestamp,omitempty"`
	TimeRange       *TTimeRange       `thrift:"timeRange,4" db:"timeRange" json:"timeRange,omitempty"`
	MaxVersions     *int32            `thrift:"maxVersions,5" db:"maxVersions" json:"maxVersions,omitempty"`
	FilterString    []byte            `thrift:"filterString,6" db:"filterString" json:"filterString,omitempty"`
	Attributes      map[string][]byte `thrift:"attributes,7" db:"attributes" json:"attributes,omitempty"`
	Authorizations  *TAuthorization   `thrift:"authorizations,8" db:"authorizations" json:"authorizations,omitempty"`
	Consistency     *TConsistency     `thrift:"consistency,9" db:"consistency" json:"consistency,omitempty"`
	TargetReplicaId *int32            `thrift:"targetReplicaId,10" db:"targetReplicaId" json:"targetReplicaId,omitempty"`
	CacheBlocks     *bool             `thrift:"cacheBlocks,11" db:"cacheBlocks" json:"cacheBlocks,omitempty"`
	StoreLimit      *int32            `thrift:"storeLimit,12" db:"storeLimit" json:"storeLimit,omitempty"`
	StoreOffset     *int32            `thrift:"storeOffset,13" db:"storeOffset" json:"storeOffset,omitempty"`
	ExistenceOnly   *bool             `thrift:"existence_only,14" db:"existence_only" json:"existence_only,omitempty"`
	FilterBytes     []byte            `thrift:"filterBytes,15" db:"filterBytes" json:"filterBytes,omitempty"`
}

Used to perform Get operations on a single row.

The scope can be further narrowed down by specifying a list of columns or column families.

To get everything for a row, instantiate a Get object with just the row to get. To further define the scope of what to get you can add a timestamp or time range with an optional maximum number of versions to return.

If you specify a time range and a timestamp the range is ignored. Timestamps on TColumns are ignored.

Attributes:

  • Row
  • Columns
  • Timestamp
  • TimeRange
  • MaxVersions
  • FilterString
  • Attributes
  • Authorizations
  • Consistency
  • TargetReplicaId
  • CacheBlocks
  • StoreLimit
  • StoreOffset
  • ExistenceOnly
  • FilterBytes
var THBaseServiceExistsArgs_Tget_DEFAULT *TGet
var THBaseServiceGetArgs_Tget_DEFAULT *TGet

func NewTGet

func NewTGet() *TGet

func (*TGet) Equals

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

func (*TGet) GetAttributes

func (p *TGet) GetAttributes() map[string][]byte

func (*TGet) GetAuthorizations

func (p *TGet) GetAuthorizations() *TAuthorization

func (*TGet) GetCacheBlocks

func (p *TGet) GetCacheBlocks() bool

func (*TGet) GetColumns

func (p *TGet) GetColumns() []*TColumn

func (*TGet) GetConsistency

func (p *TGet) GetConsistency() TConsistency

func (*TGet) GetExistenceOnly

func (p *TGet) GetExistenceOnly() bool

func (*TGet) GetFilterBytes

func (p *TGet) GetFilterBytes() []byte

func (*TGet) GetFilterString

func (p *TGet) GetFilterString() []byte

func (*TGet) GetMaxVersions

func (p *TGet) GetMaxVersions() int32

func (*TGet) GetRow

func (p *TGet) GetRow() []byte

func (*TGet) GetStoreLimit

func (p *TGet) GetStoreLimit() int32

func (*TGet) GetStoreOffset

func (p *TGet) GetStoreOffset() int32

func (*TGet) GetTargetReplicaId

func (p *TGet) GetTargetReplicaId() int32

func (*TGet) GetTimeRange

func (p *TGet) GetTimeRange() *TTimeRange

func (*TGet) GetTimestamp

func (p *TGet) GetTimestamp() int64

func (*TGet) IsSetAttributes

func (p *TGet) IsSetAttributes() bool

func (*TGet) IsSetAuthorizations

func (p *TGet) IsSetAuthorizations() bool

func (*TGet) IsSetCacheBlocks

func (p *TGet) IsSetCacheBlocks() bool

func (*TGet) IsSetColumns

func (p *TGet) IsSetColumns() bool

func (*TGet) IsSetConsistency

func (p *TGet) IsSetConsistency() bool

func (*TGet) IsSetExistenceOnly

func (p *TGet) IsSetExistenceOnly() bool

func (*TGet) IsSetFilterBytes

func (p *TGet) IsSetFilterBytes() bool

func (*TGet) IsSetFilterString

func (p *TGet) IsSetFilterString() bool

func (*TGet) IsSetMaxVersions

func (p *TGet) IsSetMaxVersions() bool

func (*TGet) IsSetStoreLimit

func (p *TGet) IsSetStoreLimit() bool

func (*TGet) IsSetStoreOffset

func (p *TGet) IsSetStoreOffset() bool

func (*TGet) IsSetTargetReplicaId

func (p *TGet) IsSetTargetReplicaId() bool

func (*TGet) IsSetTimeRange

func (p *TGet) IsSetTimeRange() bool

func (*TGet) IsSetTimestamp

func (p *TGet) IsSetTimestamp() bool

func (*TGet) Read

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

func (*TGet) ReadField1

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

func (*TGet) ReadField10

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

func (*TGet) ReadField11

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

func (*TGet) ReadField12

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

func (*TGet) ReadField13

func (p *TGet) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*TGet) ReadField14

func (p *TGet) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*TGet) ReadField15

func (p *TGet) ReadField15(ctx context.Context, iprot thrift.TProtocol) error

func (*TGet) ReadField2

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

func (*TGet) ReadField3

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

func (*TGet) ReadField4

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

func (*TGet) ReadField5

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

func (*TGet) ReadField6

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

func (*TGet) ReadField7

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

func (*TGet) ReadField8

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

func (*TGet) ReadField9

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

func (*TGet) String

func (p *TGet) String() string

func (*TGet) Write

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

type THBaseService

type THBaseService interface {
	// Test for the existence of columns in the table, as specified in the TGet.
	//
	// @return true if the specified TGet matches one or more keys, false if not
	//
	// Parameters:
	//  - Table: the table to check on
	//  - Tget: the TGet to check for
	Exists(ctx context.Context, table []byte, tget *TGet) (_r bool, _err error)
	// Test for the existence of columns in the table, as specified by the TGets.
	//
	// This will return an array of booleans. Each value will be true if the related Get matches
	// one or more keys, false if not.
	//
	// Parameters:
	//  - Table: the table to check on
	//  - Tgets: a list of TGets to check for
	ExistsAll(ctx context.Context, table []byte, tgets []*TGet) (_r []bool, _err error)
	// Method for getting data from a row.
	//
	// If the row cannot be found an empty Result is returned.
	// This can be checked by the empty field of the TResult
	//
	// @return the result
	//
	// Parameters:
	//  - Table: the table to get from
	//  - Tget: the TGet to fetch
	Get(ctx context.Context, table []byte, tget *TGet) (_r *TResult_, _err error)
	// Method for getting multiple rows.
	//
	// If a row cannot be found there will be a null
	// value in the result list for that TGet at the
	// same position.
	//
	// So the Results are in the same order as the TGets.
	//
	// Parameters:
	//  - Table: the table to get from
	//  - Tgets: a list of TGets to fetch, the Result list
	// will have the Results at corresponding positions
	// or null if there was an error
	GetMultiple(ctx context.Context, table []byte, tgets []*TGet) (_r []*TResult_, _err error)
	// Commit a TPut to a table.
	//
	// Parameters:
	//  - Table: the table to put data in
	//  - Tput: the TPut to put
	Put(ctx context.Context, table []byte, tput *TPut) (_err error)
	// Atomically checks if a row/family/qualifier value matches the expected
	// value. If it does, it adds the TPut.
	//
	// @return true if the new put was executed, false otherwise
	//
	// Parameters:
	//  - Table: to check in and put to
	//  - Row: row to check
	//  - Family: column family to check
	//  - Qualifier: column qualifier to check
	//  - Value: the expected value, if not provided the
	// check is for the non-existence of the
	// column in question
	//  - Tput: the TPut to put if the check succeeds
	CheckAndPut(ctx context.Context, table []byte, row []byte, family []byte, qualifier []byte, value []byte, tput *TPut) (_r bool, _err error)
	// Commit a List of Puts to the table.
	//
	// Parameters:
	//  - Table: the table to put data in
	//  - Tputs: a list of TPuts to commit
	PutMultiple(ctx context.Context, table []byte, tputs []*TPut) (_err error)
	// Deletes as specified by the TDelete.
	//
	// Note: "delete" is a reserved keyword and cannot be used in Thrift
	// thus the inconsistent naming scheme from the other functions.
	//
	// Parameters:
	//  - Table: the table to delete from
	//  - Tdelete: the TDelete to delete
	DeleteSingle(ctx context.Context, table []byte, tdelete *TDelete) (_err error)
	// Bulk commit a List of TDeletes to the table.
	//
	// Throws a TIOError if any of the deletes fail.
	//
	// Always returns an empty list for backwards compatibility.
	//
	// Parameters:
	//  - Table: the table to delete from
	//  - Tdeletes: list of TDeletes to delete
	DeleteMultiple(ctx context.Context, table []byte, tdeletes []*TDelete) (_r []*TDelete, _err error)
	// Atomically checks if a row/family/qualifier value matches the expected
	// value. If it does, it adds the delete.
	//
	// @return true if the new delete was executed, false otherwise
	//
	// Parameters:
	//  - Table: to check in and delete from
	//  - Row: row to check
	//  - Family: column family to check
	//  - Qualifier: column qualifier to check
	//  - Value: the expected value, if not provided the
	// check is for the non-existence of the
	// column in question
	//  - Tdelete: the TDelete to execute if the check succeeds
	CheckAndDelete(ctx context.Context, table []byte, row []byte, family []byte, qualifier []byte, value []byte, tdelete *TDelete) (_r bool, _err error)
	// Parameters:
	//  - Table: the table to increment the value on
	//  - Tincrement: the TIncrement to increment
	Increment(ctx context.Context, table []byte, tincrement *TIncrement) (_r *TResult_, _err error)
	// Parameters:
	//  - Table: the table to append the value on
	//  - Tappend: the TAppend to append
	Append(ctx context.Context, table []byte, tappend *TAppend) (_r *TResult_, _err error)
	// Get a Scanner for the provided TScan object.
	//
	// @return Scanner Id to be used with other scanner procedures
	//
	// Parameters:
	//  - Table: the table to get the Scanner for
	//  - Tscan: the scan object to get a Scanner for
	OpenScanner(ctx context.Context, table []byte, tscan *TScan) (_r int32, _err error)
	// Grabs multiple rows from a Scanner.
	//
	// @return Between zero and numRows TResults
	//
	// Parameters:
	//  - ScannerId: the Id of the Scanner to return rows from. This is an Id returned from the openScanner function.
	//  - NumRows: number of rows to return
	GetScannerRows(ctx context.Context, scannerId int32, numRows int32) (_r []*TResult_, _err error)
	// Closes the scanner. Should be called to free server side resources timely.
	// Typically close once the scanner is not needed anymore, i.e. after looping
	// over it to get all the required rows.
	//
	// Parameters:
	//  - ScannerId: the Id of the Scanner to close *
	CloseScanner(ctx context.Context, scannerId int32) (_err error)
	// mutateRow performs multiple mutations atomically on a single row.
	//
	// Parameters:
	//  - Table: table to apply the mutations
	//  - TrowMutations: mutations to apply
	MutateRow(ctx context.Context, table []byte, trowMutations *TRowMutations) (_err error)
	// Get results for the provided TScan object.
	// This helper function opens a scanner, get the results and close the scanner.
	//
	// @return between zero and numRows TResults
	//
	// Parameters:
	//  - Table: the table to get the Scanner for
	//  - Tscan: the scan object to get a Scanner for
	//  - NumRows: number of rows to return
	GetScannerResults(ctx context.Context, table []byte, tscan *TScan, numRows int32) (_r []*TResult_, _err error)
	// Given a table and a row get the location of the region that
	// would contain the given row key.
	//
	// reload = true means the cache will be cleared and the location
	// will be fetched from meta.
	//
	// Parameters:
	//  - Table
	//  - Row
	//  - Reload
	GetRegionLocation(ctx context.Context, table []byte, row []byte, reload bool) (_r *THRegionLocation, _err error)
	// Get all of the region locations for a given table.
	//
	//
	// Parameters:
	//  - Table
	GetAllRegionLocations(ctx context.Context, table []byte) (_r []*THRegionLocation, _err error)
	// Atomically checks if a row/family/qualifier value matches the expected
	// value. If it does, it mutates the row.
	//
	// @return true if the row was mutated, false otherwise
	//
	// Parameters:
	//  - Table: to check in and delete from
	//  - Row: row to check
	//  - Family: column family to check
	//  - Qualifier: column qualifier to check
	//  - CompareOperator: comparison to make on the value
	//  - Value: the expected value to be compared against, if not provided the
	// check is for the non-existence of the column in question
	//  - RowMutations: row mutations to execute if the value matches
	CheckAndMutate(ctx context.Context, table []byte, row []byte, family []byte, qualifier []byte, compareOperator TCompareOperator, value []byte, rowMutations *TRowMutations) (_r bool, _err error)
	// Get a table descriptor.
	// @return the TableDescriptor of the giving tablename
	//
	//
	// Parameters:
	//  - Table: the tablename of the table to get tableDescriptor
	GetTableDescriptor(ctx context.Context, table *TTableName) (_r *TTableDescriptor, _err error)
	// Get table descriptors of tables.
	// @return the TableDescriptor of the giving tablename
	//
	//
	// Parameters:
	//  - Tables: the tablename list of the tables to get tableDescriptor
	GetTableDescriptors(ctx context.Context, tables []*TTableName) (_r []*TTableDescriptor, _err error)
	//
	// @return true if table exists already, false if not
	//
	//
	// Parameters:
	//  - TableName: the tablename of the tables to check
	TableExists(ctx context.Context, tableName *TTableName) (_r bool, _err error)
	// Get table descriptors of tables that match the given pattern
	// @return the tableDescriptors of the matching table
	//
	//
	// Parameters:
	//  - Regex: The regular expression to match against
	//  - IncludeSysTables: set to false if match only against userspace tables
	GetTableDescriptorsByPattern(ctx context.Context, regex string, includeSysTables bool) (_r []*TTableDescriptor, _err error)
	// Get table descriptors of tables in the given namespace
	// @return the tableDescriptors in the namespce
	//
	//
	// Parameters:
	//  - Name: The namesapce's name
	GetTableDescriptorsByNamespace(ctx context.Context, name string) (_r []*TTableDescriptor, _err error)
	// Get table names of tables that match the given pattern
	// @return the table names of the matching table
	//
	//
	// Parameters:
	//  - Regex: The regular expression to match against
	//  - IncludeSysTables: set to false if match only against userspace tables
	GetTableNamesByPattern(ctx context.Context, regex string, includeSysTables bool) (_r []*TTableName, _err error)
	// Get table names of tables in the given namespace
	// @return the table names of the matching table
	//
	//
	// Parameters:
	//  - Name: The namesapce's name
	GetTableNamesByNamespace(ctx context.Context, name string) (_r []*TTableName, _err error)
	// Creates a new table with an initial set of empty regions defined by the specified split keys.
	// The total number of regions created will be the number of split keys plus one. Synchronous
	// operation.
	//
	//
	// Parameters:
	//  - Desc: table descriptor for table
	//  - SplitKeys: rray of split keys for the initial regions of the table
	CreateTable(ctx context.Context, desc *TTableDescriptor, splitKeys [][]byte) (_err error)
	// Deletes a table. Synchronous operation.
	//
	//
	// Parameters:
	//  - TableName: the tablename to delete
	DeleteTable(ctx context.Context, tableName *TTableName) (_err error)
	// Truncate a table. Synchronous operation.
	//
	//
	// Parameters:
	//  - TableName: the tablename to truncate
	//  - PreserveSplits: whether to  preserve previous splits
	TruncateTable(ctx context.Context, tableName *TTableName, preserveSplits bool) (_err error)
	// Enalbe a table
	//
	//
	// Parameters:
	//  - TableName: the tablename to enable
	EnableTable(ctx context.Context, tableName *TTableName) (_err error)
	// Disable a table
	//
	//
	// Parameters:
	//  - TableName: the tablename to disable
	DisableTable(ctx context.Context, tableName *TTableName) (_err error)
	//
	// @return true if table is enabled, false if not
	//
	//
	// Parameters:
	//  - TableName: the tablename to check
	IsTableEnabled(ctx context.Context, tableName *TTableName) (_r bool, _err error)
	//
	// @return true if table is disabled, false if not
	//
	//
	// Parameters:
	//  - TableName: the tablename to check
	IsTableDisabled(ctx context.Context, tableName *TTableName) (_r bool, _err error)
	//
	// @return true if table is available, false if not
	//
	//
	// Parameters:
	//  - TableName: the tablename to check
	IsTableAvailable(ctx context.Context, tableName *TTableName) (_r bool, _err error)
	//  * Use this api to check if the table has been created with the specified number of splitkeys
	//  * which was used while creating the given table. Note : If this api is used after a table's
	//  * region gets splitted, the api may return false.
	//  *
	//  * @return true if table is available, false if not
	//  *
	//  * @deprecated Since 2.2.0. Because the same method in Table interface has been deprecated
	//  * since 2.0.0, we will remove it in 3.0.0 release.
	//  * Use {@link #isTableAvailable(TTableName tableName)} instead
	// *
	//
	// Parameters:
	//  - TableName: the tablename to check
	//  - SplitKeys: keys to check if the table has been created with all split keys
	IsTableAvailableWithSplit(ctx context.Context, tableName *TTableName, splitKeys [][]byte) (_r bool, _err error)
	// Add a column family to an existing table. Synchronous operation.
	//
	//
	// Parameters:
	//  - TableName: the tablename to add column family to
	//  - Column: column family descriptor of column family to be added
	AddColumnFamily(ctx context.Context, tableName *TTableName, column *TColumnFamilyDescriptor) (_err error)
	// Delete a column family from a table. Synchronous operation.
	//
	//
	// Parameters:
	//  - TableName: the tablename to delete column family from
	//  - Column: name of column family to be deleted
	DeleteColumnFamily(ctx context.Context, tableName *TTableName, column []byte) (_err error)
	// Modify an existing column family on a table. Synchronous operation.
	//
	//
	// Parameters:
	//  - TableName: the tablename to modify column family
	//  - Column: column family descriptor of column family to be modified
	ModifyColumnFamily(ctx context.Context, tableName *TTableName, column *TColumnFamilyDescriptor) (_err error)
	// Modify an existing table
	//
	//
	// Parameters:
	//  - Desc: the descriptor of the table to modify
	ModifyTable(ctx context.Context, desc *TTableDescriptor) (_err error)
	// Create a new namespace. Blocks until namespace has been successfully created or an exception is
	// thrown
	//
	//
	// Parameters:
	//  - NamespaceDesc: descriptor which describes the new namespace
	CreateNamespace(ctx context.Context, namespaceDesc *TNamespaceDescriptor) (_err error)
	// Modify an existing namespace.  Blocks until namespace has been successfully modified or an
	// exception is thrown
	//
	//
	// Parameters:
	//  - NamespaceDesc: descriptor which describes the new namespace
	ModifyNamespace(ctx context.Context, namespaceDesc *TNamespaceDescriptor) (_err error)
	// Delete an existing namespace. Only empty namespaces (no tables) can be removed.
	// Blocks until namespace has been successfully deleted or an
	// exception is thrown.
	//
	//
	// Parameters:
	//  - Name: namespace name
	DeleteNamespace(ctx context.Context, name string) (_err error)
	// Get a namespace descriptor by name.
	// @retrun the descriptor
	//
	//
	// Parameters:
	//  - Name: name of namespace descriptor
	GetNamespaceDescriptor(ctx context.Context, name string) (_r *TNamespaceDescriptor, _err error)
	// @return all namespaces
	//
	ListNamespaceDescriptors(ctx context.Context) (_r []*TNamespaceDescriptor, _err error)
	// @return all namespace names
	//
	ListNamespaces(ctx context.Context) (_r []string, _err error)
	// Get the type of this thrift server.
	//
	// @return the type of this thrift server
	GetThriftServerType(ctx context.Context) (_r TThriftServerType, _err error)
	// Returns the cluster ID for this cluster.
	GetClusterId(ctx context.Context) (_r string, _err error)
	// Retrieves online slow RPC logs from the provided list of
	// RegionServers
	//
	// @return online slowlog response list
	// @throws TIOError if a remote or network exception occurs
	//
	// Parameters:
	//  - ServerNames: @param serverNames Server names to get slowlog responses from
	//  - LogQueryFilter: @param logQueryFilter filter to be used if provided
	GetSlowLogResponses(ctx context.Context, serverNames []*TServerName, logQueryFilter *TLogQueryFilter) (_r []*TOnlineLogRecord, _err error)
	// Clears online slow/large RPC logs from the provided list of
	// RegionServers
	//
	// @return List of booleans representing if online slowlog response buffer is cleaned
	//   from each RegionServer
	// @throws TIOError if a remote or network exception occurs
	//
	// Parameters:
	//  - ServerNames: @param serverNames Set of Server names to clean slowlog responses from
	ClearSlowLogResponses(ctx context.Context, serverNames []*TServerName) (_r []bool, _err error)
	// Grant permissions in table or namespace level.
	//
	// Parameters:
	//  - Info
	Grant(ctx context.Context, info *TAccessControlEntity) (_r bool, _err error)
	// Revoke permissions in table or namespace level.
	//
	// Parameters:
	//  - Info
	Revoke(ctx context.Context, info *TAccessControlEntity) (_r bool, _err error)
}

type THBaseServiceAddColumnFamilyArgs

type THBaseServiceAddColumnFamilyArgs struct {
	TableName *TTableName              `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
	Column    *TColumnFamilyDescriptor `thrift:"column,2,required" db:"column" json:"column"`
}

Attributes:

  • TableName: the tablename to add column family to
  • Column: column family descriptor of column family to be added

func NewTHBaseServiceAddColumnFamilyArgs

func NewTHBaseServiceAddColumnFamilyArgs() *THBaseServiceAddColumnFamilyArgs

func (*THBaseServiceAddColumnFamilyArgs) GetColumn

func (*THBaseServiceAddColumnFamilyArgs) GetTableName

func (p *THBaseServiceAddColumnFamilyArgs) GetTableName() *TTableName

func (*THBaseServiceAddColumnFamilyArgs) IsSetColumn

func (p *THBaseServiceAddColumnFamilyArgs) IsSetColumn() bool

func (*THBaseServiceAddColumnFamilyArgs) IsSetTableName

func (p *THBaseServiceAddColumnFamilyArgs) IsSetTableName() bool

func (*THBaseServiceAddColumnFamilyArgs) Read

func (*THBaseServiceAddColumnFamilyArgs) ReadField1

func (*THBaseServiceAddColumnFamilyArgs) ReadField2

func (*THBaseServiceAddColumnFamilyArgs) String

func (*THBaseServiceAddColumnFamilyArgs) Write

type THBaseServiceAddColumnFamilyResult

type THBaseServiceAddColumnFamilyResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceAddColumnFamilyResult

func NewTHBaseServiceAddColumnFamilyResult() *THBaseServiceAddColumnFamilyResult

func (*THBaseServiceAddColumnFamilyResult) GetIo

func (*THBaseServiceAddColumnFamilyResult) IsSetIo

func (*THBaseServiceAddColumnFamilyResult) Read

func (*THBaseServiceAddColumnFamilyResult) ReadField1

func (*THBaseServiceAddColumnFamilyResult) String

func (*THBaseServiceAddColumnFamilyResult) Write

type THBaseServiceAppendArgs

type THBaseServiceAppendArgs struct {
	Table   []byte   `thrift:"table,1,required" db:"table" json:"table"`
	Tappend *TAppend `thrift:"tappend,2,required" db:"tappend" json:"tappend"`
}

Attributes:

  • Table: the table to append the value on
  • Tappend: the TAppend to append

func NewTHBaseServiceAppendArgs

func NewTHBaseServiceAppendArgs() *THBaseServiceAppendArgs

func (*THBaseServiceAppendArgs) GetTable

func (p *THBaseServiceAppendArgs) GetTable() []byte

func (*THBaseServiceAppendArgs) GetTappend

func (p *THBaseServiceAppendArgs) GetTappend() *TAppend

func (*THBaseServiceAppendArgs) IsSetTappend

func (p *THBaseServiceAppendArgs) IsSetTappend() bool

func (*THBaseServiceAppendArgs) Read

func (*THBaseServiceAppendArgs) ReadField1

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

func (*THBaseServiceAppendArgs) ReadField2

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

func (*THBaseServiceAppendArgs) String

func (p *THBaseServiceAppendArgs) String() string

func (*THBaseServiceAppendArgs) Write

type THBaseServiceAppendResult

type THBaseServiceAppendResult struct {
	Success *TResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceAppendResult

func NewTHBaseServiceAppendResult() *THBaseServiceAppendResult

func (*THBaseServiceAppendResult) GetIo

func (p *THBaseServiceAppendResult) GetIo() *TIOError

func (*THBaseServiceAppendResult) GetSuccess

func (p *THBaseServiceAppendResult) GetSuccess() *TResult_

func (*THBaseServiceAppendResult) IsSetIo

func (p *THBaseServiceAppendResult) IsSetIo() bool

func (*THBaseServiceAppendResult) IsSetSuccess

func (p *THBaseServiceAppendResult) IsSetSuccess() bool

func (*THBaseServiceAppendResult) Read

func (*THBaseServiceAppendResult) ReadField0

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

func (*THBaseServiceAppendResult) ReadField1

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

func (*THBaseServiceAppendResult) String

func (p *THBaseServiceAppendResult) String() string

func (*THBaseServiceAppendResult) Write

type THBaseServiceCheckAndDeleteArgs

type THBaseServiceCheckAndDeleteArgs struct {
	Table     []byte   `thrift:"table,1,required" db:"table" json:"table"`
	Row       []byte   `thrift:"row,2,required" db:"row" json:"row"`
	Family    []byte   `thrift:"family,3,required" db:"family" json:"family"`
	Qualifier []byte   `thrift:"qualifier,4,required" db:"qualifier" json:"qualifier"`
	Value     []byte   `thrift:"value,5" db:"value" json:"value"`
	Tdelete   *TDelete `thrift:"tdelete,6,required" db:"tdelete" json:"tdelete"`
}

Attributes:

  • Table: to check in and delete from
  • Row: row to check
  • Family: column family to check
  • Qualifier: column qualifier to check
  • Value: the expected value, if not provided the

check is for the non-existence of the column in question

  • Tdelete: the TDelete to execute if the check succeeds

func NewTHBaseServiceCheckAndDeleteArgs

func NewTHBaseServiceCheckAndDeleteArgs() *THBaseServiceCheckAndDeleteArgs

func (*THBaseServiceCheckAndDeleteArgs) GetFamily

func (p *THBaseServiceCheckAndDeleteArgs) GetFamily() []byte

func (*THBaseServiceCheckAndDeleteArgs) GetQualifier

func (p *THBaseServiceCheckAndDeleteArgs) GetQualifier() []byte

func (*THBaseServiceCheckAndDeleteArgs) GetRow

func (p *THBaseServiceCheckAndDeleteArgs) GetRow() []byte

func (*THBaseServiceCheckAndDeleteArgs) GetTable

func (p *THBaseServiceCheckAndDeleteArgs) GetTable() []byte

func (*THBaseServiceCheckAndDeleteArgs) GetTdelete

func (p *THBaseServiceCheckAndDeleteArgs) GetTdelete() *TDelete

func (*THBaseServiceCheckAndDeleteArgs) GetValue

func (p *THBaseServiceCheckAndDeleteArgs) GetValue() []byte

func (*THBaseServiceCheckAndDeleteArgs) IsSetTdelete

func (p *THBaseServiceCheckAndDeleteArgs) IsSetTdelete() bool

func (*THBaseServiceCheckAndDeleteArgs) Read

func (*THBaseServiceCheckAndDeleteArgs) ReadField1

func (*THBaseServiceCheckAndDeleteArgs) ReadField2

func (*THBaseServiceCheckAndDeleteArgs) ReadField3

func (*THBaseServiceCheckAndDeleteArgs) ReadField4

func (*THBaseServiceCheckAndDeleteArgs) ReadField5

func (*THBaseServiceCheckAndDeleteArgs) ReadField6

func (*THBaseServiceCheckAndDeleteArgs) String

func (*THBaseServiceCheckAndDeleteArgs) Write

type THBaseServiceCheckAndDeleteResult

type THBaseServiceCheckAndDeleteResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceCheckAndDeleteResult

func NewTHBaseServiceCheckAndDeleteResult() *THBaseServiceCheckAndDeleteResult

func (*THBaseServiceCheckAndDeleteResult) GetIo

func (*THBaseServiceCheckAndDeleteResult) GetSuccess

func (p *THBaseServiceCheckAndDeleteResult) GetSuccess() bool

func (*THBaseServiceCheckAndDeleteResult) IsSetIo

func (*THBaseServiceCheckAndDeleteResult) IsSetSuccess

func (p *THBaseServiceCheckAndDeleteResult) IsSetSuccess() bool

func (*THBaseServiceCheckAndDeleteResult) Read

func (*THBaseServiceCheckAndDeleteResult) ReadField0

func (*THBaseServiceCheckAndDeleteResult) ReadField1

func (*THBaseServiceCheckAndDeleteResult) String

func (*THBaseServiceCheckAndDeleteResult) Write

type THBaseServiceCheckAndMutateArgs

type THBaseServiceCheckAndMutateArgs struct {
	Table           []byte           `thrift:"table,1,required" db:"table" json:"table"`
	Row             []byte           `thrift:"row,2,required" db:"row" json:"row"`
	Family          []byte           `thrift:"family,3,required" db:"family" json:"family"`
	Qualifier       []byte           `thrift:"qualifier,4,required" db:"qualifier" json:"qualifier"`
	CompareOperator TCompareOperator `thrift:"compareOperator,5,required" db:"compareOperator" json:"compareOperator"`
	Value           []byte           `thrift:"value,6" db:"value" json:"value"`
	RowMutations    *TRowMutations   `thrift:"rowMutations,7,required" db:"rowMutations" json:"rowMutations"`
}

Attributes:

  • Table: to check in and delete from
  • Row: row to check
  • Family: column family to check
  • Qualifier: column qualifier to check
  • CompareOperator: comparison to make on the value
  • Value: the expected value to be compared against, if not provided the

check is for the non-existence of the column in question

  • RowMutations: row mutations to execute if the value matches

func NewTHBaseServiceCheckAndMutateArgs

func NewTHBaseServiceCheckAndMutateArgs() *THBaseServiceCheckAndMutateArgs

func (*THBaseServiceCheckAndMutateArgs) GetCompareOperator

func (p *THBaseServiceCheckAndMutateArgs) GetCompareOperator() TCompareOperator

func (*THBaseServiceCheckAndMutateArgs) GetFamily

func (p *THBaseServiceCheckAndMutateArgs) GetFamily() []byte

func (*THBaseServiceCheckAndMutateArgs) GetQualifier

func (p *THBaseServiceCheckAndMutateArgs) GetQualifier() []byte

func (*THBaseServiceCheckAndMutateArgs) GetRow

func (p *THBaseServiceCheckAndMutateArgs) GetRow() []byte

func (*THBaseServiceCheckAndMutateArgs) GetRowMutations

func (p *THBaseServiceCheckAndMutateArgs) GetRowMutations() *TRowMutations

func (*THBaseServiceCheckAndMutateArgs) GetTable

func (p *THBaseServiceCheckAndMutateArgs) GetTable() []byte

func (*THBaseServiceCheckAndMutateArgs) GetValue

func (p *THBaseServiceCheckAndMutateArgs) GetValue() []byte

func (*THBaseServiceCheckAndMutateArgs) IsSetRowMutations

func (p *THBaseServiceCheckAndMutateArgs) IsSetRowMutations() bool

func (*THBaseServiceCheckAndMutateArgs) Read

func (*THBaseServiceCheckAndMutateArgs) ReadField1

func (*THBaseServiceCheckAndMutateArgs) ReadField2

func (*THBaseServiceCheckAndMutateArgs) ReadField3

func (*THBaseServiceCheckAndMutateArgs) ReadField4

func (*THBaseServiceCheckAndMutateArgs) ReadField5

func (*THBaseServiceCheckAndMutateArgs) ReadField6

func (*THBaseServiceCheckAndMutateArgs) ReadField7

func (*THBaseServiceCheckAndMutateArgs) String

func (*THBaseServiceCheckAndMutateArgs) Write

type THBaseServiceCheckAndMutateResult

type THBaseServiceCheckAndMutateResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceCheckAndMutateResult

func NewTHBaseServiceCheckAndMutateResult() *THBaseServiceCheckAndMutateResult

func (*THBaseServiceCheckAndMutateResult) GetIo

func (*THBaseServiceCheckAndMutateResult) GetSuccess

func (p *THBaseServiceCheckAndMutateResult) GetSuccess() bool

func (*THBaseServiceCheckAndMutateResult) IsSetIo

func (*THBaseServiceCheckAndMutateResult) IsSetSuccess

func (p *THBaseServiceCheckAndMutateResult) IsSetSuccess() bool

func (*THBaseServiceCheckAndMutateResult) Read

func (*THBaseServiceCheckAndMutateResult) ReadField0

func (*THBaseServiceCheckAndMutateResult) ReadField1

func (*THBaseServiceCheckAndMutateResult) String

func (*THBaseServiceCheckAndMutateResult) Write

type THBaseServiceCheckAndPutArgs

type THBaseServiceCheckAndPutArgs struct {
	Table     []byte `thrift:"table,1,required" db:"table" json:"table"`
	Row       []byte `thrift:"row,2,required" db:"row" json:"row"`
	Family    []byte `thrift:"family,3,required" db:"family" json:"family"`
	Qualifier []byte `thrift:"qualifier,4,required" db:"qualifier" json:"qualifier"`
	Value     []byte `thrift:"value,5" db:"value" json:"value"`
	Tput      *TPut  `thrift:"tput,6,required" db:"tput" json:"tput"`
}

Attributes:

  • Table: to check in and put to
  • Row: row to check
  • Family: column family to check
  • Qualifier: column qualifier to check
  • Value: the expected value, if not provided the

check is for the non-existence of the column in question

  • Tput: the TPut to put if the check succeeds

func NewTHBaseServiceCheckAndPutArgs

func NewTHBaseServiceCheckAndPutArgs() *THBaseServiceCheckAndPutArgs

func (*THBaseServiceCheckAndPutArgs) GetFamily

func (p *THBaseServiceCheckAndPutArgs) GetFamily() []byte

func (*THBaseServiceCheckAndPutArgs) GetQualifier

func (p *THBaseServiceCheckAndPutArgs) GetQualifier() []byte

func (*THBaseServiceCheckAndPutArgs) GetRow

func (p *THBaseServiceCheckAndPutArgs) GetRow() []byte

func (*THBaseServiceCheckAndPutArgs) GetTable

func (p *THBaseServiceCheckAndPutArgs) GetTable() []byte

func (*THBaseServiceCheckAndPutArgs) GetTput

func (p *THBaseServiceCheckAndPutArgs) GetTput() *TPut

func (*THBaseServiceCheckAndPutArgs) GetValue

func (p *THBaseServiceCheckAndPutArgs) GetValue() []byte

func (*THBaseServiceCheckAndPutArgs) IsSetTput

func (p *THBaseServiceCheckAndPutArgs) IsSetTput() bool

func (*THBaseServiceCheckAndPutArgs) Read

func (*THBaseServiceCheckAndPutArgs) ReadField1

func (*THBaseServiceCheckAndPutArgs) ReadField2

func (*THBaseServiceCheckAndPutArgs) ReadField3

func (*THBaseServiceCheckAndPutArgs) ReadField4

func (*THBaseServiceCheckAndPutArgs) ReadField5

func (*THBaseServiceCheckAndPutArgs) ReadField6

func (*THBaseServiceCheckAndPutArgs) String

func (*THBaseServiceCheckAndPutArgs) Write

type THBaseServiceCheckAndPutResult

type THBaseServiceCheckAndPutResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceCheckAndPutResult

func NewTHBaseServiceCheckAndPutResult() *THBaseServiceCheckAndPutResult

func (*THBaseServiceCheckAndPutResult) GetIo

func (*THBaseServiceCheckAndPutResult) GetSuccess

func (p *THBaseServiceCheckAndPutResult) GetSuccess() bool

func (*THBaseServiceCheckAndPutResult) IsSetIo

func (p *THBaseServiceCheckAndPutResult) IsSetIo() bool

func (*THBaseServiceCheckAndPutResult) IsSetSuccess

func (p *THBaseServiceCheckAndPutResult) IsSetSuccess() bool

func (*THBaseServiceCheckAndPutResult) Read

func (*THBaseServiceCheckAndPutResult) ReadField0

func (*THBaseServiceCheckAndPutResult) ReadField1

func (*THBaseServiceCheckAndPutResult) String

func (*THBaseServiceCheckAndPutResult) Write

type THBaseServiceClearSlowLogResponsesArgs

type THBaseServiceClearSlowLogResponsesArgs struct {
	ServerNames []*TServerName `thrift:"serverNames,1" db:"serverNames" json:"serverNames"`
}

Attributes:

  • ServerNames: @param serverNames Set of Server names to clean slowlog responses from

func NewTHBaseServiceClearSlowLogResponsesArgs

func NewTHBaseServiceClearSlowLogResponsesArgs() *THBaseServiceClearSlowLogResponsesArgs

func (*THBaseServiceClearSlowLogResponsesArgs) GetServerNames

func (p *THBaseServiceClearSlowLogResponsesArgs) GetServerNames() []*TServerName

func (*THBaseServiceClearSlowLogResponsesArgs) Read

func (*THBaseServiceClearSlowLogResponsesArgs) ReadField1

func (*THBaseServiceClearSlowLogResponsesArgs) String

func (*THBaseServiceClearSlowLogResponsesArgs) Write

type THBaseServiceClearSlowLogResponsesResult

type THBaseServiceClearSlowLogResponsesResult struct {
	Success []bool    `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceClearSlowLogResponsesResult

func NewTHBaseServiceClearSlowLogResponsesResult() *THBaseServiceClearSlowLogResponsesResult

func (*THBaseServiceClearSlowLogResponsesResult) GetIo

func (*THBaseServiceClearSlowLogResponsesResult) GetSuccess

func (*THBaseServiceClearSlowLogResponsesResult) IsSetIo

func (*THBaseServiceClearSlowLogResponsesResult) IsSetSuccess

func (*THBaseServiceClearSlowLogResponsesResult) Read

func (*THBaseServiceClearSlowLogResponsesResult) ReadField0

func (*THBaseServiceClearSlowLogResponsesResult) ReadField1

func (*THBaseServiceClearSlowLogResponsesResult) String

func (*THBaseServiceClearSlowLogResponsesResult) Write

type THBaseServiceClient

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

func NewTHBaseServiceClient

func NewTHBaseServiceClient(c thrift.TClient) *THBaseServiceClient

func NewTHBaseServiceClientProtocol

func NewTHBaseServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *THBaseServiceClient

func (*THBaseServiceClient) AddColumnFamily

func (p *THBaseServiceClient) AddColumnFamily(ctx context.Context, tableName *TTableName, column *TColumnFamilyDescriptor) (_err error)

Add a column family to an existing table. Synchronous operation.

Parameters:

  • TableName: the tablename to add column family to
  • Column: column family descriptor of column family to be added

func (*THBaseServiceClient) Append

func (p *THBaseServiceClient) Append(ctx context.Context, table []byte, tappend *TAppend) (_r *TResult_, _err error)

Parameters:

  • Table: the table to append the value on
  • Tappend: the TAppend to append

func (*THBaseServiceClient) CheckAndDelete

func (p *THBaseServiceClient) CheckAndDelete(ctx context.Context, table []byte, row []byte, family []byte, qualifier []byte, value []byte, tdelete *TDelete) (_r bool, _err error)

Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the delete.

@return true if the new delete was executed, false otherwise

Parameters:

  • Table: to check in and delete from
  • Row: row to check
  • Family: column family to check
  • Qualifier: column qualifier to check
  • Value: the expected value, if not provided the

check is for the non-existence of the column in question

  • Tdelete: the TDelete to execute if the check succeeds

func (*THBaseServiceClient) CheckAndMutate

func (p *THBaseServiceClient) CheckAndMutate(ctx context.Context, table []byte, row []byte, family []byte, qualifier []byte, compareOperator TCompareOperator, value []byte, rowMutations *TRowMutations) (_r bool, _err error)

Atomically checks if a row/family/qualifier value matches the expected value. If it does, it mutates the row.

@return true if the row was mutated, false otherwise

Parameters:

  • Table: to check in and delete from
  • Row: row to check
  • Family: column family to check
  • Qualifier: column qualifier to check
  • CompareOperator: comparison to make on the value
  • Value: the expected value to be compared against, if not provided the

check is for the non-existence of the column in question

  • RowMutations: row mutations to execute if the value matches

func (*THBaseServiceClient) CheckAndPut

func (p *THBaseServiceClient) CheckAndPut(ctx context.Context, table []byte, row []byte, family []byte, qualifier []byte, value []byte, tput *TPut) (_r bool, _err error)

Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the TPut.

@return true if the new put was executed, false otherwise

Parameters:

  • Table: to check in and put to
  • Row: row to check
  • Family: column family to check
  • Qualifier: column qualifier to check
  • Value: the expected value, if not provided the

check is for the non-existence of the column in question

  • Tput: the TPut to put if the check succeeds

func (*THBaseServiceClient) ClearSlowLogResponses

func (p *THBaseServiceClient) ClearSlowLogResponses(ctx context.Context, serverNames []*TServerName) (_r []bool, _err error)

Clears online slow/large RPC logs from the provided list of RegionServers

@return List of booleans representing if online slowlog response buffer is cleaned

from each RegionServer

@throws TIOError if a remote or network exception occurs

Parameters:

  • ServerNames: @param serverNames Set of Server names to clean slowlog responses from

func (*THBaseServiceClient) Client_

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

func (*THBaseServiceClient) CloseScanner

func (p *THBaseServiceClient) CloseScanner(ctx context.Context, scannerId int32) (_err error)

Closes the scanner. Should be called to free server side resources timely. Typically close once the scanner is not needed anymore, i.e. after looping over it to get all the required rows.

Parameters:

  • ScannerId: the Id of the Scanner to close *

func (*THBaseServiceClient) CreateNamespace

func (p *THBaseServiceClient) CreateNamespace(ctx context.Context, namespaceDesc *TNamespaceDescriptor) (_err error)

Create a new namespace. Blocks until namespace has been successfully created or an exception is thrown

Parameters:

  • NamespaceDesc: descriptor which describes the new namespace

func (*THBaseServiceClient) CreateTable

func (p *THBaseServiceClient) CreateTable(ctx context.Context, desc *TTableDescriptor, splitKeys [][]byte) (_err error)

Creates a new table with an initial set of empty regions defined by the specified split keys. The total number of regions created will be the number of split keys plus one. Synchronous operation.

Parameters:

  • Desc: table descriptor for table
  • SplitKeys: rray of split keys for the initial regions of the table

func (*THBaseServiceClient) DeleteColumnFamily

func (p *THBaseServiceClient) DeleteColumnFamily(ctx context.Context, tableName *TTableName, column []byte) (_err error)

Delete a column family from a table. Synchronous operation.

Parameters:

  • TableName: the tablename to delete column family from
  • Column: name of column family to be deleted

func (*THBaseServiceClient) DeleteMultiple

func (p *THBaseServiceClient) DeleteMultiple(ctx context.Context, table []byte, tdeletes []*TDelete) (_r []*TDelete, _err error)

Bulk commit a List of TDeletes to the table.

Throws a TIOError if any of the deletes fail.

Always returns an empty list for backwards compatibility.

Parameters:

  • Table: the table to delete from
  • Tdeletes: list of TDeletes to delete

func (*THBaseServiceClient) DeleteNamespace

func (p *THBaseServiceClient) DeleteNamespace(ctx context.Context, name string) (_err error)

Delete an existing namespace. Only empty namespaces (no tables) can be removed. Blocks until namespace has been successfully deleted or an exception is thrown.

Parameters:

  • Name: namespace name

func (*THBaseServiceClient) DeleteSingle

func (p *THBaseServiceClient) DeleteSingle(ctx context.Context, table []byte, tdelete *TDelete) (_err error)

Deletes as specified by the TDelete.

Note: "delete" is a reserved keyword and cannot be used in Thrift thus the inconsistent naming scheme from the other functions.

Parameters:

  • Table: the table to delete from
  • Tdelete: the TDelete to delete

func (*THBaseServiceClient) DeleteTable

func (p *THBaseServiceClient) DeleteTable(ctx context.Context, tableName *TTableName) (_err error)

Deletes a table. Synchronous operation.

Parameters:

  • TableName: the tablename to delete

func (*THBaseServiceClient) DisableTable

func (p *THBaseServiceClient) DisableTable(ctx context.Context, tableName *TTableName) (_err error)

Disable a table

Parameters:

  • TableName: the tablename to disable

func (*THBaseServiceClient) EnableTable

func (p *THBaseServiceClient) EnableTable(ctx context.Context, tableName *TTableName) (_err error)

Enalbe a table

Parameters:

  • TableName: the tablename to enable

func (*THBaseServiceClient) Exists

func (p *THBaseServiceClient) Exists(ctx context.Context, table []byte, tget *TGet) (_r bool, _err error)

Test for the existence of columns in the table, as specified in the TGet.

@return true if the specified TGet matches one or more keys, false if not

Parameters:

  • Table: the table to check on
  • Tget: the TGet to check for

func (*THBaseServiceClient) ExistsAll

func (p *THBaseServiceClient) ExistsAll(ctx context.Context, table []byte, tgets []*TGet) (_r []bool, _err error)

Test for the existence of columns in the table, as specified by the TGets.

This will return an array of booleans. Each value will be true if the related Get matches one or more keys, false if not.

Parameters:

  • Table: the table to check on
  • Tgets: a list of TGets to check for

func (*THBaseServiceClient) Get

func (p *THBaseServiceClient) Get(ctx context.Context, table []byte, tget *TGet) (_r *TResult_, _err error)

Method for getting data from a row.

If the row cannot be found an empty Result is returned. This can be checked by the empty field of the TResult

@return the result

Parameters:

  • Table: the table to get from
  • Tget: the TGet to fetch

func (*THBaseServiceClient) GetAllRegionLocations

func (p *THBaseServiceClient) GetAllRegionLocations(ctx context.Context, table []byte) (_r []*THRegionLocation, _err error)

Get all of the region locations for a given table.

Parameters:

  • Table

func (*THBaseServiceClient) GetClusterId

func (p *THBaseServiceClient) GetClusterId(ctx context.Context) (_r string, _err error)

Returns the cluster ID for this cluster.

func (*THBaseServiceClient) GetMultiple

func (p *THBaseServiceClient) GetMultiple(ctx context.Context, table []byte, tgets []*TGet) (_r []*TResult_, _err error)

Method for getting multiple rows.

If a row cannot be found there will be a null value in the result list for that TGet at the same position.

So the Results are in the same order as the TGets.

Parameters:

  • Table: the table to get from
  • Tgets: a list of TGets to fetch, the Result list

will have the Results at corresponding positions or null if there was an error

func (*THBaseServiceClient) GetNamespaceDescriptor

func (p *THBaseServiceClient) GetNamespaceDescriptor(ctx context.Context, name string) (_r *TNamespaceDescriptor, _err error)

Get a namespace descriptor by name. @retrun the descriptor

Parameters:

  • Name: name of namespace descriptor

func (*THBaseServiceClient) GetRegionLocation

func (p *THBaseServiceClient) GetRegionLocation(ctx context.Context, table []byte, row []byte, reload bool) (_r *THRegionLocation, _err error)

Given a table and a row get the location of the region that would contain the given row key.

reload = true means the cache will be cleared and the location will be fetched from meta.

Parameters:

  • Table
  • Row
  • Reload

func (*THBaseServiceClient) GetScannerResults

func (p *THBaseServiceClient) GetScannerResults(ctx context.Context, table []byte, tscan *TScan, numRows int32) (_r []*TResult_, _err error)

Get results for the provided TScan object. This helper function opens a scanner, get the results and close the scanner.

@return between zero and numRows TResults

Parameters:

  • Table: the table to get the Scanner for
  • Tscan: the scan object to get a Scanner for
  • NumRows: number of rows to return

func (*THBaseServiceClient) GetScannerRows

func (p *THBaseServiceClient) GetScannerRows(ctx context.Context, scannerId int32, numRows int32) (_r []*TResult_, _err error)

Grabs multiple rows from a Scanner.

@return Between zero and numRows TResults

Parameters:

  • ScannerId: the Id of the Scanner to return rows from. This is an Id returned from the openScanner function.
  • NumRows: number of rows to return

func (*THBaseServiceClient) GetSlowLogResponses

func (p *THBaseServiceClient) GetSlowLogResponses(ctx context.Context, serverNames []*TServerName, logQueryFilter *TLogQueryFilter) (_r []*TOnlineLogRecord, _err error)

Retrieves online slow RPC logs from the provided list of RegionServers

@return online slowlog response list @throws TIOError if a remote or network exception occurs

Parameters:

  • ServerNames: @param serverNames Server names to get slowlog responses from
  • LogQueryFilter: @param logQueryFilter filter to be used if provided

func (*THBaseServiceClient) GetTableDescriptor

func (p *THBaseServiceClient) GetTableDescriptor(ctx context.Context, table *TTableName) (_r *TTableDescriptor, _err error)

Get a table descriptor. @return the TableDescriptor of the giving tablename

Parameters:

  • Table: the tablename of the table to get tableDescriptor

func (*THBaseServiceClient) GetTableDescriptors

func (p *THBaseServiceClient) GetTableDescriptors(ctx context.Context, tables []*TTableName) (_r []*TTableDescriptor, _err error)

Get table descriptors of tables. @return the TableDescriptor of the giving tablename

Parameters:

  • Tables: the tablename list of the tables to get tableDescriptor

func (*THBaseServiceClient) GetTableDescriptorsByNamespace

func (p *THBaseServiceClient) GetTableDescriptorsByNamespace(ctx context.Context, name string) (_r []*TTableDescriptor, _err error)

Get table descriptors of tables in the given namespace @return the tableDescriptors in the namespce

Parameters:

  • Name: The namesapce's name

func (*THBaseServiceClient) GetTableDescriptorsByPattern

func (p *THBaseServiceClient) GetTableDescriptorsByPattern(ctx context.Context, regex string, includeSysTables bool) (_r []*TTableDescriptor, _err error)

Get table descriptors of tables that match the given pattern @return the tableDescriptors of the matching table

Parameters:

  • Regex: The regular expression to match against
  • IncludeSysTables: set to false if match only against userspace tables

func (*THBaseServiceClient) GetTableNamesByNamespace

func (p *THBaseServiceClient) GetTableNamesByNamespace(ctx context.Context, name string) (_r []*TTableName, _err error)

Get table names of tables in the given namespace @return the table names of the matching table

Parameters:

  • Name: The namesapce's name

func (*THBaseServiceClient) GetTableNamesByPattern

func (p *THBaseServiceClient) GetTableNamesByPattern(ctx context.Context, regex string, includeSysTables bool) (_r []*TTableName, _err error)

Get table names of tables that match the given pattern @return the table names of the matching table

Parameters:

  • Regex: The regular expression to match against
  • IncludeSysTables: set to false if match only against userspace tables

func (*THBaseServiceClient) GetThriftServerType

func (p *THBaseServiceClient) GetThriftServerType(ctx context.Context) (_r TThriftServerType, _err error)

Get the type of this thrift server.

@return the type of this thrift server

func (*THBaseServiceClient) Grant

func (p *THBaseServiceClient) Grant(ctx context.Context, info *TAccessControlEntity) (_r bool, _err error)

Grant permissions in table or namespace level.

Parameters:

  • Info

func (*THBaseServiceClient) Increment

func (p *THBaseServiceClient) Increment(ctx context.Context, table []byte, tincrement *TIncrement) (_r *TResult_, _err error)

Parameters:

  • Table: the table to increment the value on
  • Tincrement: the TIncrement to increment

func (*THBaseServiceClient) IsTableAvailable

func (p *THBaseServiceClient) IsTableAvailable(ctx context.Context, tableName *TTableName) (_r bool, _err error)

@return true if table is available, false if not

Parameters:

  • TableName: the tablename to check

func (*THBaseServiceClient) IsTableAvailableWithSplit

func (p *THBaseServiceClient) IsTableAvailableWithSplit(ctx context.Context, tableName *TTableName, splitKeys [][]byte) (_r bool, _err error)
  • Use this api to check if the table has been created with the specified number of splitkeys
  • which was used while creating the given table. Note : If this api is used after a table's
  • region gets splitted, the api may return false. *
  • @return true if table is available, false if not *
  • @deprecated Since 2.2.0. Because the same method in Table interface has been deprecated
  • since 2.0.0, we will remove it in 3.0.0 release.
  • Use {@link #isTableAvailable(TTableName tableName)} instead

*

Parameters:

  • TableName: the tablename to check
  • SplitKeys: keys to check if the table has been created with all split keys

func (*THBaseServiceClient) IsTableDisabled

func (p *THBaseServiceClient) IsTableDisabled(ctx context.Context, tableName *TTableName) (_r bool, _err error)

@return true if table is disabled, false if not

Parameters:

  • TableName: the tablename to check

func (*THBaseServiceClient) IsTableEnabled

func (p *THBaseServiceClient) IsTableEnabled(ctx context.Context, tableName *TTableName) (_r bool, _err error)

@return true if table is enabled, false if not

Parameters:

  • TableName: the tablename to check

func (*THBaseServiceClient) LastResponseMeta_

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

func (*THBaseServiceClient) ListNamespaceDescriptors

func (p *THBaseServiceClient) ListNamespaceDescriptors(ctx context.Context) (_r []*TNamespaceDescriptor, _err error)

@return all namespaces

func (*THBaseServiceClient) ListNamespaces

func (p *THBaseServiceClient) ListNamespaces(ctx context.Context) (_r []string, _err error)

@return all namespace names

func (*THBaseServiceClient) ModifyColumnFamily

func (p *THBaseServiceClient) ModifyColumnFamily(ctx context.Context, tableName *TTableName, column *TColumnFamilyDescriptor) (_err error)

Modify an existing column family on a table. Synchronous operation.

Parameters:

  • TableName: the tablename to modify column family
  • Column: column family descriptor of column family to be modified

func (*THBaseServiceClient) ModifyNamespace

func (p *THBaseServiceClient) ModifyNamespace(ctx context.Context, namespaceDesc *TNamespaceDescriptor) (_err error)

Modify an existing namespace. Blocks until namespace has been successfully modified or an exception is thrown

Parameters:

  • NamespaceDesc: descriptor which describes the new namespace

func (*THBaseServiceClient) ModifyTable

func (p *THBaseServiceClient) ModifyTable(ctx context.Context, desc *TTableDescriptor) (_err error)

Modify an existing table

Parameters:

  • Desc: the descriptor of the table to modify

func (*THBaseServiceClient) MutateRow

func (p *THBaseServiceClient) MutateRow(ctx context.Context, table []byte, trowMutations *TRowMutations) (_err error)

mutateRow performs multiple mutations atomically on a single row.

Parameters:

  • Table: table to apply the mutations
  • TrowMutations: mutations to apply

func (*THBaseServiceClient) OpenScanner

func (p *THBaseServiceClient) OpenScanner(ctx context.Context, table []byte, tscan *TScan) (_r int32, _err error)

Get a Scanner for the provided TScan object.

@return Scanner Id to be used with other scanner procedures

Parameters:

  • Table: the table to get the Scanner for
  • Tscan: the scan object to get a Scanner for

func (*THBaseServiceClient) Put

func (p *THBaseServiceClient) Put(ctx context.Context, table []byte, tput *TPut) (_err error)

Commit a TPut to a table.

Parameters:

  • Table: the table to put data in
  • Tput: the TPut to put

func (*THBaseServiceClient) PutMultiple

func (p *THBaseServiceClient) PutMultiple(ctx context.Context, table []byte, tputs []*TPut) (_err error)

Commit a List of Puts to the table.

Parameters:

  • Table: the table to put data in
  • Tputs: a list of TPuts to commit

func (*THBaseServiceClient) Revoke

func (p *THBaseServiceClient) Revoke(ctx context.Context, info *TAccessControlEntity) (_r bool, _err error)

Revoke permissions in table or namespace level.

Parameters:

  • Info

func (*THBaseServiceClient) SetLastResponseMeta_

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

func (*THBaseServiceClient) TableExists

func (p *THBaseServiceClient) TableExists(ctx context.Context, tableName *TTableName) (_r bool, _err error)

@return true if table exists already, false if not

Parameters:

  • TableName: the tablename of the tables to check

func (*THBaseServiceClient) TruncateTable

func (p *THBaseServiceClient) TruncateTable(ctx context.Context, tableName *TTableName, preserveSplits bool) (_err error)

Truncate a table. Synchronous operation.

Parameters:

  • TableName: the tablename to truncate
  • PreserveSplits: whether to preserve previous splits

type THBaseServiceCloseScannerArgs

type THBaseServiceCloseScannerArgs struct {
	ScannerId int32 `thrift:"scannerId,1,required" db:"scannerId" json:"scannerId"`
}

Attributes:

  • ScannerId: the Id of the Scanner to close *

func NewTHBaseServiceCloseScannerArgs

func NewTHBaseServiceCloseScannerArgs() *THBaseServiceCloseScannerArgs

func (*THBaseServiceCloseScannerArgs) GetScannerId

func (p *THBaseServiceCloseScannerArgs) GetScannerId() int32

func (*THBaseServiceCloseScannerArgs) Read

func (*THBaseServiceCloseScannerArgs) ReadField1

func (*THBaseServiceCloseScannerArgs) String

func (*THBaseServiceCloseScannerArgs) Write

type THBaseServiceCloseScannerResult

type THBaseServiceCloseScannerResult struct {
	Io *TIOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia *TIllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Io
  • Ia: if the scannerId is invalid

func NewTHBaseServiceCloseScannerResult

func NewTHBaseServiceCloseScannerResult() *THBaseServiceCloseScannerResult

func (*THBaseServiceCloseScannerResult) GetIa

func (*THBaseServiceCloseScannerResult) GetIo

func (*THBaseServiceCloseScannerResult) IsSetIa

func (*THBaseServiceCloseScannerResult) IsSetIo

func (*THBaseServiceCloseScannerResult) Read

func (*THBaseServiceCloseScannerResult) ReadField1

func (*THBaseServiceCloseScannerResult) ReadField2

func (*THBaseServiceCloseScannerResult) String

func (*THBaseServiceCloseScannerResult) Write

type THBaseServiceCreateNamespaceArgs

type THBaseServiceCreateNamespaceArgs struct {
	NamespaceDesc *TNamespaceDescriptor `thrift:"namespaceDesc,1,required" db:"namespaceDesc" json:"namespaceDesc"`
}

Attributes:

  • NamespaceDesc: descriptor which describes the new namespace

func NewTHBaseServiceCreateNamespaceArgs

func NewTHBaseServiceCreateNamespaceArgs() *THBaseServiceCreateNamespaceArgs

func (*THBaseServiceCreateNamespaceArgs) GetNamespaceDesc

func (*THBaseServiceCreateNamespaceArgs) IsSetNamespaceDesc

func (p *THBaseServiceCreateNamespaceArgs) IsSetNamespaceDesc() bool

func (*THBaseServiceCreateNamespaceArgs) Read

func (*THBaseServiceCreateNamespaceArgs) ReadField1

func (*THBaseServiceCreateNamespaceArgs) String

func (*THBaseServiceCreateNamespaceArgs) Write

type THBaseServiceCreateNamespaceResult

type THBaseServiceCreateNamespaceResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceCreateNamespaceResult

func NewTHBaseServiceCreateNamespaceResult() *THBaseServiceCreateNamespaceResult

func (*THBaseServiceCreateNamespaceResult) GetIo

func (*THBaseServiceCreateNamespaceResult) IsSetIo

func (*THBaseServiceCreateNamespaceResult) Read

func (*THBaseServiceCreateNamespaceResult) ReadField1

func (*THBaseServiceCreateNamespaceResult) String

func (*THBaseServiceCreateNamespaceResult) Write

type THBaseServiceCreateTableArgs

type THBaseServiceCreateTableArgs struct {
	Desc      *TTableDescriptor `thrift:"desc,1,required" db:"desc" json:"desc"`
	SplitKeys [][]byte          `thrift:"splitKeys,2" db:"splitKeys" json:"splitKeys"`
}

Attributes:

  • Desc: table descriptor for table
  • SplitKeys: rray of split keys for the initial regions of the table

func NewTHBaseServiceCreateTableArgs

func NewTHBaseServiceCreateTableArgs() *THBaseServiceCreateTableArgs

func (*THBaseServiceCreateTableArgs) GetDesc

func (*THBaseServiceCreateTableArgs) GetSplitKeys

func (p *THBaseServiceCreateTableArgs) GetSplitKeys() [][]byte

func (*THBaseServiceCreateTableArgs) IsSetDesc

func (p *THBaseServiceCreateTableArgs) IsSetDesc() bool

func (*THBaseServiceCreateTableArgs) Read

func (*THBaseServiceCreateTableArgs) ReadField1

func (*THBaseServiceCreateTableArgs) ReadField2

func (*THBaseServiceCreateTableArgs) String

func (*THBaseServiceCreateTableArgs) Write

type THBaseServiceCreateTableResult

type THBaseServiceCreateTableResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceCreateTableResult

func NewTHBaseServiceCreateTableResult() *THBaseServiceCreateTableResult

func (*THBaseServiceCreateTableResult) GetIo

func (*THBaseServiceCreateTableResult) IsSetIo

func (p *THBaseServiceCreateTableResult) IsSetIo() bool

func (*THBaseServiceCreateTableResult) Read

func (*THBaseServiceCreateTableResult) ReadField1

func (*THBaseServiceCreateTableResult) String

func (*THBaseServiceCreateTableResult) Write

type THBaseServiceDeleteColumnFamilyArgs

type THBaseServiceDeleteColumnFamilyArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
	Column    []byte      `thrift:"column,2,required" db:"column" json:"column"`
}

Attributes:

  • TableName: the tablename to delete column family from
  • Column: name of column family to be deleted

func NewTHBaseServiceDeleteColumnFamilyArgs

func NewTHBaseServiceDeleteColumnFamilyArgs() *THBaseServiceDeleteColumnFamilyArgs

func (*THBaseServiceDeleteColumnFamilyArgs) GetColumn

func (p *THBaseServiceDeleteColumnFamilyArgs) GetColumn() []byte

func (*THBaseServiceDeleteColumnFamilyArgs) GetTableName

func (*THBaseServiceDeleteColumnFamilyArgs) IsSetTableName

func (p *THBaseServiceDeleteColumnFamilyArgs) IsSetTableName() bool

func (*THBaseServiceDeleteColumnFamilyArgs) Read

func (*THBaseServiceDeleteColumnFamilyArgs) ReadField1

func (*THBaseServiceDeleteColumnFamilyArgs) ReadField2

func (*THBaseServiceDeleteColumnFamilyArgs) String

func (*THBaseServiceDeleteColumnFamilyArgs) Write

type THBaseServiceDeleteColumnFamilyResult

type THBaseServiceDeleteColumnFamilyResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceDeleteColumnFamilyResult

func NewTHBaseServiceDeleteColumnFamilyResult() *THBaseServiceDeleteColumnFamilyResult

func (*THBaseServiceDeleteColumnFamilyResult) GetIo

func (*THBaseServiceDeleteColumnFamilyResult) IsSetIo

func (*THBaseServiceDeleteColumnFamilyResult) Read

func (*THBaseServiceDeleteColumnFamilyResult) ReadField1

func (*THBaseServiceDeleteColumnFamilyResult) String

func (*THBaseServiceDeleteColumnFamilyResult) Write

type THBaseServiceDeleteMultipleArgs

type THBaseServiceDeleteMultipleArgs struct {
	Table    []byte     `thrift:"table,1,required" db:"table" json:"table"`
	Tdeletes []*TDelete `thrift:"tdeletes,2,required" db:"tdeletes" json:"tdeletes"`
}

Attributes:

  • Table: the table to delete from
  • Tdeletes: list of TDeletes to delete

func NewTHBaseServiceDeleteMultipleArgs

func NewTHBaseServiceDeleteMultipleArgs() *THBaseServiceDeleteMultipleArgs

func (*THBaseServiceDeleteMultipleArgs) GetTable

func (p *THBaseServiceDeleteMultipleArgs) GetTable() []byte

func (*THBaseServiceDeleteMultipleArgs) GetTdeletes

func (p *THBaseServiceDeleteMultipleArgs) GetTdeletes() []*TDelete

func (*THBaseServiceDeleteMultipleArgs) Read

func (*THBaseServiceDeleteMultipleArgs) ReadField1

func (*THBaseServiceDeleteMultipleArgs) ReadField2

func (*THBaseServiceDeleteMultipleArgs) String

func (*THBaseServiceDeleteMultipleArgs) Write

type THBaseServiceDeleteMultipleResult

type THBaseServiceDeleteMultipleResult struct {
	Success []*TDelete `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError  `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceDeleteMultipleResult

func NewTHBaseServiceDeleteMultipleResult() *THBaseServiceDeleteMultipleResult

func (*THBaseServiceDeleteMultipleResult) GetIo

func (*THBaseServiceDeleteMultipleResult) GetSuccess

func (p *THBaseServiceDeleteMultipleResult) GetSuccess() []*TDelete

func (*THBaseServiceDeleteMultipleResult) IsSetIo

func (*THBaseServiceDeleteMultipleResult) IsSetSuccess

func (p *THBaseServiceDeleteMultipleResult) IsSetSuccess() bool

func (*THBaseServiceDeleteMultipleResult) Read

func (*THBaseServiceDeleteMultipleResult) ReadField0

func (*THBaseServiceDeleteMultipleResult) ReadField1

func (*THBaseServiceDeleteMultipleResult) String

func (*THBaseServiceDeleteMultipleResult) Write

type THBaseServiceDeleteNamespaceArgs

type THBaseServiceDeleteNamespaceArgs struct {
	Name string `thrift:"name,1,required" db:"name" json:"name"`
}

Attributes:

  • Name: namespace name

func NewTHBaseServiceDeleteNamespaceArgs

func NewTHBaseServiceDeleteNamespaceArgs() *THBaseServiceDeleteNamespaceArgs

func (*THBaseServiceDeleteNamespaceArgs) GetName

func (*THBaseServiceDeleteNamespaceArgs) Read

func (*THBaseServiceDeleteNamespaceArgs) ReadField1

func (*THBaseServiceDeleteNamespaceArgs) String

func (*THBaseServiceDeleteNamespaceArgs) Write

type THBaseServiceDeleteNamespaceResult

type THBaseServiceDeleteNamespaceResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceDeleteNamespaceResult

func NewTHBaseServiceDeleteNamespaceResult() *THBaseServiceDeleteNamespaceResult

func (*THBaseServiceDeleteNamespaceResult) GetIo

func (*THBaseServiceDeleteNamespaceResult) IsSetIo

func (*THBaseServiceDeleteNamespaceResult) Read

func (*THBaseServiceDeleteNamespaceResult) ReadField1

func (*THBaseServiceDeleteNamespaceResult) String

func (*THBaseServiceDeleteNamespaceResult) Write

type THBaseServiceDeleteSingleArgs

type THBaseServiceDeleteSingleArgs struct {
	Table   []byte   `thrift:"table,1,required" db:"table" json:"table"`
	Tdelete *TDelete `thrift:"tdelete,2,required" db:"tdelete" json:"tdelete"`
}

Attributes:

  • Table: the table to delete from
  • Tdelete: the TDelete to delete

func NewTHBaseServiceDeleteSingleArgs

func NewTHBaseServiceDeleteSingleArgs() *THBaseServiceDeleteSingleArgs

func (*THBaseServiceDeleteSingleArgs) GetTable

func (p *THBaseServiceDeleteSingleArgs) GetTable() []byte

func (*THBaseServiceDeleteSingleArgs) GetTdelete

func (p *THBaseServiceDeleteSingleArgs) GetTdelete() *TDelete

func (*THBaseServiceDeleteSingleArgs) IsSetTdelete

func (p *THBaseServiceDeleteSingleArgs) IsSetTdelete() bool

func (*THBaseServiceDeleteSingleArgs) Read

func (*THBaseServiceDeleteSingleArgs) ReadField1

func (*THBaseServiceDeleteSingleArgs) ReadField2

func (*THBaseServiceDeleteSingleArgs) String

func (*THBaseServiceDeleteSingleArgs) Write

type THBaseServiceDeleteSingleResult

type THBaseServiceDeleteSingleResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceDeleteSingleResult

func NewTHBaseServiceDeleteSingleResult() *THBaseServiceDeleteSingleResult

func (*THBaseServiceDeleteSingleResult) GetIo

func (*THBaseServiceDeleteSingleResult) IsSetIo

func (*THBaseServiceDeleteSingleResult) Read

func (*THBaseServiceDeleteSingleResult) ReadField1

func (*THBaseServiceDeleteSingleResult) String

func (*THBaseServiceDeleteSingleResult) Write

type THBaseServiceDeleteTableArgs

type THBaseServiceDeleteTableArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename to delete

func NewTHBaseServiceDeleteTableArgs

func NewTHBaseServiceDeleteTableArgs() *THBaseServiceDeleteTableArgs

func (*THBaseServiceDeleteTableArgs) GetTableName

func (p *THBaseServiceDeleteTableArgs) GetTableName() *TTableName

func (*THBaseServiceDeleteTableArgs) IsSetTableName

func (p *THBaseServiceDeleteTableArgs) IsSetTableName() bool

func (*THBaseServiceDeleteTableArgs) Read

func (*THBaseServiceDeleteTableArgs) ReadField1

func (*THBaseServiceDeleteTableArgs) String

func (*THBaseServiceDeleteTableArgs) Write

type THBaseServiceDeleteTableResult

type THBaseServiceDeleteTableResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceDeleteTableResult

func NewTHBaseServiceDeleteTableResult() *THBaseServiceDeleteTableResult

func (*THBaseServiceDeleteTableResult) GetIo

func (*THBaseServiceDeleteTableResult) IsSetIo

func (p *THBaseServiceDeleteTableResult) IsSetIo() bool

func (*THBaseServiceDeleteTableResult) Read

func (*THBaseServiceDeleteTableResult) ReadField1

func (*THBaseServiceDeleteTableResult) String

func (*THBaseServiceDeleteTableResult) Write

type THBaseServiceDisableTableArgs

type THBaseServiceDisableTableArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename to disable

func NewTHBaseServiceDisableTableArgs

func NewTHBaseServiceDisableTableArgs() *THBaseServiceDisableTableArgs

func (*THBaseServiceDisableTableArgs) GetTableName

func (p *THBaseServiceDisableTableArgs) GetTableName() *TTableName

func (*THBaseServiceDisableTableArgs) IsSetTableName

func (p *THBaseServiceDisableTableArgs) IsSetTableName() bool

func (*THBaseServiceDisableTableArgs) Read

func (*THBaseServiceDisableTableArgs) ReadField1

func (*THBaseServiceDisableTableArgs) String

func (*THBaseServiceDisableTableArgs) Write

type THBaseServiceDisableTableResult

type THBaseServiceDisableTableResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceDisableTableResult

func NewTHBaseServiceDisableTableResult() *THBaseServiceDisableTableResult

func (*THBaseServiceDisableTableResult) GetIo

func (*THBaseServiceDisableTableResult) IsSetIo

func (*THBaseServiceDisableTableResult) Read

func (*THBaseServiceDisableTableResult) ReadField1

func (*THBaseServiceDisableTableResult) String

func (*THBaseServiceDisableTableResult) Write

type THBaseServiceEnableTableArgs

type THBaseServiceEnableTableArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename to enable

func NewTHBaseServiceEnableTableArgs

func NewTHBaseServiceEnableTableArgs() *THBaseServiceEnableTableArgs

func (*THBaseServiceEnableTableArgs) GetTableName

func (p *THBaseServiceEnableTableArgs) GetTableName() *TTableName

func (*THBaseServiceEnableTableArgs) IsSetTableName

func (p *THBaseServiceEnableTableArgs) IsSetTableName() bool

func (*THBaseServiceEnableTableArgs) Read

func (*THBaseServiceEnableTableArgs) ReadField1

func (*THBaseServiceEnableTableArgs) String

func (*THBaseServiceEnableTableArgs) Write

type THBaseServiceEnableTableResult

type THBaseServiceEnableTableResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceEnableTableResult

func NewTHBaseServiceEnableTableResult() *THBaseServiceEnableTableResult

func (*THBaseServiceEnableTableResult) GetIo

func (*THBaseServiceEnableTableResult) IsSetIo

func (p *THBaseServiceEnableTableResult) IsSetIo() bool

func (*THBaseServiceEnableTableResult) Read

func (*THBaseServiceEnableTableResult) ReadField1

func (*THBaseServiceEnableTableResult) String

func (*THBaseServiceEnableTableResult) Write

type THBaseServiceExistsAllArgs

type THBaseServiceExistsAllArgs struct {
	Table []byte  `thrift:"table,1,required" db:"table" json:"table"`
	Tgets []*TGet `thrift:"tgets,2,required" db:"tgets" json:"tgets"`
}

Attributes:

  • Table: the table to check on
  • Tgets: a list of TGets to check for

func NewTHBaseServiceExistsAllArgs

func NewTHBaseServiceExistsAllArgs() *THBaseServiceExistsAllArgs

func (*THBaseServiceExistsAllArgs) GetTable

func (p *THBaseServiceExistsAllArgs) GetTable() []byte

func (*THBaseServiceExistsAllArgs) GetTgets

func (p *THBaseServiceExistsAllArgs) GetTgets() []*TGet

func (*THBaseServiceExistsAllArgs) Read

func (*THBaseServiceExistsAllArgs) ReadField1

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

func (*THBaseServiceExistsAllArgs) ReadField2

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

func (*THBaseServiceExistsAllArgs) String

func (p *THBaseServiceExistsAllArgs) String() string

func (*THBaseServiceExistsAllArgs) Write

type THBaseServiceExistsAllResult

type THBaseServiceExistsAllResult struct {
	Success []bool    `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceExistsAllResult

func NewTHBaseServiceExistsAllResult() *THBaseServiceExistsAllResult

func (*THBaseServiceExistsAllResult) GetIo

func (*THBaseServiceExistsAllResult) GetSuccess

func (p *THBaseServiceExistsAllResult) GetSuccess() []bool

func (*THBaseServiceExistsAllResult) IsSetIo

func (p *THBaseServiceExistsAllResult) IsSetIo() bool

func (*THBaseServiceExistsAllResult) IsSetSuccess

func (p *THBaseServiceExistsAllResult) IsSetSuccess() bool

func (*THBaseServiceExistsAllResult) Read

func (*THBaseServiceExistsAllResult) ReadField0

func (*THBaseServiceExistsAllResult) ReadField1

func (*THBaseServiceExistsAllResult) String

func (*THBaseServiceExistsAllResult) Write

type THBaseServiceExistsArgs

type THBaseServiceExistsArgs struct {
	Table []byte `thrift:"table,1,required" db:"table" json:"table"`
	Tget  *TGet  `thrift:"tget,2,required" db:"tget" json:"tget"`
}

Attributes:

  • Table: the table to check on
  • Tget: the TGet to check for

func NewTHBaseServiceExistsArgs

func NewTHBaseServiceExistsArgs() *THBaseServiceExistsArgs

func (*THBaseServiceExistsArgs) GetTable

func (p *THBaseServiceExistsArgs) GetTable() []byte

func (*THBaseServiceExistsArgs) GetTget

func (p *THBaseServiceExistsArgs) GetTget() *TGet

func (*THBaseServiceExistsArgs) IsSetTget

func (p *THBaseServiceExistsArgs) IsSetTget() bool

func (*THBaseServiceExistsArgs) Read

func (*THBaseServiceExistsArgs) ReadField1

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

func (*THBaseServiceExistsArgs) ReadField2

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

func (*THBaseServiceExistsArgs) String

func (p *THBaseServiceExistsArgs) String() string

func (*THBaseServiceExistsArgs) Write

type THBaseServiceExistsResult

type THBaseServiceExistsResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceExistsResult

func NewTHBaseServiceExistsResult() *THBaseServiceExistsResult

func (*THBaseServiceExistsResult) GetIo

func (p *THBaseServiceExistsResult) GetIo() *TIOError

func (*THBaseServiceExistsResult) GetSuccess

func (p *THBaseServiceExistsResult) GetSuccess() bool

func (*THBaseServiceExistsResult) IsSetIo

func (p *THBaseServiceExistsResult) IsSetIo() bool

func (*THBaseServiceExistsResult) IsSetSuccess

func (p *THBaseServiceExistsResult) IsSetSuccess() bool

func (*THBaseServiceExistsResult) Read

func (*THBaseServiceExistsResult) ReadField0

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

func (*THBaseServiceExistsResult) ReadField1

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

func (*THBaseServiceExistsResult) String

func (p *THBaseServiceExistsResult) String() string

func (*THBaseServiceExistsResult) Write

type THBaseServiceGetAllRegionLocationsArgs

type THBaseServiceGetAllRegionLocationsArgs struct {
	Table []byte `thrift:"table,1,required" db:"table" json:"table"`
}

Attributes:

  • Table

func NewTHBaseServiceGetAllRegionLocationsArgs

func NewTHBaseServiceGetAllRegionLocationsArgs() *THBaseServiceGetAllRegionLocationsArgs

func (*THBaseServiceGetAllRegionLocationsArgs) GetTable

func (*THBaseServiceGetAllRegionLocationsArgs) Read

func (*THBaseServiceGetAllRegionLocationsArgs) ReadField1

func (*THBaseServiceGetAllRegionLocationsArgs) String

func (*THBaseServiceGetAllRegionLocationsArgs) Write

type THBaseServiceGetAllRegionLocationsResult

type THBaseServiceGetAllRegionLocationsResult struct {
	Success []*THRegionLocation `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError           `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetAllRegionLocationsResult

func NewTHBaseServiceGetAllRegionLocationsResult() *THBaseServiceGetAllRegionLocationsResult

func (*THBaseServiceGetAllRegionLocationsResult) GetIo

func (*THBaseServiceGetAllRegionLocationsResult) GetSuccess

func (*THBaseServiceGetAllRegionLocationsResult) IsSetIo

func (*THBaseServiceGetAllRegionLocationsResult) IsSetSuccess

func (*THBaseServiceGetAllRegionLocationsResult) Read

func (*THBaseServiceGetAllRegionLocationsResult) ReadField0

func (*THBaseServiceGetAllRegionLocationsResult) ReadField1

func (*THBaseServiceGetAllRegionLocationsResult) String

func (*THBaseServiceGetAllRegionLocationsResult) Write

type THBaseServiceGetArgs

type THBaseServiceGetArgs struct {
	Table []byte `thrift:"table,1,required" db:"table" json:"table"`
	Tget  *TGet  `thrift:"tget,2,required" db:"tget" json:"tget"`
}

Attributes:

  • Table: the table to get from
  • Tget: the TGet to fetch

func NewTHBaseServiceGetArgs

func NewTHBaseServiceGetArgs() *THBaseServiceGetArgs

func (*THBaseServiceGetArgs) GetTable

func (p *THBaseServiceGetArgs) GetTable() []byte

func (*THBaseServiceGetArgs) GetTget

func (p *THBaseServiceGetArgs) GetTget() *TGet

func (*THBaseServiceGetArgs) IsSetTget

func (p *THBaseServiceGetArgs) IsSetTget() bool

func (*THBaseServiceGetArgs) Read

func (*THBaseServiceGetArgs) ReadField1

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

func (*THBaseServiceGetArgs) ReadField2

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

func (*THBaseServiceGetArgs) String

func (p *THBaseServiceGetArgs) String() string

func (*THBaseServiceGetArgs) Write

type THBaseServiceGetClusterIdArgs

type THBaseServiceGetClusterIdArgs struct {
}

func NewTHBaseServiceGetClusterIdArgs

func NewTHBaseServiceGetClusterIdArgs() *THBaseServiceGetClusterIdArgs

func (*THBaseServiceGetClusterIdArgs) Read

func (*THBaseServiceGetClusterIdArgs) String

func (*THBaseServiceGetClusterIdArgs) Write

type THBaseServiceGetClusterIdResult

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

Attributes:

  • Success

func NewTHBaseServiceGetClusterIdResult

func NewTHBaseServiceGetClusterIdResult() *THBaseServiceGetClusterIdResult

func (*THBaseServiceGetClusterIdResult) GetSuccess

func (p *THBaseServiceGetClusterIdResult) GetSuccess() string

func (*THBaseServiceGetClusterIdResult) IsSetSuccess

func (p *THBaseServiceGetClusterIdResult) IsSetSuccess() bool

func (*THBaseServiceGetClusterIdResult) Read

func (*THBaseServiceGetClusterIdResult) ReadField0

func (*THBaseServiceGetClusterIdResult) String

func (*THBaseServiceGetClusterIdResult) Write

type THBaseServiceGetMultipleArgs

type THBaseServiceGetMultipleArgs struct {
	Table []byte  `thrift:"table,1,required" db:"table" json:"table"`
	Tgets []*TGet `thrift:"tgets,2,required" db:"tgets" json:"tgets"`
}

Attributes:

  • Table: the table to get from
  • Tgets: a list of TGets to fetch, the Result list

will have the Results at corresponding positions or null if there was an error

func NewTHBaseServiceGetMultipleArgs

func NewTHBaseServiceGetMultipleArgs() *THBaseServiceGetMultipleArgs

func (*THBaseServiceGetMultipleArgs) GetTable

func (p *THBaseServiceGetMultipleArgs) GetTable() []byte

func (*THBaseServiceGetMultipleArgs) GetTgets

func (p *THBaseServiceGetMultipleArgs) GetTgets() []*TGet

func (*THBaseServiceGetMultipleArgs) Read

func (*THBaseServiceGetMultipleArgs) ReadField1

func (*THBaseServiceGetMultipleArgs) ReadField2

func (*THBaseServiceGetMultipleArgs) String

func (*THBaseServiceGetMultipleArgs) Write

type THBaseServiceGetMultipleResult

type THBaseServiceGetMultipleResult struct {
	Success []*TResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetMultipleResult

func NewTHBaseServiceGetMultipleResult() *THBaseServiceGetMultipleResult

func (*THBaseServiceGetMultipleResult) GetIo

func (*THBaseServiceGetMultipleResult) GetSuccess

func (p *THBaseServiceGetMultipleResult) GetSuccess() []*TResult_

func (*THBaseServiceGetMultipleResult) IsSetIo

func (p *THBaseServiceGetMultipleResult) IsSetIo() bool

func (*THBaseServiceGetMultipleResult) IsSetSuccess

func (p *THBaseServiceGetMultipleResult) IsSetSuccess() bool

func (*THBaseServiceGetMultipleResult) Read

func (*THBaseServiceGetMultipleResult) ReadField0

func (*THBaseServiceGetMultipleResult) ReadField1

func (*THBaseServiceGetMultipleResult) String

func (*THBaseServiceGetMultipleResult) Write

type THBaseServiceGetNamespaceDescriptorArgs

type THBaseServiceGetNamespaceDescriptorArgs struct {
	Name string `thrift:"name,1,required" db:"name" json:"name"`
}

Attributes:

  • Name: name of namespace descriptor

func NewTHBaseServiceGetNamespaceDescriptorArgs

func NewTHBaseServiceGetNamespaceDescriptorArgs() *THBaseServiceGetNamespaceDescriptorArgs

func (*THBaseServiceGetNamespaceDescriptorArgs) GetName

func (*THBaseServiceGetNamespaceDescriptorArgs) Read

func (*THBaseServiceGetNamespaceDescriptorArgs) ReadField1

func (*THBaseServiceGetNamespaceDescriptorArgs) String

func (*THBaseServiceGetNamespaceDescriptorArgs) Write

type THBaseServiceGetNamespaceDescriptorResult

type THBaseServiceGetNamespaceDescriptorResult struct {
	Success *TNamespaceDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError             `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetNamespaceDescriptorResult

func NewTHBaseServiceGetNamespaceDescriptorResult() *THBaseServiceGetNamespaceDescriptorResult

func (*THBaseServiceGetNamespaceDescriptorResult) GetIo

func (*THBaseServiceGetNamespaceDescriptorResult) GetSuccess

func (*THBaseServiceGetNamespaceDescriptorResult) IsSetIo

func (*THBaseServiceGetNamespaceDescriptorResult) IsSetSuccess

func (*THBaseServiceGetNamespaceDescriptorResult) Read

func (*THBaseServiceGetNamespaceDescriptorResult) ReadField0

func (*THBaseServiceGetNamespaceDescriptorResult) ReadField1

func (*THBaseServiceGetNamespaceDescriptorResult) String

func (*THBaseServiceGetNamespaceDescriptorResult) Write

type THBaseServiceGetRegionLocationArgs

type THBaseServiceGetRegionLocationArgs struct {
	Table  []byte `thrift:"table,1,required" db:"table" json:"table"`
	Row    []byte `thrift:"row,2,required" db:"row" json:"row"`
	Reload bool   `thrift:"reload,3" db:"reload" json:"reload"`
}

Attributes:

  • Table
  • Row
  • Reload

func NewTHBaseServiceGetRegionLocationArgs

func NewTHBaseServiceGetRegionLocationArgs() *THBaseServiceGetRegionLocationArgs

func (*THBaseServiceGetRegionLocationArgs) GetReload

func (*THBaseServiceGetRegionLocationArgs) GetRow

func (*THBaseServiceGetRegionLocationArgs) GetTable

func (p *THBaseServiceGetRegionLocationArgs) GetTable() []byte

func (*THBaseServiceGetRegionLocationArgs) Read

func (*THBaseServiceGetRegionLocationArgs) ReadField1

func (*THBaseServiceGetRegionLocationArgs) ReadField2

func (*THBaseServiceGetRegionLocationArgs) ReadField3

func (*THBaseServiceGetRegionLocationArgs) String

func (*THBaseServiceGetRegionLocationArgs) Write

type THBaseServiceGetRegionLocationResult

type THBaseServiceGetRegionLocationResult struct {
	Success *THRegionLocation `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetRegionLocationResult

func NewTHBaseServiceGetRegionLocationResult() *THBaseServiceGetRegionLocationResult

func (*THBaseServiceGetRegionLocationResult) GetIo

func (*THBaseServiceGetRegionLocationResult) GetSuccess

func (*THBaseServiceGetRegionLocationResult) IsSetIo

func (*THBaseServiceGetRegionLocationResult) IsSetSuccess

func (p *THBaseServiceGetRegionLocationResult) IsSetSuccess() bool

func (*THBaseServiceGetRegionLocationResult) Read

func (*THBaseServiceGetRegionLocationResult) ReadField0

func (*THBaseServiceGetRegionLocationResult) ReadField1

func (*THBaseServiceGetRegionLocationResult) String

func (*THBaseServiceGetRegionLocationResult) Write

type THBaseServiceGetResult

type THBaseServiceGetResult struct {
	Success *TResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetResult

func NewTHBaseServiceGetResult() *THBaseServiceGetResult

func (*THBaseServiceGetResult) GetIo

func (p *THBaseServiceGetResult) GetIo() *TIOError

func (*THBaseServiceGetResult) GetSuccess

func (p *THBaseServiceGetResult) GetSuccess() *TResult_

func (*THBaseServiceGetResult) IsSetIo

func (p *THBaseServiceGetResult) IsSetIo() bool

func (*THBaseServiceGetResult) IsSetSuccess

func (p *THBaseServiceGetResult) IsSetSuccess() bool

func (*THBaseServiceGetResult) Read

func (*THBaseServiceGetResult) ReadField0

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

func (*THBaseServiceGetResult) ReadField1

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

func (*THBaseServiceGetResult) String

func (p *THBaseServiceGetResult) String() string

func (*THBaseServiceGetResult) Write

type THBaseServiceGetScannerResultsArgs

type THBaseServiceGetScannerResultsArgs struct {
	Table   []byte `thrift:"table,1,required" db:"table" json:"table"`
	Tscan   *TScan `thrift:"tscan,2,required" db:"tscan" json:"tscan"`
	NumRows int32  `thrift:"numRows,3" db:"numRows" json:"numRows"`
}

Attributes:

  • Table: the table to get the Scanner for
  • Tscan: the scan object to get a Scanner for
  • NumRows: number of rows to return

func NewTHBaseServiceGetScannerResultsArgs

func NewTHBaseServiceGetScannerResultsArgs() *THBaseServiceGetScannerResultsArgs

func (*THBaseServiceGetScannerResultsArgs) GetNumRows

func (p *THBaseServiceGetScannerResultsArgs) GetNumRows() int32

func (*THBaseServiceGetScannerResultsArgs) GetTable

func (p *THBaseServiceGetScannerResultsArgs) GetTable() []byte

func (*THBaseServiceGetScannerResultsArgs) GetTscan

func (*THBaseServiceGetScannerResultsArgs) IsSetTscan

func (p *THBaseServiceGetScannerResultsArgs) IsSetTscan() bool

func (*THBaseServiceGetScannerResultsArgs) Read

func (*THBaseServiceGetScannerResultsArgs) ReadField1

func (*THBaseServiceGetScannerResultsArgs) ReadField2

func (*THBaseServiceGetScannerResultsArgs) ReadField3

func (*THBaseServiceGetScannerResultsArgs) String

func (*THBaseServiceGetScannerResultsArgs) Write

type THBaseServiceGetScannerResultsResult

type THBaseServiceGetScannerResultsResult struct {
	Success []*TResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetScannerResultsResult

func NewTHBaseServiceGetScannerResultsResult() *THBaseServiceGetScannerResultsResult

func (*THBaseServiceGetScannerResultsResult) GetIo

func (*THBaseServiceGetScannerResultsResult) GetSuccess

func (*THBaseServiceGetScannerResultsResult) IsSetIo

func (*THBaseServiceGetScannerResultsResult) IsSetSuccess

func (p *THBaseServiceGetScannerResultsResult) IsSetSuccess() bool

func (*THBaseServiceGetScannerResultsResult) Read

func (*THBaseServiceGetScannerResultsResult) ReadField0

func (*THBaseServiceGetScannerResultsResult) ReadField1

func (*THBaseServiceGetScannerResultsResult) String

func (*THBaseServiceGetScannerResultsResult) Write

type THBaseServiceGetScannerRowsArgs

type THBaseServiceGetScannerRowsArgs struct {
	ScannerId int32 `thrift:"scannerId,1,required" db:"scannerId" json:"scannerId"`
	NumRows   int32 `thrift:"numRows,2" db:"numRows" json:"numRows"`
}

Attributes:

  • ScannerId: the Id of the Scanner to return rows from. This is an Id returned from the openScanner function.
  • NumRows: number of rows to return

func NewTHBaseServiceGetScannerRowsArgs

func NewTHBaseServiceGetScannerRowsArgs() *THBaseServiceGetScannerRowsArgs

func (*THBaseServiceGetScannerRowsArgs) GetNumRows

func (p *THBaseServiceGetScannerRowsArgs) GetNumRows() int32

func (*THBaseServiceGetScannerRowsArgs) GetScannerId

func (p *THBaseServiceGetScannerRowsArgs) GetScannerId() int32

func (*THBaseServiceGetScannerRowsArgs) Read

func (*THBaseServiceGetScannerRowsArgs) ReadField1

func (*THBaseServiceGetScannerRowsArgs) ReadField2

func (*THBaseServiceGetScannerRowsArgs) String

func (*THBaseServiceGetScannerRowsArgs) Write

type THBaseServiceGetScannerRowsResult

type THBaseServiceGetScannerRowsResult struct {
	Success []*TResult_       `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia      *TIllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Success
  • Io
  • Ia: if the scannerId is invalid

func NewTHBaseServiceGetScannerRowsResult

func NewTHBaseServiceGetScannerRowsResult() *THBaseServiceGetScannerRowsResult

func (*THBaseServiceGetScannerRowsResult) GetIa

func (*THBaseServiceGetScannerRowsResult) GetIo

func (*THBaseServiceGetScannerRowsResult) GetSuccess

func (p *THBaseServiceGetScannerRowsResult) GetSuccess() []*TResult_

func (*THBaseServiceGetScannerRowsResult) IsSetIa

func (*THBaseServiceGetScannerRowsResult) IsSetIo

func (*THBaseServiceGetScannerRowsResult) IsSetSuccess

func (p *THBaseServiceGetScannerRowsResult) IsSetSuccess() bool

func (*THBaseServiceGetScannerRowsResult) Read

func (*THBaseServiceGetScannerRowsResult) ReadField0

func (*THBaseServiceGetScannerRowsResult) ReadField1

func (*THBaseServiceGetScannerRowsResult) ReadField2

func (*THBaseServiceGetScannerRowsResult) String

func (*THBaseServiceGetScannerRowsResult) Write

type THBaseServiceGetSlowLogResponsesArgs

type THBaseServiceGetSlowLogResponsesArgs struct {
	ServerNames    []*TServerName   `thrift:"serverNames,1" db:"serverNames" json:"serverNames"`
	LogQueryFilter *TLogQueryFilter `thrift:"logQueryFilter,2" db:"logQueryFilter" json:"logQueryFilter"`
}

Attributes:

  • ServerNames: @param serverNames Server names to get slowlog responses from
  • LogQueryFilter: @param logQueryFilter filter to be used if provided

func NewTHBaseServiceGetSlowLogResponsesArgs

func NewTHBaseServiceGetSlowLogResponsesArgs() *THBaseServiceGetSlowLogResponsesArgs

func (*THBaseServiceGetSlowLogResponsesArgs) GetLogQueryFilter

func (p *THBaseServiceGetSlowLogResponsesArgs) GetLogQueryFilter() *TLogQueryFilter

func (*THBaseServiceGetSlowLogResponsesArgs) GetServerNames

func (p *THBaseServiceGetSlowLogResponsesArgs) GetServerNames() []*TServerName

func (*THBaseServiceGetSlowLogResponsesArgs) IsSetLogQueryFilter

func (p *THBaseServiceGetSlowLogResponsesArgs) IsSetLogQueryFilter() bool

func (*THBaseServiceGetSlowLogResponsesArgs) Read

func (*THBaseServiceGetSlowLogResponsesArgs) ReadField1

func (*THBaseServiceGetSlowLogResponsesArgs) ReadField2

func (*THBaseServiceGetSlowLogResponsesArgs) String

func (*THBaseServiceGetSlowLogResponsesArgs) Write

type THBaseServiceGetSlowLogResponsesResult

type THBaseServiceGetSlowLogResponsesResult struct {
	Success []*TOnlineLogRecord `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError           `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetSlowLogResponsesResult

func NewTHBaseServiceGetSlowLogResponsesResult() *THBaseServiceGetSlowLogResponsesResult

func (*THBaseServiceGetSlowLogResponsesResult) GetIo

func (*THBaseServiceGetSlowLogResponsesResult) GetSuccess

func (*THBaseServiceGetSlowLogResponsesResult) IsSetIo

func (*THBaseServiceGetSlowLogResponsesResult) IsSetSuccess

func (p *THBaseServiceGetSlowLogResponsesResult) IsSetSuccess() bool

func (*THBaseServiceGetSlowLogResponsesResult) Read

func (*THBaseServiceGetSlowLogResponsesResult) ReadField0

func (*THBaseServiceGetSlowLogResponsesResult) ReadField1

func (*THBaseServiceGetSlowLogResponsesResult) String

func (*THBaseServiceGetSlowLogResponsesResult) Write

type THBaseServiceGetTableDescriptorArgs

type THBaseServiceGetTableDescriptorArgs struct {
	Table *TTableName `thrift:"table,1,required" db:"table" json:"table"`
}

Attributes:

  • Table: the tablename of the table to get tableDescriptor

func NewTHBaseServiceGetTableDescriptorArgs

func NewTHBaseServiceGetTableDescriptorArgs() *THBaseServiceGetTableDescriptorArgs

func (*THBaseServiceGetTableDescriptorArgs) GetTable

func (*THBaseServiceGetTableDescriptorArgs) IsSetTable

func (p *THBaseServiceGetTableDescriptorArgs) IsSetTable() bool

func (*THBaseServiceGetTableDescriptorArgs) Read

func (*THBaseServiceGetTableDescriptorArgs) ReadField1

func (*THBaseServiceGetTableDescriptorArgs) String

func (*THBaseServiceGetTableDescriptorArgs) Write

type THBaseServiceGetTableDescriptorResult

type THBaseServiceGetTableDescriptorResult struct {
	Success *TTableDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetTableDescriptorResult

func NewTHBaseServiceGetTableDescriptorResult() *THBaseServiceGetTableDescriptorResult

func (*THBaseServiceGetTableDescriptorResult) GetIo

func (*THBaseServiceGetTableDescriptorResult) GetSuccess

func (*THBaseServiceGetTableDescriptorResult) IsSetIo

func (*THBaseServiceGetTableDescriptorResult) IsSetSuccess

func (p *THBaseServiceGetTableDescriptorResult) IsSetSuccess() bool

func (*THBaseServiceGetTableDescriptorResult) Read

func (*THBaseServiceGetTableDescriptorResult) ReadField0

func (*THBaseServiceGetTableDescriptorResult) ReadField1

func (*THBaseServiceGetTableDescriptorResult) String

func (*THBaseServiceGetTableDescriptorResult) Write

type THBaseServiceGetTableDescriptorsArgs

type THBaseServiceGetTableDescriptorsArgs struct {
	Tables []*TTableName `thrift:"tables,1,required" db:"tables" json:"tables"`
}

Attributes:

  • Tables: the tablename list of the tables to get tableDescriptor

func NewTHBaseServiceGetTableDescriptorsArgs

func NewTHBaseServiceGetTableDescriptorsArgs() *THBaseServiceGetTableDescriptorsArgs

func (*THBaseServiceGetTableDescriptorsArgs) GetTables

func (*THBaseServiceGetTableDescriptorsArgs) Read

func (*THBaseServiceGetTableDescriptorsArgs) ReadField1

func (*THBaseServiceGetTableDescriptorsArgs) String

func (*THBaseServiceGetTableDescriptorsArgs) Write

type THBaseServiceGetTableDescriptorsByNamespaceArgs

type THBaseServiceGetTableDescriptorsByNamespaceArgs struct {
	Name string `thrift:"name,1,required" db:"name" json:"name"`
}

Attributes:

  • Name: The namesapce's name

func NewTHBaseServiceGetTableDescriptorsByNamespaceArgs

func NewTHBaseServiceGetTableDescriptorsByNamespaceArgs() *THBaseServiceGetTableDescriptorsByNamespaceArgs

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) GetName

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) Read

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) ReadField1

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) String

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) Write

type THBaseServiceGetTableDescriptorsByNamespaceResult

type THBaseServiceGetTableDescriptorsByNamespaceResult struct {
	Success []*TTableDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError           `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetTableDescriptorsByNamespaceResult

func NewTHBaseServiceGetTableDescriptorsByNamespaceResult() *THBaseServiceGetTableDescriptorsByNamespaceResult

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) GetIo

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) GetSuccess

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) IsSetIo

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) IsSetSuccess

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) Read

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) ReadField0

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) ReadField1

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) String

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) Write

type THBaseServiceGetTableDescriptorsByPatternArgs

type THBaseServiceGetTableDescriptorsByPatternArgs struct {
	Regex            string `thrift:"regex,1" db:"regex" json:"regex"`
	IncludeSysTables bool   `thrift:"includeSysTables,2,required" db:"includeSysTables" json:"includeSysTables"`
}

Attributes:

  • Regex: The regular expression to match against
  • IncludeSysTables: set to false if match only against userspace tables

func NewTHBaseServiceGetTableDescriptorsByPatternArgs

func NewTHBaseServiceGetTableDescriptorsByPatternArgs() *THBaseServiceGetTableDescriptorsByPatternArgs

func (*THBaseServiceGetTableDescriptorsByPatternArgs) GetIncludeSysTables

func (p *THBaseServiceGetTableDescriptorsByPatternArgs) GetIncludeSysTables() bool

func (*THBaseServiceGetTableDescriptorsByPatternArgs) GetRegex

func (*THBaseServiceGetTableDescriptorsByPatternArgs) Read

func (*THBaseServiceGetTableDescriptorsByPatternArgs) ReadField1

func (*THBaseServiceGetTableDescriptorsByPatternArgs) ReadField2

func (*THBaseServiceGetTableDescriptorsByPatternArgs) String

func (*THBaseServiceGetTableDescriptorsByPatternArgs) Write

type THBaseServiceGetTableDescriptorsByPatternResult

type THBaseServiceGetTableDescriptorsByPatternResult struct {
	Success []*TTableDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError           `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetTableDescriptorsByPatternResult

func NewTHBaseServiceGetTableDescriptorsByPatternResult() *THBaseServiceGetTableDescriptorsByPatternResult

func (*THBaseServiceGetTableDescriptorsByPatternResult) GetIo

func (*THBaseServiceGetTableDescriptorsByPatternResult) GetSuccess

func (*THBaseServiceGetTableDescriptorsByPatternResult) IsSetIo

func (*THBaseServiceGetTableDescriptorsByPatternResult) IsSetSuccess

func (*THBaseServiceGetTableDescriptorsByPatternResult) Read

func (*THBaseServiceGetTableDescriptorsByPatternResult) ReadField0

func (*THBaseServiceGetTableDescriptorsByPatternResult) ReadField1

func (*THBaseServiceGetTableDescriptorsByPatternResult) String

func (*THBaseServiceGetTableDescriptorsByPatternResult) Write

type THBaseServiceGetTableDescriptorsResult

type THBaseServiceGetTableDescriptorsResult struct {
	Success []*TTableDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError           `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetTableDescriptorsResult

func NewTHBaseServiceGetTableDescriptorsResult() *THBaseServiceGetTableDescriptorsResult

func (*THBaseServiceGetTableDescriptorsResult) GetIo

func (*THBaseServiceGetTableDescriptorsResult) GetSuccess

func (*THBaseServiceGetTableDescriptorsResult) IsSetIo

func (*THBaseServiceGetTableDescriptorsResult) IsSetSuccess

func (p *THBaseServiceGetTableDescriptorsResult) IsSetSuccess() bool

func (*THBaseServiceGetTableDescriptorsResult) Read

func (*THBaseServiceGetTableDescriptorsResult) ReadField0

func (*THBaseServiceGetTableDescriptorsResult) ReadField1

func (*THBaseServiceGetTableDescriptorsResult) String

func (*THBaseServiceGetTableDescriptorsResult) Write

type THBaseServiceGetTableNamesByNamespaceArgs

type THBaseServiceGetTableNamesByNamespaceArgs struct {
	Name string `thrift:"name,1,required" db:"name" json:"name"`
}

Attributes:

  • Name: The namesapce's name

func NewTHBaseServiceGetTableNamesByNamespaceArgs

func NewTHBaseServiceGetTableNamesByNamespaceArgs() *THBaseServiceGetTableNamesByNamespaceArgs

func (*THBaseServiceGetTableNamesByNamespaceArgs) GetName

func (*THBaseServiceGetTableNamesByNamespaceArgs) Read

func (*THBaseServiceGetTableNamesByNamespaceArgs) ReadField1

func (*THBaseServiceGetTableNamesByNamespaceArgs) String

func (*THBaseServiceGetTableNamesByNamespaceArgs) Write

type THBaseServiceGetTableNamesByNamespaceResult

type THBaseServiceGetTableNamesByNamespaceResult struct {
	Success []*TTableName `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError     `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetTableNamesByNamespaceResult

func NewTHBaseServiceGetTableNamesByNamespaceResult() *THBaseServiceGetTableNamesByNamespaceResult

func (*THBaseServiceGetTableNamesByNamespaceResult) GetIo

func (*THBaseServiceGetTableNamesByNamespaceResult) GetSuccess

func (*THBaseServiceGetTableNamesByNamespaceResult) IsSetIo

func (*THBaseServiceGetTableNamesByNamespaceResult) IsSetSuccess

func (*THBaseServiceGetTableNamesByNamespaceResult) Read

func (*THBaseServiceGetTableNamesByNamespaceResult) ReadField0

func (*THBaseServiceGetTableNamesByNamespaceResult) ReadField1

func (*THBaseServiceGetTableNamesByNamespaceResult) String

func (*THBaseServiceGetTableNamesByNamespaceResult) Write

type THBaseServiceGetTableNamesByPatternArgs

type THBaseServiceGetTableNamesByPatternArgs struct {
	Regex            string `thrift:"regex,1" db:"regex" json:"regex"`
	IncludeSysTables bool   `thrift:"includeSysTables,2,required" db:"includeSysTables" json:"includeSysTables"`
}

Attributes:

  • Regex: The regular expression to match against
  • IncludeSysTables: set to false if match only against userspace tables

func NewTHBaseServiceGetTableNamesByPatternArgs

func NewTHBaseServiceGetTableNamesByPatternArgs() *THBaseServiceGetTableNamesByPatternArgs

func (*THBaseServiceGetTableNamesByPatternArgs) GetIncludeSysTables

func (p *THBaseServiceGetTableNamesByPatternArgs) GetIncludeSysTables() bool

func (*THBaseServiceGetTableNamesByPatternArgs) GetRegex

func (*THBaseServiceGetTableNamesByPatternArgs) Read

func (*THBaseServiceGetTableNamesByPatternArgs) ReadField1

func (*THBaseServiceGetTableNamesByPatternArgs) ReadField2

func (*THBaseServiceGetTableNamesByPatternArgs) String

func (*THBaseServiceGetTableNamesByPatternArgs) Write

type THBaseServiceGetTableNamesByPatternResult

type THBaseServiceGetTableNamesByPatternResult struct {
	Success []*TTableName `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError     `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGetTableNamesByPatternResult

func NewTHBaseServiceGetTableNamesByPatternResult() *THBaseServiceGetTableNamesByPatternResult

func (*THBaseServiceGetTableNamesByPatternResult) GetIo

func (*THBaseServiceGetTableNamesByPatternResult) GetSuccess

func (*THBaseServiceGetTableNamesByPatternResult) IsSetIo

func (*THBaseServiceGetTableNamesByPatternResult) IsSetSuccess

func (*THBaseServiceGetTableNamesByPatternResult) Read

func (*THBaseServiceGetTableNamesByPatternResult) ReadField0

func (*THBaseServiceGetTableNamesByPatternResult) ReadField1

func (*THBaseServiceGetTableNamesByPatternResult) String

func (*THBaseServiceGetTableNamesByPatternResult) Write

type THBaseServiceGetThriftServerTypeArgs

type THBaseServiceGetThriftServerTypeArgs struct {
}

func NewTHBaseServiceGetThriftServerTypeArgs

func NewTHBaseServiceGetThriftServerTypeArgs() *THBaseServiceGetThriftServerTypeArgs

func (*THBaseServiceGetThriftServerTypeArgs) Read

func (*THBaseServiceGetThriftServerTypeArgs) String

func (*THBaseServiceGetThriftServerTypeArgs) Write

type THBaseServiceGetThriftServerTypeResult

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

Attributes:

  • Success

func NewTHBaseServiceGetThriftServerTypeResult

func NewTHBaseServiceGetThriftServerTypeResult() *THBaseServiceGetThriftServerTypeResult

func (*THBaseServiceGetThriftServerTypeResult) GetSuccess

func (*THBaseServiceGetThriftServerTypeResult) IsSetSuccess

func (p *THBaseServiceGetThriftServerTypeResult) IsSetSuccess() bool

func (*THBaseServiceGetThriftServerTypeResult) Read

func (*THBaseServiceGetThriftServerTypeResult) ReadField0

func (*THBaseServiceGetThriftServerTypeResult) String

func (*THBaseServiceGetThriftServerTypeResult) Write

type THBaseServiceGrantArgs

type THBaseServiceGrantArgs struct {
	Info *TAccessControlEntity `thrift:"info,1,required" db:"info" json:"info"`
}

Attributes:

  • Info

func NewTHBaseServiceGrantArgs

func NewTHBaseServiceGrantArgs() *THBaseServiceGrantArgs

func (*THBaseServiceGrantArgs) GetInfo

func (*THBaseServiceGrantArgs) IsSetInfo

func (p *THBaseServiceGrantArgs) IsSetInfo() bool

func (*THBaseServiceGrantArgs) Read

func (*THBaseServiceGrantArgs) ReadField1

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

func (*THBaseServiceGrantArgs) String

func (p *THBaseServiceGrantArgs) String() string

func (*THBaseServiceGrantArgs) Write

type THBaseServiceGrantResult

type THBaseServiceGrantResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceGrantResult

func NewTHBaseServiceGrantResult() *THBaseServiceGrantResult

func (*THBaseServiceGrantResult) GetIo

func (p *THBaseServiceGrantResult) GetIo() *TIOError

func (*THBaseServiceGrantResult) GetSuccess

func (p *THBaseServiceGrantResult) GetSuccess() bool

func (*THBaseServiceGrantResult) IsSetIo

func (p *THBaseServiceGrantResult) IsSetIo() bool

func (*THBaseServiceGrantResult) IsSetSuccess

func (p *THBaseServiceGrantResult) IsSetSuccess() bool

func (*THBaseServiceGrantResult) Read

func (*THBaseServiceGrantResult) ReadField0

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

func (*THBaseServiceGrantResult) ReadField1

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

func (*THBaseServiceGrantResult) String

func (p *THBaseServiceGrantResult) String() string

func (*THBaseServiceGrantResult) Write

type THBaseServiceIncrementArgs

type THBaseServiceIncrementArgs struct {
	Table      []byte      `thrift:"table,1,required" db:"table" json:"table"`
	Tincrement *TIncrement `thrift:"tincrement,2,required" db:"tincrement" json:"tincrement"`
}

Attributes:

  • Table: the table to increment the value on
  • Tincrement: the TIncrement to increment

func NewTHBaseServiceIncrementArgs

func NewTHBaseServiceIncrementArgs() *THBaseServiceIncrementArgs

func (*THBaseServiceIncrementArgs) GetTable

func (p *THBaseServiceIncrementArgs) GetTable() []byte

func (*THBaseServiceIncrementArgs) GetTincrement

func (p *THBaseServiceIncrementArgs) GetTincrement() *TIncrement

func (*THBaseServiceIncrementArgs) IsSetTincrement

func (p *THBaseServiceIncrementArgs) IsSetTincrement() bool

func (*THBaseServiceIncrementArgs) Read

func (*THBaseServiceIncrementArgs) ReadField1

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

func (*THBaseServiceIncrementArgs) ReadField2

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

func (*THBaseServiceIncrementArgs) String

func (p *THBaseServiceIncrementArgs) String() string

func (*THBaseServiceIncrementArgs) Write

type THBaseServiceIncrementResult

type THBaseServiceIncrementResult struct {
	Success *TResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceIncrementResult

func NewTHBaseServiceIncrementResult() *THBaseServiceIncrementResult

func (*THBaseServiceIncrementResult) GetIo

func (*THBaseServiceIncrementResult) GetSuccess

func (p *THBaseServiceIncrementResult) GetSuccess() *TResult_

func (*THBaseServiceIncrementResult) IsSetIo

func (p *THBaseServiceIncrementResult) IsSetIo() bool

func (*THBaseServiceIncrementResult) IsSetSuccess

func (p *THBaseServiceIncrementResult) IsSetSuccess() bool

func (*THBaseServiceIncrementResult) Read

func (*THBaseServiceIncrementResult) ReadField0

func (*THBaseServiceIncrementResult) ReadField1

func (*THBaseServiceIncrementResult) String

func (*THBaseServiceIncrementResult) Write

type THBaseServiceIsTableAvailableArgs

type THBaseServiceIsTableAvailableArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename to check

func NewTHBaseServiceIsTableAvailableArgs

func NewTHBaseServiceIsTableAvailableArgs() *THBaseServiceIsTableAvailableArgs

func (*THBaseServiceIsTableAvailableArgs) GetTableName

func (p *THBaseServiceIsTableAvailableArgs) GetTableName() *TTableName

func (*THBaseServiceIsTableAvailableArgs) IsSetTableName

func (p *THBaseServiceIsTableAvailableArgs) IsSetTableName() bool

func (*THBaseServiceIsTableAvailableArgs) Read

func (*THBaseServiceIsTableAvailableArgs) ReadField1

func (*THBaseServiceIsTableAvailableArgs) String

func (*THBaseServiceIsTableAvailableArgs) Write

type THBaseServiceIsTableAvailableResult

type THBaseServiceIsTableAvailableResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceIsTableAvailableResult

func NewTHBaseServiceIsTableAvailableResult() *THBaseServiceIsTableAvailableResult

func (*THBaseServiceIsTableAvailableResult) GetIo

func (*THBaseServiceIsTableAvailableResult) GetSuccess

func (p *THBaseServiceIsTableAvailableResult) GetSuccess() bool

func (*THBaseServiceIsTableAvailableResult) IsSetIo

func (*THBaseServiceIsTableAvailableResult) IsSetSuccess

func (p *THBaseServiceIsTableAvailableResult) IsSetSuccess() bool

func (*THBaseServiceIsTableAvailableResult) Read

func (*THBaseServiceIsTableAvailableResult) ReadField0

func (*THBaseServiceIsTableAvailableResult) ReadField1

func (*THBaseServiceIsTableAvailableResult) String

func (*THBaseServiceIsTableAvailableResult) Write

type THBaseServiceIsTableAvailableWithSplitArgs

type THBaseServiceIsTableAvailableWithSplitArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
	SplitKeys [][]byte    `thrift:"splitKeys,2" db:"splitKeys" json:"splitKeys"`
}

Attributes:

  • TableName: the tablename to check
  • SplitKeys: keys to check if the table has been created with all split keys

func NewTHBaseServiceIsTableAvailableWithSplitArgs

func NewTHBaseServiceIsTableAvailableWithSplitArgs() *THBaseServiceIsTableAvailableWithSplitArgs

func (*THBaseServiceIsTableAvailableWithSplitArgs) GetSplitKeys

func (p *THBaseServiceIsTableAvailableWithSplitArgs) GetSplitKeys() [][]byte

func (*THBaseServiceIsTableAvailableWithSplitArgs) GetTableName

func (*THBaseServiceIsTableAvailableWithSplitArgs) IsSetTableName

func (*THBaseServiceIsTableAvailableWithSplitArgs) Read

func (*THBaseServiceIsTableAvailableWithSplitArgs) ReadField1

func (*THBaseServiceIsTableAvailableWithSplitArgs) ReadField2

func (*THBaseServiceIsTableAvailableWithSplitArgs) String

func (*THBaseServiceIsTableAvailableWithSplitArgs) Write

type THBaseServiceIsTableAvailableWithSplitResult

type THBaseServiceIsTableAvailableWithSplitResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceIsTableAvailableWithSplitResult

func NewTHBaseServiceIsTableAvailableWithSplitResult() *THBaseServiceIsTableAvailableWithSplitResult

func (*THBaseServiceIsTableAvailableWithSplitResult) GetIo

func (*THBaseServiceIsTableAvailableWithSplitResult) GetSuccess

func (*THBaseServiceIsTableAvailableWithSplitResult) IsSetIo

func (*THBaseServiceIsTableAvailableWithSplitResult) IsSetSuccess

func (*THBaseServiceIsTableAvailableWithSplitResult) Read

func (*THBaseServiceIsTableAvailableWithSplitResult) ReadField0

func (*THBaseServiceIsTableAvailableWithSplitResult) ReadField1

func (*THBaseServiceIsTableAvailableWithSplitResult) String

func (*THBaseServiceIsTableAvailableWithSplitResult) Write

type THBaseServiceIsTableDisabledArgs

type THBaseServiceIsTableDisabledArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename to check

func NewTHBaseServiceIsTableDisabledArgs

func NewTHBaseServiceIsTableDisabledArgs() *THBaseServiceIsTableDisabledArgs

func (*THBaseServiceIsTableDisabledArgs) GetTableName

func (p *THBaseServiceIsTableDisabledArgs) GetTableName() *TTableName

func (*THBaseServiceIsTableDisabledArgs) IsSetTableName

func (p *THBaseServiceIsTableDisabledArgs) IsSetTableName() bool

func (*THBaseServiceIsTableDisabledArgs) Read

func (*THBaseServiceIsTableDisabledArgs) ReadField1

func (*THBaseServiceIsTableDisabledArgs) String

func (*THBaseServiceIsTableDisabledArgs) Write

type THBaseServiceIsTableDisabledResult

type THBaseServiceIsTableDisabledResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceIsTableDisabledResult

func NewTHBaseServiceIsTableDisabledResult() *THBaseServiceIsTableDisabledResult

func (*THBaseServiceIsTableDisabledResult) GetIo

func (*THBaseServiceIsTableDisabledResult) GetSuccess

func (p *THBaseServiceIsTableDisabledResult) GetSuccess() bool

func (*THBaseServiceIsTableDisabledResult) IsSetIo

func (*THBaseServiceIsTableDisabledResult) IsSetSuccess

func (p *THBaseServiceIsTableDisabledResult) IsSetSuccess() bool

func (*THBaseServiceIsTableDisabledResult) Read

func (*THBaseServiceIsTableDisabledResult) ReadField0

func (*THBaseServiceIsTableDisabledResult) ReadField1

func (*THBaseServiceIsTableDisabledResult) String

func (*THBaseServiceIsTableDisabledResult) Write

type THBaseServiceIsTableEnabledArgs

type THBaseServiceIsTableEnabledArgs struct {
	TableName *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename to check

func NewTHBaseServiceIsTableEnabledArgs

func NewTHBaseServiceIsTableEnabledArgs() *THBaseServiceIsTableEnabledArgs

func (*THBaseServiceIsTableEnabledArgs) GetTableName

func (p *THBaseServiceIsTableEnabledArgs) GetTableName() *TTableName

func (*THBaseServiceIsTableEnabledArgs) IsSetTableName

func (p *THBaseServiceIsTableEnabledArgs) IsSetTableName() bool

func (*THBaseServiceIsTableEnabledArgs) Read

func (*THBaseServiceIsTableEnabledArgs) ReadField1

func (*THBaseServiceIsTableEnabledArgs) String

func (*THBaseServiceIsTableEnabledArgs) Write

type THBaseServiceIsTableEnabledResult

type THBaseServiceIsTableEnabledResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceIsTableEnabledResult

func NewTHBaseServiceIsTableEnabledResult() *THBaseServiceIsTableEnabledResult

func (*THBaseServiceIsTableEnabledResult) GetIo

func (*THBaseServiceIsTableEnabledResult) GetSuccess

func (p *THBaseServiceIsTableEnabledResult) GetSuccess() bool

func (*THBaseServiceIsTableEnabledResult) IsSetIo

func (*THBaseServiceIsTableEnabledResult) IsSetSuccess

func (p *THBaseServiceIsTableEnabledResult) IsSetSuccess() bool

func (*THBaseServiceIsTableEnabledResult) Read

func (*THBaseServiceIsTableEnabledResult) ReadField0

func (*THBaseServiceIsTableEnabledResult) ReadField1

func (*THBaseServiceIsTableEnabledResult) String

func (*THBaseServiceIsTableEnabledResult) Write

type THBaseServiceListNamespaceDescriptorsArgs

type THBaseServiceListNamespaceDescriptorsArgs struct {
}

func NewTHBaseServiceListNamespaceDescriptorsArgs

func NewTHBaseServiceListNamespaceDescriptorsArgs() *THBaseServiceListNamespaceDescriptorsArgs

func (*THBaseServiceListNamespaceDescriptorsArgs) Read

func (*THBaseServiceListNamespaceDescriptorsArgs) String

func (*THBaseServiceListNamespaceDescriptorsArgs) Write

type THBaseServiceListNamespaceDescriptorsResult

type THBaseServiceListNamespaceDescriptorsResult struct {
	Success []*TNamespaceDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError               `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceListNamespaceDescriptorsResult

func NewTHBaseServiceListNamespaceDescriptorsResult() *THBaseServiceListNamespaceDescriptorsResult

func (*THBaseServiceListNamespaceDescriptorsResult) GetIo

func (*THBaseServiceListNamespaceDescriptorsResult) GetSuccess

func (*THBaseServiceListNamespaceDescriptorsResult) IsSetIo

func (*THBaseServiceListNamespaceDescriptorsResult) IsSetSuccess

func (*THBaseServiceListNamespaceDescriptorsResult) Read

func (*THBaseServiceListNamespaceDescriptorsResult) ReadField0

func (*THBaseServiceListNamespaceDescriptorsResult) ReadField1

func (*THBaseServiceListNamespaceDescriptorsResult) String

func (*THBaseServiceListNamespaceDescriptorsResult) Write

type THBaseServiceListNamespacesArgs

type THBaseServiceListNamespacesArgs struct {
}

func NewTHBaseServiceListNamespacesArgs

func NewTHBaseServiceListNamespacesArgs() *THBaseServiceListNamespacesArgs

func (*THBaseServiceListNamespacesArgs) Read

func (*THBaseServiceListNamespacesArgs) String

func (*THBaseServiceListNamespacesArgs) Write

type THBaseServiceListNamespacesResult

type THBaseServiceListNamespacesResult struct {
	Success []string  `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceListNamespacesResult

func NewTHBaseServiceListNamespacesResult() *THBaseServiceListNamespacesResult

func (*THBaseServiceListNamespacesResult) GetIo

func (*THBaseServiceListNamespacesResult) GetSuccess

func (p *THBaseServiceListNamespacesResult) GetSuccess() []string

func (*THBaseServiceListNamespacesResult) IsSetIo

func (*THBaseServiceListNamespacesResult) IsSetSuccess

func (p *THBaseServiceListNamespacesResult) IsSetSuccess() bool

func (*THBaseServiceListNamespacesResult) Read

func (*THBaseServiceListNamespacesResult) ReadField0

func (*THBaseServiceListNamespacesResult) ReadField1

func (*THBaseServiceListNamespacesResult) String

func (*THBaseServiceListNamespacesResult) Write

type THBaseServiceModifyColumnFamilyArgs

type THBaseServiceModifyColumnFamilyArgs struct {
	TableName *TTableName              `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
	Column    *TColumnFamilyDescriptor `thrift:"column,2,required" db:"column" json:"column"`
}

Attributes:

  • TableName: the tablename to modify column family
  • Column: column family descriptor of column family to be modified

func NewTHBaseServiceModifyColumnFamilyArgs

func NewTHBaseServiceModifyColumnFamilyArgs() *THBaseServiceModifyColumnFamilyArgs

func (*THBaseServiceModifyColumnFamilyArgs) GetColumn

func (*THBaseServiceModifyColumnFamilyArgs) GetTableName

func (*THBaseServiceModifyColumnFamilyArgs) IsSetColumn

func (p *THBaseServiceModifyColumnFamilyArgs) IsSetColumn() bool

func (*THBaseServiceModifyColumnFamilyArgs) IsSetTableName

func (p *THBaseServiceModifyColumnFamilyArgs) IsSetTableName() bool

func (*THBaseServiceModifyColumnFamilyArgs) Read

func (*THBaseServiceModifyColumnFamilyArgs) ReadField1

func (*THBaseServiceModifyColumnFamilyArgs) ReadField2

func (*THBaseServiceModifyColumnFamilyArgs) String

func (*THBaseServiceModifyColumnFamilyArgs) Write

type THBaseServiceModifyColumnFamilyResult

type THBaseServiceModifyColumnFamilyResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceModifyColumnFamilyResult

func NewTHBaseServiceModifyColumnFamilyResult() *THBaseServiceModifyColumnFamilyResult

func (*THBaseServiceModifyColumnFamilyResult) GetIo

func (*THBaseServiceModifyColumnFamilyResult) IsSetIo

func (*THBaseServiceModifyColumnFamilyResult) Read

func (*THBaseServiceModifyColumnFamilyResult) ReadField1

func (*THBaseServiceModifyColumnFamilyResult) String

func (*THBaseServiceModifyColumnFamilyResult) Write

type THBaseServiceModifyNamespaceArgs

type THBaseServiceModifyNamespaceArgs struct {
	NamespaceDesc *TNamespaceDescriptor `thrift:"namespaceDesc,1,required" db:"namespaceDesc" json:"namespaceDesc"`
}

Attributes:

  • NamespaceDesc: descriptor which describes the new namespace

func NewTHBaseServiceModifyNamespaceArgs

func NewTHBaseServiceModifyNamespaceArgs() *THBaseServiceModifyNamespaceArgs

func (*THBaseServiceModifyNamespaceArgs) GetNamespaceDesc

func (*THBaseServiceModifyNamespaceArgs) IsSetNamespaceDesc

func (p *THBaseServiceModifyNamespaceArgs) IsSetNamespaceDesc() bool

func (*THBaseServiceModifyNamespaceArgs) Read

func (*THBaseServiceModifyNamespaceArgs) ReadField1

func (*THBaseServiceModifyNamespaceArgs) String

func (*THBaseServiceModifyNamespaceArgs) Write

type THBaseServiceModifyNamespaceResult

type THBaseServiceModifyNamespaceResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceModifyNamespaceResult

func NewTHBaseServiceModifyNamespaceResult() *THBaseServiceModifyNamespaceResult

func (*THBaseServiceModifyNamespaceResult) GetIo

func (*THBaseServiceModifyNamespaceResult) IsSetIo

func (*THBaseServiceModifyNamespaceResult) Read

func (*THBaseServiceModifyNamespaceResult) ReadField1

func (*THBaseServiceModifyNamespaceResult) String

func (*THBaseServiceModifyNamespaceResult) Write

type THBaseServiceModifyTableArgs

type THBaseServiceModifyTableArgs struct {
	Desc *TTableDescriptor `thrift:"desc,1,required" db:"desc" json:"desc"`
}

Attributes:

  • Desc: the descriptor of the table to modify

func NewTHBaseServiceModifyTableArgs

func NewTHBaseServiceModifyTableArgs() *THBaseServiceModifyTableArgs

func (*THBaseServiceModifyTableArgs) GetDesc

func (*THBaseServiceModifyTableArgs) IsSetDesc

func (p *THBaseServiceModifyTableArgs) IsSetDesc() bool

func (*THBaseServiceModifyTableArgs) Read

func (*THBaseServiceModifyTableArgs) ReadField1

func (*THBaseServiceModifyTableArgs) String

func (*THBaseServiceModifyTableArgs) Write

type THBaseServiceModifyTableResult

type THBaseServiceModifyTableResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceModifyTableResult

func NewTHBaseServiceModifyTableResult() *THBaseServiceModifyTableResult

func (*THBaseServiceModifyTableResult) GetIo

func (*THBaseServiceModifyTableResult) IsSetIo

func (p *THBaseServiceModifyTableResult) IsSetIo() bool

func (*THBaseServiceModifyTableResult) Read

func (*THBaseServiceModifyTableResult) ReadField1

func (*THBaseServiceModifyTableResult) String

func (*THBaseServiceModifyTableResult) Write

type THBaseServiceMutateRowArgs

type THBaseServiceMutateRowArgs struct {
	Table         []byte         `thrift:"table,1,required" db:"table" json:"table"`
	TrowMutations *TRowMutations `thrift:"trowMutations,2,required" db:"trowMutations" json:"trowMutations"`
}

Attributes:

  • Table: table to apply the mutations
  • TrowMutations: mutations to apply

func NewTHBaseServiceMutateRowArgs

func NewTHBaseServiceMutateRowArgs() *THBaseServiceMutateRowArgs

func (*THBaseServiceMutateRowArgs) GetTable

func (p *THBaseServiceMutateRowArgs) GetTable() []byte

func (*THBaseServiceMutateRowArgs) GetTrowMutations

func (p *THBaseServiceMutateRowArgs) GetTrowMutations() *TRowMutations

func (*THBaseServiceMutateRowArgs) IsSetTrowMutations

func (p *THBaseServiceMutateRowArgs) IsSetTrowMutations() bool

func (*THBaseServiceMutateRowArgs) Read

func (*THBaseServiceMutateRowArgs) ReadField1

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

func (*THBaseServiceMutateRowArgs) ReadField2

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

func (*THBaseServiceMutateRowArgs) String

func (p *THBaseServiceMutateRowArgs) String() string

func (*THBaseServiceMutateRowArgs) Write

type THBaseServiceMutateRowResult

type THBaseServiceMutateRowResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceMutateRowResult

func NewTHBaseServiceMutateRowResult() *THBaseServiceMutateRowResult

func (*THBaseServiceMutateRowResult) GetIo

func (*THBaseServiceMutateRowResult) IsSetIo

func (p *THBaseServiceMutateRowResult) IsSetIo() bool

func (*THBaseServiceMutateRowResult) Read

func (*THBaseServiceMutateRowResult) ReadField1

func (*THBaseServiceMutateRowResult) String

func (*THBaseServiceMutateRowResult) Write

type THBaseServiceOpenScannerArgs

type THBaseServiceOpenScannerArgs struct {
	Table []byte `thrift:"table,1,required" db:"table" json:"table"`
	Tscan *TScan `thrift:"tscan,2,required" db:"tscan" json:"tscan"`
}

Attributes:

  • Table: the table to get the Scanner for
  • Tscan: the scan object to get a Scanner for

func NewTHBaseServiceOpenScannerArgs

func NewTHBaseServiceOpenScannerArgs() *THBaseServiceOpenScannerArgs

func (*THBaseServiceOpenScannerArgs) GetTable

func (p *THBaseServiceOpenScannerArgs) GetTable() []byte

func (*THBaseServiceOpenScannerArgs) GetTscan

func (p *THBaseServiceOpenScannerArgs) GetTscan() *TScan

func (*THBaseServiceOpenScannerArgs) IsSetTscan

func (p *THBaseServiceOpenScannerArgs) IsSetTscan() bool

func (*THBaseServiceOpenScannerArgs) Read

func (*THBaseServiceOpenScannerArgs) ReadField1

func (*THBaseServiceOpenScannerArgs) ReadField2

func (*THBaseServiceOpenScannerArgs) String

func (*THBaseServiceOpenScannerArgs) Write

type THBaseServiceOpenScannerResult

type THBaseServiceOpenScannerResult struct {
	Success *int32    `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceOpenScannerResult

func NewTHBaseServiceOpenScannerResult() *THBaseServiceOpenScannerResult

func (*THBaseServiceOpenScannerResult) GetIo

func (*THBaseServiceOpenScannerResult) GetSuccess

func (p *THBaseServiceOpenScannerResult) GetSuccess() int32

func (*THBaseServiceOpenScannerResult) IsSetIo

func (p *THBaseServiceOpenScannerResult) IsSetIo() bool

func (*THBaseServiceOpenScannerResult) IsSetSuccess

func (p *THBaseServiceOpenScannerResult) IsSetSuccess() bool

func (*THBaseServiceOpenScannerResult) Read

func (*THBaseServiceOpenScannerResult) ReadField0

func (*THBaseServiceOpenScannerResult) ReadField1

func (*THBaseServiceOpenScannerResult) String

func (*THBaseServiceOpenScannerResult) Write

type THBaseServiceProcessor

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

func NewTHBaseServiceProcessor

func NewTHBaseServiceProcessor(handler THBaseService) *THBaseServiceProcessor

func (*THBaseServiceProcessor) AddToProcessorMap

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

func (*THBaseServiceProcessor) GetProcessorFunction

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

func (*THBaseServiceProcessor) Process

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

func (*THBaseServiceProcessor) ProcessorMap

type THBaseServicePutArgs

type THBaseServicePutArgs struct {
	Table []byte `thrift:"table,1,required" db:"table" json:"table"`
	Tput  *TPut  `thrift:"tput,2,required" db:"tput" json:"tput"`
}

Attributes:

  • Table: the table to put data in
  • Tput: the TPut to put

func NewTHBaseServicePutArgs

func NewTHBaseServicePutArgs() *THBaseServicePutArgs

func (*THBaseServicePutArgs) GetTable

func (p *THBaseServicePutArgs) GetTable() []byte

func (*THBaseServicePutArgs) GetTput

func (p *THBaseServicePutArgs) GetTput() *TPut

func (*THBaseServicePutArgs) IsSetTput

func (p *THBaseServicePutArgs) IsSetTput() bool

func (*THBaseServicePutArgs) Read

func (*THBaseServicePutArgs) ReadField1

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

func (*THBaseServicePutArgs) ReadField2

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

func (*THBaseServicePutArgs) String

func (p *THBaseServicePutArgs) String() string

func (*THBaseServicePutArgs) Write

type THBaseServicePutMultipleArgs

type THBaseServicePutMultipleArgs struct {
	Table []byte  `thrift:"table,1,required" db:"table" json:"table"`
	Tputs []*TPut `thrift:"tputs,2,required" db:"tputs" json:"tputs"`
}

Attributes:

  • Table: the table to put data in
  • Tputs: a list of TPuts to commit

func NewTHBaseServicePutMultipleArgs

func NewTHBaseServicePutMultipleArgs() *THBaseServicePutMultipleArgs

func (*THBaseServicePutMultipleArgs) GetTable

func (p *THBaseServicePutMultipleArgs) GetTable() []byte

func (*THBaseServicePutMultipleArgs) GetTputs

func (p *THBaseServicePutMultipleArgs) GetTputs() []*TPut

func (*THBaseServicePutMultipleArgs) Read

func (*THBaseServicePutMultipleArgs) ReadField1

func (*THBaseServicePutMultipleArgs) ReadField2

func (*THBaseServicePutMultipleArgs) String

func (*THBaseServicePutMultipleArgs) Write

type THBaseServicePutMultipleResult

type THBaseServicePutMultipleResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServicePutMultipleResult

func NewTHBaseServicePutMultipleResult() *THBaseServicePutMultipleResult

func (*THBaseServicePutMultipleResult) GetIo

func (*THBaseServicePutMultipleResult) IsSetIo

func (p *THBaseServicePutMultipleResult) IsSetIo() bool

func (*THBaseServicePutMultipleResult) Read

func (*THBaseServicePutMultipleResult) ReadField1

func (*THBaseServicePutMultipleResult) String

func (*THBaseServicePutMultipleResult) Write

type THBaseServicePutResult

type THBaseServicePutResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServicePutResult

func NewTHBaseServicePutResult() *THBaseServicePutResult

func (*THBaseServicePutResult) GetIo

func (p *THBaseServicePutResult) GetIo() *TIOError

func (*THBaseServicePutResult) IsSetIo

func (p *THBaseServicePutResult) IsSetIo() bool

func (*THBaseServicePutResult) Read

func (*THBaseServicePutResult) ReadField1

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

func (*THBaseServicePutResult) String

func (p *THBaseServicePutResult) String() string

func (*THBaseServicePutResult) Write

type THBaseServiceRevokeArgs

type THBaseServiceRevokeArgs struct {
	Info *TAccessControlEntity `thrift:"info,1,required" db:"info" json:"info"`
}

Attributes:

  • Info

func NewTHBaseServiceRevokeArgs

func NewTHBaseServiceRevokeArgs() *THBaseServiceRevokeArgs

func (*THBaseServiceRevokeArgs) GetInfo

func (*THBaseServiceRevokeArgs) IsSetInfo

func (p *THBaseServiceRevokeArgs) IsSetInfo() bool

func (*THBaseServiceRevokeArgs) Read

func (*THBaseServiceRevokeArgs) ReadField1

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

func (*THBaseServiceRevokeArgs) String

func (p *THBaseServiceRevokeArgs) String() string

func (*THBaseServiceRevokeArgs) Write

type THBaseServiceRevokeResult

type THBaseServiceRevokeResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceRevokeResult

func NewTHBaseServiceRevokeResult() *THBaseServiceRevokeResult

func (*THBaseServiceRevokeResult) GetIo

func (p *THBaseServiceRevokeResult) GetIo() *TIOError

func (*THBaseServiceRevokeResult) GetSuccess

func (p *THBaseServiceRevokeResult) GetSuccess() bool

func (*THBaseServiceRevokeResult) IsSetIo

func (p *THBaseServiceRevokeResult) IsSetIo() bool

func (*THBaseServiceRevokeResult) IsSetSuccess

func (p *THBaseServiceRevokeResult) IsSetSuccess() bool

func (*THBaseServiceRevokeResult) Read

func (*THBaseServiceRevokeResult) ReadField0

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

func (*THBaseServiceRevokeResult) ReadField1

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

func (*THBaseServiceRevokeResult) String

func (p *THBaseServiceRevokeResult) String() string

func (*THBaseServiceRevokeResult) Write

type THBaseServiceTableExistsArgs

type THBaseServiceTableExistsArgs struct {
	TableName *TTableName `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: the tablename of the tables to check

func NewTHBaseServiceTableExistsArgs

func NewTHBaseServiceTableExistsArgs() *THBaseServiceTableExistsArgs

func (*THBaseServiceTableExistsArgs) GetTableName

func (p *THBaseServiceTableExistsArgs) GetTableName() *TTableName

func (*THBaseServiceTableExistsArgs) IsSetTableName

func (p *THBaseServiceTableExistsArgs) IsSetTableName() bool

func (*THBaseServiceTableExistsArgs) Read

func (*THBaseServiceTableExistsArgs) ReadField1

func (*THBaseServiceTableExistsArgs) String

func (*THBaseServiceTableExistsArgs) Write

type THBaseServiceTableExistsResult

type THBaseServiceTableExistsResult struct {
	Success *bool     `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewTHBaseServiceTableExistsResult

func NewTHBaseServiceTableExistsResult() *THBaseServiceTableExistsResult

func (*THBaseServiceTableExistsResult) GetIo

func (*THBaseServiceTableExistsResult) GetSuccess

func (p *THBaseServiceTableExistsResult) GetSuccess() bool

func (*THBaseServiceTableExistsResult) IsSetIo

func (p *THBaseServiceTableExistsResult) IsSetIo() bool

func (*THBaseServiceTableExistsResult) IsSetSuccess

func (p *THBaseServiceTableExistsResult) IsSetSuccess() bool

func (*THBaseServiceTableExistsResult) Read

func (*THBaseServiceTableExistsResult) ReadField0

func (*THBaseServiceTableExistsResult) ReadField1

func (*THBaseServiceTableExistsResult) String

func (*THBaseServiceTableExistsResult) Write

type THBaseServiceTruncateTableArgs

type THBaseServiceTruncateTableArgs struct {
	TableName      *TTableName `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
	PreserveSplits bool        `thrift:"preserveSplits,2,required" db:"preserveSplits" json:"preserveSplits"`
}

Attributes:

  • TableName: the tablename to truncate
  • PreserveSplits: whether to preserve previous splits

func NewTHBaseServiceTruncateTableArgs

func NewTHBaseServiceTruncateTableArgs() *THBaseServiceTruncateTableArgs

func (*THBaseServiceTruncateTableArgs) GetPreserveSplits

func (p *THBaseServiceTruncateTableArgs) GetPreserveSplits() bool

func (*THBaseServiceTruncateTableArgs) GetTableName

func (p *THBaseServiceTruncateTableArgs) GetTableName() *TTableName

func (*THBaseServiceTruncateTableArgs) IsSetTableName

func (p *THBaseServiceTruncateTableArgs) IsSetTableName() bool

func (*THBaseServiceTruncateTableArgs) Read

func (*THBaseServiceTruncateTableArgs) ReadField1

func (*THBaseServiceTruncateTableArgs) ReadField2

func (*THBaseServiceTruncateTableArgs) String

func (*THBaseServiceTruncateTableArgs) Write

type THBaseServiceTruncateTableResult

type THBaseServiceTruncateTableResult struct {
	Io *TIOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Io

func NewTHBaseServiceTruncateTableResult

func NewTHBaseServiceTruncateTableResult() *THBaseServiceTruncateTableResult

func (*THBaseServiceTruncateTableResult) GetIo

func (*THBaseServiceTruncateTableResult) IsSetIo

func (*THBaseServiceTruncateTableResult) Read

func (*THBaseServiceTruncateTableResult) ReadField1

func (*THBaseServiceTruncateTableResult) String

func (*THBaseServiceTruncateTableResult) Write

type THRegionInfo

type THRegionInfo struct {
	RegionId  int64  `thrift:"regionId,1,required" db:"regionId" json:"regionId"`
	TableName []byte `thrift:"tableName,2,required" db:"tableName" json:"tableName"`
	StartKey  []byte `thrift:"startKey,3" db:"startKey" json:"startKey,omitempty"`
	EndKey    []byte `thrift:"endKey,4" db:"endKey" json:"endKey,omitempty"`
	Offline   *bool  `thrift:"offline,5" db:"offline" json:"offline,omitempty"`
	Split     *bool  `thrift:"split,6" db:"split" json:"split,omitempty"`
	ReplicaId *int32 `thrift:"replicaId,7" db:"replicaId" json:"replicaId,omitempty"`
}

Attributes:

  • RegionId
  • TableName
  • StartKey
  • EndKey
  • Offline
  • Split
  • ReplicaId
var THRegionLocation_RegionInfo_DEFAULT *THRegionInfo

func NewTHRegionInfo

func NewTHRegionInfo() *THRegionInfo

func (*THRegionInfo) Equals

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

func (*THRegionInfo) GetEndKey

func (p *THRegionInfo) GetEndKey() []byte

func (*THRegionInfo) GetOffline

func (p *THRegionInfo) GetOffline() bool

func (*THRegionInfo) GetRegionId

func (p *THRegionInfo) GetRegionId() int64

func (*THRegionInfo) GetReplicaId

func (p *THRegionInfo) GetReplicaId() int32

func (*THRegionInfo) GetSplit

func (p *THRegionInfo) GetSplit() bool

func (*THRegionInfo) GetStartKey

func (p *THRegionInfo) GetStartKey() []byte

func (*THRegionInfo) GetTableName

func (p *THRegionInfo) GetTableName() []byte

func (*THRegionInfo) IsSetEndKey

func (p *THRegionInfo) IsSetEndKey() bool

func (*THRegionInfo) IsSetOffline

func (p *THRegionInfo) IsSetOffline() bool

func (*THRegionInfo) IsSetReplicaId

func (p *THRegionInfo) IsSetReplicaId() bool

func (*THRegionInfo) IsSetSplit

func (p *THRegionInfo) IsSetSplit() bool

func (*THRegionInfo) IsSetStartKey

func (p *THRegionInfo) IsSetStartKey() bool

func (*THRegionInfo) Read

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

func (*THRegionInfo) ReadField1

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

func (*THRegionInfo) ReadField2

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

func (*THRegionInfo) ReadField3

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

func (*THRegionInfo) ReadField4

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

func (*THRegionInfo) ReadField5

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

func (*THRegionInfo) ReadField6

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

func (*THRegionInfo) ReadField7

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

func (*THRegionInfo) String

func (p *THRegionInfo) String() string

func (*THRegionInfo) Write

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

type THRegionLocation

type THRegionLocation struct {
	ServerName *TServerName  `thrift:"serverName,1,required" db:"serverName" json:"serverName"`
	RegionInfo *THRegionInfo `thrift:"regionInfo,2,required" db:"regionInfo" json:"regionInfo"`
}

Attributes:

  • ServerName
  • RegionInfo
var THBaseServiceGetRegionLocationResult_Success_DEFAULT *THRegionLocation

func NewTHRegionLocation

func NewTHRegionLocation() *THRegionLocation

func (*THRegionLocation) Equals

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

func (*THRegionLocation) GetRegionInfo

func (p *THRegionLocation) GetRegionInfo() *THRegionInfo

func (*THRegionLocation) GetServerName

func (p *THRegionLocation) GetServerName() *TServerName

func (*THRegionLocation) IsSetRegionInfo

func (p *THRegionLocation) IsSetRegionInfo() bool

func (*THRegionLocation) IsSetServerName

func (p *THRegionLocation) IsSetServerName() bool

func (*THRegionLocation) Read

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

func (*THRegionLocation) ReadField1

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

func (*THRegionLocation) ReadField2

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

func (*THRegionLocation) String

func (p *THRegionLocation) String() string

func (*THRegionLocation) Write

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

type TIOError

type TIOError struct {
	Message  *string `thrift:"message,1" db:"message" json:"message,omitempty"`
	CanRetry *bool   `thrift:"canRetry,2" db:"canRetry" json:"canRetry,omitempty"`
}

A TIOError exception signals that an error occurred communicating to the HBase master or a HBase region server. Also used to return more general HBase error conditions.

Attributes:

  • Message
  • CanRetry
var THBaseServiceAddColumnFamilyResult_Io_DEFAULT *TIOError
var THBaseServiceAppendResult_Io_DEFAULT *TIOError
var THBaseServiceCheckAndDeleteResult_Io_DEFAULT *TIOError
var THBaseServiceCheckAndMutateResult_Io_DEFAULT *TIOError
var THBaseServiceCheckAndPutResult_Io_DEFAULT *TIOError
var THBaseServiceClearSlowLogResponsesResult_Io_DEFAULT *TIOError
var THBaseServiceCloseScannerResult_Io_DEFAULT *TIOError
var THBaseServiceCreateNamespaceResult_Io_DEFAULT *TIOError
var THBaseServiceCreateTableResult_Io_DEFAULT *TIOError
var THBaseServiceDeleteColumnFamilyResult_Io_DEFAULT *TIOError
var THBaseServiceDeleteMultipleResult_Io_DEFAULT *TIOError
var THBaseServiceDeleteNamespaceResult_Io_DEFAULT *TIOError
var THBaseServiceDeleteSingleResult_Io_DEFAULT *TIOError
var THBaseServiceDeleteTableResult_Io_DEFAULT *TIOError
var THBaseServiceDisableTableResult_Io_DEFAULT *TIOError
var THBaseServiceEnableTableResult_Io_DEFAULT *TIOError
var THBaseServiceExistsAllResult_Io_DEFAULT *TIOError
var THBaseServiceExistsResult_Io_DEFAULT *TIOError
var THBaseServiceGetAllRegionLocationsResult_Io_DEFAULT *TIOError
var THBaseServiceGetMultipleResult_Io_DEFAULT *TIOError
var THBaseServiceGetNamespaceDescriptorResult_Io_DEFAULT *TIOError
var THBaseServiceGetRegionLocationResult_Io_DEFAULT *TIOError
var THBaseServiceGetResult_Io_DEFAULT *TIOError
var THBaseServiceGetScannerResultsResult_Io_DEFAULT *TIOError
var THBaseServiceGetScannerRowsResult_Io_DEFAULT *TIOError
var THBaseServiceGetSlowLogResponsesResult_Io_DEFAULT *TIOError
var THBaseServiceGetTableDescriptorResult_Io_DEFAULT *TIOError
var THBaseServiceGetTableDescriptorsByNamespaceResult_Io_DEFAULT *TIOError
var THBaseServiceGetTableDescriptorsByPatternResult_Io_DEFAULT *TIOError
var THBaseServiceGetTableDescriptorsResult_Io_DEFAULT *TIOError
var THBaseServiceGetTableNamesByNamespaceResult_Io_DEFAULT *TIOError
var THBaseServiceGetTableNamesByPatternResult_Io_DEFAULT *TIOError
var THBaseServiceGrantResult_Io_DEFAULT *TIOError
var THBaseServiceIncrementResult_Io_DEFAULT *TIOError
var THBaseServiceIsTableAvailableResult_Io_DEFAULT *TIOError
var THBaseServiceIsTableAvailableWithSplitResult_Io_DEFAULT *TIOError
var THBaseServiceIsTableDisabledResult_Io_DEFAULT *TIOError
var THBaseServiceIsTableEnabledResult_Io_DEFAULT *TIOError
var THBaseServiceListNamespaceDescriptorsResult_Io_DEFAULT *TIOError
var THBaseServiceListNamespacesResult_Io_DEFAULT *TIOError
var THBaseServiceModifyColumnFamilyResult_Io_DEFAULT *TIOError
var THBaseServiceModifyNamespaceResult_Io_DEFAULT *TIOError
var THBaseServiceModifyTableResult_Io_DEFAULT *TIOError
var THBaseServiceMutateRowResult_Io_DEFAULT *TIOError
var THBaseServiceOpenScannerResult_Io_DEFAULT *TIOError
var THBaseServicePutMultipleResult_Io_DEFAULT *TIOError
var THBaseServicePutResult_Io_DEFAULT *TIOError
var THBaseServiceRevokeResult_Io_DEFAULT *TIOError
var THBaseServiceTableExistsResult_Io_DEFAULT *TIOError
var THBaseServiceTruncateTableResult_Io_DEFAULT *TIOError

func NewTIOError

func NewTIOError() *TIOError

func (*TIOError) Equals

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

func (*TIOError) Error

func (p *TIOError) Error() string

func (*TIOError) GetCanRetry

func (p *TIOError) GetCanRetry() bool

func (*TIOError) GetMessage

func (p *TIOError) GetMessage() string

func (*TIOError) IsSetCanRetry

func (p *TIOError) IsSetCanRetry() bool

func (*TIOError) IsSetMessage

func (p *TIOError) IsSetMessage() bool

func (*TIOError) Read

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

func (*TIOError) ReadField1

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

func (*TIOError) ReadField2

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

func (*TIOError) String

func (p *TIOError) String() string

func (TIOError) TExceptionType

func (TIOError) TExceptionType() thrift.TExceptionType

func (*TIOError) Write

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

type TIllegalArgument

type TIllegalArgument struct {
	Message *string `thrift:"message,1" db:"message" json:"message,omitempty"`
}

A TIllegalArgument exception indicates an illegal or invalid argument was passed into a procedure.

Attributes:

  • Message
var THBaseServiceCloseScannerResult_Ia_DEFAULT *TIllegalArgument
var THBaseServiceGetScannerRowsResult_Ia_DEFAULT *TIllegalArgument

func NewTIllegalArgument

func NewTIllegalArgument() *TIllegalArgument

func (*TIllegalArgument) Equals

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

func (*TIllegalArgument) Error

func (p *TIllegalArgument) Error() string

func (*TIllegalArgument) GetMessage

func (p *TIllegalArgument) GetMessage() string

func (*TIllegalArgument) IsSetMessage

func (p *TIllegalArgument) IsSetMessage() bool

func (*TIllegalArgument) Read

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

func (*TIllegalArgument) ReadField1

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

func (*TIllegalArgument) String

func (p *TIllegalArgument) String() string

func (TIllegalArgument) TExceptionType

func (TIllegalArgument) TExceptionType() thrift.TExceptionType

func (*TIllegalArgument) Write

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

type TIncrement

type TIncrement struct {
	Row     []byte              `thrift:"row,1,required" db:"row" json:"row"`
	Columns []*TColumnIncrement `thrift:"columns,2,required" db:"columns" json:"columns"`
	// unused field # 3
	Attributes     map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes,omitempty"`
	Durability     *TDurability      `thrift:"durability,5" db:"durability" json:"durability,omitempty"`
	CellVisibility *TCellVisibility  `thrift:"cellVisibility,6" db:"cellVisibility" json:"cellVisibility,omitempty"`
	ReturnResults  *bool             `thrift:"returnResults,7" db:"returnResults" json:"returnResults,omitempty"`
}

Used to perform Increment operations for a single row.

You can specify how this Increment should be written to the write-ahead Log (WAL) by changing the durability. If you don't provide durability, it defaults to column family's default setting for durability.

Attributes:

  • Row
  • Columns
  • Attributes
  • Durability
  • CellVisibility
  • ReturnResults
var THBaseServiceIncrementArgs_Tincrement_DEFAULT *TIncrement

func NewTIncrement

func NewTIncrement() *TIncrement

func (*TIncrement) Equals

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

func (*TIncrement) GetAttributes

func (p *TIncrement) GetAttributes() map[string][]byte

func (*TIncrement) GetCellVisibility

func (p *TIncrement) GetCellVisibility() *TCellVisibility

func (*TIncrement) GetColumns

func (p *TIncrement) GetColumns() []*TColumnIncrement

func (*TIncrement) GetDurability

func (p *TIncrement) GetDurability() TDurability

func (*TIncrement) GetReturnResults

func (p *TIncrement) GetReturnResults() bool

func (*TIncrement) GetRow

func (p *TIncrement) GetRow() []byte

func (*TIncrement) IsSetAttributes

func (p *TIncrement) IsSetAttributes() bool

func (*TIncrement) IsSetCellVisibility

func (p *TIncrement) IsSetCellVisibility() bool

func (*TIncrement) IsSetDurability

func (p *TIncrement) IsSetDurability() bool

func (*TIncrement) IsSetReturnResults

func (p *TIncrement) IsSetReturnResults() bool

func (*TIncrement) Read

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

func (*TIncrement) ReadField1

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

func (*TIncrement) ReadField2

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

func (*TIncrement) ReadField4

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

func (*TIncrement) ReadField5

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

func (*TIncrement) ReadField6

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

func (*TIncrement) ReadField7

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

func (*TIncrement) String

func (p *TIncrement) String() string

func (*TIncrement) Write

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

type TKeepDeletedCells

type TKeepDeletedCells int64

Thrift wrapper around org.apache.hadoop.hbase.KeepDeletedCells

const (
	TKeepDeletedCells_FALSE TKeepDeletedCells = 0
	TKeepDeletedCells_TRUE  TKeepDeletedCells = 1
	TKeepDeletedCells_TTL   TKeepDeletedCells = 2
)
var TColumnFamilyDescriptor_KeepDeletedCells_DEFAULT TKeepDeletedCells

func TKeepDeletedCellsFromString

func TKeepDeletedCellsFromString(s string) (TKeepDeletedCells, error)

func TKeepDeletedCellsPtr

func TKeepDeletedCellsPtr(v TKeepDeletedCells) *TKeepDeletedCells

func (TKeepDeletedCells) MarshalText

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

func (*TKeepDeletedCells) Scan

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

func (TKeepDeletedCells) String

func (p TKeepDeletedCells) String() string

func (*TKeepDeletedCells) UnmarshalText

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

func (*TKeepDeletedCells) Value

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

type TLogQueryFilter

type TLogQueryFilter struct {
	RegionName       *string           `thrift:"regionName,1" db:"regionName" json:"regionName,omitempty"`
	ClientAddress    *string           `thrift:"clientAddress,2" db:"clientAddress" json:"clientAddress,omitempty"`
	TableName        *string           `thrift:"tableName,3" db:"tableName" json:"tableName,omitempty"`
	UserName         *string           `thrift:"userName,4" db:"userName" json:"userName,omitempty"`
	Limit            int32             `thrift:"limit,5" db:"limit" json:"limit"`
	LogType          TLogType          `thrift:"logType,6" db:"logType" json:"logType"`
	FilterByOperator TFilterByOperator `thrift:"filterByOperator,7" db:"filterByOperator" json:"filterByOperator"`
}

Thrift wrapper around org.apache.hadoop.hbase.client.LogQueryFilter

Attributes:

  • RegionName
  • ClientAddress
  • TableName
  • UserName
  • Limit
  • LogType
  • FilterByOperator
var THBaseServiceGetSlowLogResponsesArgs_LogQueryFilter_DEFAULT *TLogQueryFilter

func NewTLogQueryFilter

func NewTLogQueryFilter() *TLogQueryFilter

func (*TLogQueryFilter) Equals

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

func (*TLogQueryFilter) GetClientAddress

func (p *TLogQueryFilter) GetClientAddress() string

func (*TLogQueryFilter) GetFilterByOperator

func (p *TLogQueryFilter) GetFilterByOperator() TFilterByOperator

func (*TLogQueryFilter) GetLimit

func (p *TLogQueryFilter) GetLimit() int32

func (*TLogQueryFilter) GetLogType

func (p *TLogQueryFilter) GetLogType() TLogType

func (*TLogQueryFilter) GetRegionName

func (p *TLogQueryFilter) GetRegionName() string

func (*TLogQueryFilter) GetTableName

func (p *TLogQueryFilter) GetTableName() string

func (*TLogQueryFilter) GetUserName

func (p *TLogQueryFilter) GetUserName() string

func (*TLogQueryFilter) IsSetClientAddress

func (p *TLogQueryFilter) IsSetClientAddress() bool

func (*TLogQueryFilter) IsSetFilterByOperator

func (p *TLogQueryFilter) IsSetFilterByOperator() bool

func (*TLogQueryFilter) IsSetLimit

func (p *TLogQueryFilter) IsSetLimit() bool

func (*TLogQueryFilter) IsSetLogType

func (p *TLogQueryFilter) IsSetLogType() bool

func (*TLogQueryFilter) IsSetRegionName

func (p *TLogQueryFilter) IsSetRegionName() bool

func (*TLogQueryFilter) IsSetTableName

func (p *TLogQueryFilter) IsSetTableName() bool

func (*TLogQueryFilter) IsSetUserName

func (p *TLogQueryFilter) IsSetUserName() bool

func (*TLogQueryFilter) Read

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

func (*TLogQueryFilter) ReadField1

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

func (*TLogQueryFilter) ReadField2

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

func (*TLogQueryFilter) ReadField3

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

func (*TLogQueryFilter) ReadField4

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

func (*TLogQueryFilter) ReadField5

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

func (*TLogQueryFilter) ReadField6

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

func (*TLogQueryFilter) ReadField7

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

func (*TLogQueryFilter) String

func (p *TLogQueryFilter) String() string

func (*TLogQueryFilter) Write

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

type TLogType

type TLogType int64
const (
	TLogType_SLOW_LOG  TLogType = 1
	TLogType_LARGE_LOG TLogType = 2
)
var TLogQueryFilter_LogType_DEFAULT TLogType = 1

func TLogTypeFromString

func TLogTypeFromString(s string) (TLogType, error)

func TLogTypePtr

func TLogTypePtr(v TLogType) *TLogType

func (TLogType) MarshalText

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

func (*TLogType) Scan

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

func (TLogType) String

func (p TLogType) String() string

func (*TLogType) UnmarshalText

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

func (*TLogType) Value

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

type TMutation

type TMutation struct {
	Put          *TPut    `thrift:"put,1" db:"put" json:"put,omitempty"`
	DeleteSingle *TDelete `thrift:"deleteSingle,2" db:"deleteSingle" json:"deleteSingle,omitempty"`
}

Atomic mutation for the specified row. It can be either Put or Delete.

Attributes:

  • Put
  • DeleteSingle

func NewTMutation

func NewTMutation() *TMutation

func (*TMutation) CountSetFieldsTMutation

func (p *TMutation) CountSetFieldsTMutation() int

func (*TMutation) Equals

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

func (*TMutation) GetDeleteSingle

func (p *TMutation) GetDeleteSingle() *TDelete

func (*TMutation) GetPut

func (p *TMutation) GetPut() *TPut

func (*TMutation) IsSetDeleteSingle

func (p *TMutation) IsSetDeleteSingle() bool

func (*TMutation) IsSetPut

func (p *TMutation) IsSetPut() bool

func (*TMutation) Read

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

func (*TMutation) ReadField1

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

func (*TMutation) ReadField2

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

func (*TMutation) String

func (p *TMutation) String() string

func (*TMutation) Write

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

type TNamespaceDescriptor

type TNamespaceDescriptor struct {
	Name          string            `thrift:"name,1,required" db:"name" json:"name"`
	Configuration map[string]string `thrift:"configuration,2" db:"configuration" json:"configuration,omitempty"`
}

Thrift wrapper around org.apache.hadoop.hbase.NamespaceDescriptor

Attributes:

  • Name
  • Configuration
var THBaseServiceCreateNamespaceArgs_NamespaceDesc_DEFAULT *TNamespaceDescriptor
var THBaseServiceGetNamespaceDescriptorResult_Success_DEFAULT *TNamespaceDescriptor
var THBaseServiceModifyNamespaceArgs_NamespaceDesc_DEFAULT *TNamespaceDescriptor

func NewTNamespaceDescriptor

func NewTNamespaceDescriptor() *TNamespaceDescriptor

func (*TNamespaceDescriptor) Equals

func (*TNamespaceDescriptor) GetConfiguration

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

func (*TNamespaceDescriptor) GetName

func (p *TNamespaceDescriptor) GetName() string

func (*TNamespaceDescriptor) IsSetConfiguration

func (p *TNamespaceDescriptor) IsSetConfiguration() bool

func (*TNamespaceDescriptor) Read

func (*TNamespaceDescriptor) ReadField1

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

func (*TNamespaceDescriptor) ReadField2

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

func (*TNamespaceDescriptor) String

func (p *TNamespaceDescriptor) String() string

func (*TNamespaceDescriptor) Write

type TOnlineLogRecord

type TOnlineLogRecord struct {
	StartTime           int64   `thrift:"startTime,1,required" db:"startTime" json:"startTime"`
	ProcessingTime      int32   `thrift:"processingTime,2,required" db:"processingTime" json:"processingTime"`
	QueueTime           int32   `thrift:"queueTime,3,required" db:"queueTime" json:"queueTime"`
	ResponseSize        int64   `thrift:"responseSize,4,required" db:"responseSize" json:"responseSize"`
	ClientAddress       string  `thrift:"clientAddress,5,required" db:"clientAddress" json:"clientAddress"`
	ServerClass         string  `thrift:"serverClass,6,required" db:"serverClass" json:"serverClass"`
	MethodName          string  `thrift:"methodName,7,required" db:"methodName" json:"methodName"`
	CallDetails         string  `thrift:"callDetails,8,required" db:"callDetails" json:"callDetails"`
	Param               string  `thrift:"param,9,required" db:"param" json:"param"`
	UserName            string  `thrift:"userName,10,required" db:"userName" json:"userName"`
	MultiGetsCount      int32   `thrift:"multiGetsCount,11,required" db:"multiGetsCount" json:"multiGetsCount"`
	MultiMutationsCount int32   `thrift:"multiMutationsCount,12,required" db:"multiMutationsCount" json:"multiMutationsCount"`
	MultiServiceCalls   int32   `thrift:"multiServiceCalls,13,required" db:"multiServiceCalls" json:"multiServiceCalls"`
	RegionName          *string `thrift:"regionName,14" db:"regionName" json:"regionName,omitempty"`
}

Thrift wrapper around org.apache.hadoop.hbase.client.OnlineLogRecordrd

Attributes:

  • StartTime
  • ProcessingTime
  • QueueTime
  • ResponseSize
  • ClientAddress
  • ServerClass
  • MethodName
  • CallDetails
  • Param
  • UserName
  • MultiGetsCount
  • MultiMutationsCount
  • MultiServiceCalls
  • RegionName

func NewTOnlineLogRecord

func NewTOnlineLogRecord() *TOnlineLogRecord

func (*TOnlineLogRecord) Equals

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

func (*TOnlineLogRecord) GetCallDetails

func (p *TOnlineLogRecord) GetCallDetails() string

func (*TOnlineLogRecord) GetClientAddress

func (p *TOnlineLogRecord) GetClientAddress() string

func (*TOnlineLogRecord) GetMethodName

func (p *TOnlineLogRecord) GetMethodName() string

func (*TOnlineLogRecord) GetMultiGetsCount

func (p *TOnlineLogRecord) GetMultiGetsCount() int32

func (*TOnlineLogRecord) GetMultiMutationsCount

func (p *TOnlineLogRecord) GetMultiMutationsCount() int32

func (*TOnlineLogRecord) GetMultiServiceCalls

func (p *TOnlineLogRecord) GetMultiServiceCalls() int32

func (*TOnlineLogRecord) GetParam

func (p *TOnlineLogRecord) GetParam() string

func (*TOnlineLogRecord) GetProcessingTime

func (p *TOnlineLogRecord) GetProcessingTime() int32

func (*TOnlineLogRecord) GetQueueTime

func (p *TOnlineLogRecord) GetQueueTime() int32

func (*TOnlineLogRecord) GetRegionName

func (p *TOnlineLogRecord) GetRegionName() string

func (*TOnlineLogRecord) GetResponseSize

func (p *TOnlineLogRecord) GetResponseSize() int64

func (*TOnlineLogRecord) GetServerClass

func (p *TOnlineLogRecord) GetServerClass() string

func (*TOnlineLogRecord) GetStartTime

func (p *TOnlineLogRecord) GetStartTime() int64

func (*TOnlineLogRecord) GetUserName

func (p *TOnlineLogRecord) GetUserName() string

func (*TOnlineLogRecord) IsSetRegionName

func (p *TOnlineLogRecord) IsSetRegionName() bool

func (*TOnlineLogRecord) Read

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

func (*TOnlineLogRecord) ReadField1

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

func (*TOnlineLogRecord) ReadField10

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

func (*TOnlineLogRecord) ReadField11

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

func (*TOnlineLogRecord) ReadField12

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

func (*TOnlineLogRecord) ReadField13

func (p *TOnlineLogRecord) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*TOnlineLogRecord) ReadField14

func (p *TOnlineLogRecord) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*TOnlineLogRecord) ReadField2

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

func (*TOnlineLogRecord) ReadField3

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

func (*TOnlineLogRecord) ReadField4

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

func (*TOnlineLogRecord) ReadField5

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

func (*TOnlineLogRecord) ReadField6

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

func (*TOnlineLogRecord) ReadField7

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

func (*TOnlineLogRecord) ReadField8

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

func (*TOnlineLogRecord) ReadField9

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

func (*TOnlineLogRecord) String

func (p *TOnlineLogRecord) String() string

func (*TOnlineLogRecord) Write

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

type TPermissionScope

type TPermissionScope int64
const (
	TPermissionScope_TABLE     TPermissionScope = 0
	TPermissionScope_NAMESPACE TPermissionScope = 1
)

func TPermissionScopeFromString

func TPermissionScopeFromString(s string) (TPermissionScope, error)

func TPermissionScopePtr

func TPermissionScopePtr(v TPermissionScope) *TPermissionScope

func (TPermissionScope) MarshalText

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

func (*TPermissionScope) Scan

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

func (TPermissionScope) String

func (p TPermissionScope) String() string

func (*TPermissionScope) UnmarshalText

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

func (*TPermissionScope) Value

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

type TPut

type TPut struct {
	Row          []byte          `thrift:"row,1,required" db:"row" json:"row"`
	ColumnValues []*TColumnValue `thrift:"columnValues,2,required" db:"columnValues" json:"columnValues"`
	Timestamp    *int64          `thrift:"timestamp,3" db:"timestamp" json:"timestamp,omitempty"`
	// unused field # 4
	Attributes     map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes,omitempty"`
	Durability     *TDurability      `thrift:"durability,6" db:"durability" json:"durability,omitempty"`
	CellVisibility *TCellVisibility  `thrift:"cellVisibility,7" db:"cellVisibility" json:"cellVisibility,omitempty"`
}

Used to perform Put operations for a single row.

Add column values to this object and they'll be added. You can provide a default timestamp if the column values don't have one. If you don't provide a default timestamp the current time is inserted.

You can specify how this Put should be written to the write-ahead Log (WAL) by changing the durability. If you don't provide durability, it defaults to column family's default setting for durability.

Attributes:

  • Row
  • ColumnValues
  • Timestamp
  • Attributes
  • Durability
  • CellVisibility
var THBaseServiceCheckAndPutArgs_Tput_DEFAULT *TPut
var THBaseServicePutArgs_Tput_DEFAULT *TPut
var TMutation_Put_DEFAULT *TPut

func NewTPut

func NewTPut() *TPut

func (*TPut) Equals

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

func (*TPut) GetAttributes

func (p *TPut) GetAttributes() map[string][]byte

func (*TPut) GetCellVisibility

func (p *TPut) GetCellVisibility() *TCellVisibility

func (*TPut) GetColumnValues

func (p *TPut) GetColumnValues() []*TColumnValue

func (*TPut) GetDurability

func (p *TPut) GetDurability() TDurability

func (*TPut) GetRow

func (p *TPut) GetRow() []byte

func (*TPut) GetTimestamp

func (p *TPut) GetTimestamp() int64

func (*TPut) IsSetAttributes

func (p *TPut) IsSetAttributes() bool

func (*TPut) IsSetCellVisibility

func (p *TPut) IsSetCellVisibility() bool

func (*TPut) IsSetDurability

func (p *TPut) IsSetDurability() bool

func (*TPut) IsSetTimestamp

func (p *TPut) IsSetTimestamp() bool

func (*TPut) Read

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

func (*TPut) ReadField1

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

func (*TPut) ReadField2

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

func (*TPut) ReadField3

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

func (*TPut) ReadField5

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

func (*TPut) ReadField6

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

func (*TPut) ReadField7

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

func (*TPut) String

func (p *TPut) String() string

func (*TPut) Write

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

type TReadType

type TReadType int64
const (
	TReadType_DEFAULT TReadType = 1
	TReadType_STREAM  TReadType = 2
	TReadType_PREAD   TReadType = 3
)
var TScan_ReadType_DEFAULT TReadType

func TReadTypeFromString

func TReadTypeFromString(s string) (TReadType, error)

func TReadTypePtr

func TReadTypePtr(v TReadType) *TReadType

func (TReadType) MarshalText

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

func (*TReadType) Scan

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

func (TReadType) String

func (p TReadType) String() string

func (*TReadType) UnmarshalText

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

func (*TReadType) Value

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

type TResult_

type TResult_ struct {
	Row          []byte          `thrift:"row,1" db:"row" json:"row,omitempty"`
	ColumnValues []*TColumnValue `thrift:"columnValues,2,required" db:"columnValues" json:"columnValues"`
	Stale        bool            `thrift:"stale,3" db:"stale" json:"stale"`
	Partial      bool            `thrift:"partial,4" db:"partial" json:"partial"`
}

if no Result is found, row and columnValues will not be set.

Attributes:

  • Row
  • ColumnValues
  • Stale
  • Partial
var THBaseServiceAppendResult_Success_DEFAULT *TResult_
var THBaseServiceGetResult_Success_DEFAULT *TResult_
var THBaseServiceIncrementResult_Success_DEFAULT *TResult_

func NewTResult_

func NewTResult_() *TResult_

func (*TResult_) Equals

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

func (*TResult_) GetColumnValues

func (p *TResult_) GetColumnValues() []*TColumnValue

func (*TResult_) GetPartial

func (p *TResult_) GetPartial() bool

func (*TResult_) GetRow

func (p *TResult_) GetRow() []byte

func (*TResult_) GetStale

func (p *TResult_) GetStale() bool

func (*TResult_) IsSetPartial

func (p *TResult_) IsSetPartial() bool

func (*TResult_) IsSetRow

func (p *TResult_) IsSetRow() bool

func (*TResult_) IsSetStale

func (p *TResult_) IsSetStale() bool

func (*TResult_) Read

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

func (*TResult_) ReadField1

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

func (*TResult_) ReadField2

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

func (*TResult_) ReadField3

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

func (*TResult_) ReadField4

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

func (*TResult_) String

func (p *TResult_) String() string

func (*TResult_) Write

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

type TRowMutations

type TRowMutations struct {
	Row       []byte       `thrift:"row,1,required" db:"row" json:"row"`
	Mutations []*TMutation `thrift:"mutations,2,required" db:"mutations" json:"mutations"`
}

A TRowMutations object is used to apply a number of Mutations to a single row.

Attributes:

  • Row
  • Mutations
var THBaseServiceCheckAndMutateArgs_RowMutations_DEFAULT *TRowMutations
var THBaseServiceMutateRowArgs_TrowMutations_DEFAULT *TRowMutations

func NewTRowMutations

func NewTRowMutations() *TRowMutations

func (*TRowMutations) Equals

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

func (*TRowMutations) GetMutations

func (p *TRowMutations) GetMutations() []*TMutation

func (*TRowMutations) GetRow

func (p *TRowMutations) GetRow() []byte

func (*TRowMutations) Read

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

func (*TRowMutations) ReadField1

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

func (*TRowMutations) ReadField2

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

func (*TRowMutations) String

func (p *TRowMutations) String() string

func (*TRowMutations) Write

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

type TScan

type TScan struct {
	StartRow           []byte                 `thrift:"startRow,1" db:"startRow" json:"startRow,omitempty"`
	StopRow            []byte                 `thrift:"stopRow,2" db:"stopRow" json:"stopRow,omitempty"`
	Columns            []*TColumn             `thrift:"columns,3" db:"columns" json:"columns,omitempty"`
	Caching            *int32                 `thrift:"caching,4" db:"caching" json:"caching,omitempty"`
	MaxVersions        int32                  `thrift:"maxVersions,5" db:"maxVersions" json:"maxVersions"`
	TimeRange          *TTimeRange            `thrift:"timeRange,6" db:"timeRange" json:"timeRange,omitempty"`
	FilterString       []byte                 `thrift:"filterString,7" db:"filterString" json:"filterString,omitempty"`
	BatchSize          *int32                 `thrift:"batchSize,8" db:"batchSize" json:"batchSize,omitempty"`
	Attributes         map[string][]byte      `thrift:"attributes,9" db:"attributes" json:"attributes,omitempty"`
	Authorizations     *TAuthorization        `thrift:"authorizations,10" db:"authorizations" json:"authorizations,omitempty"`
	Reversed           *bool                  `thrift:"reversed,11" db:"reversed" json:"reversed,omitempty"`
	CacheBlocks        *bool                  `thrift:"cacheBlocks,12" db:"cacheBlocks" json:"cacheBlocks,omitempty"`
	ColFamTimeRangeMap map[string]*TTimeRange `thrift:"colFamTimeRangeMap,13" db:"colFamTimeRangeMap" json:"colFamTimeRangeMap,omitempty"`
	ReadType           *TReadType             `thrift:"readType,14" db:"readType" json:"readType,omitempty"`
	Limit              *int32                 `thrift:"limit,15" db:"limit" json:"limit,omitempty"`
	Consistency        *TConsistency          `thrift:"consistency,16" db:"consistency" json:"consistency,omitempty"`
	TargetReplicaId    *int32                 `thrift:"targetReplicaId,17" db:"targetReplicaId" json:"targetReplicaId,omitempty"`
	FilterBytes        []byte                 `thrift:"filterBytes,18" db:"filterBytes" json:"filterBytes,omitempty"`
}

Any timestamps in the columns are ignored but the colFamTimeRangeMap included, use timeRange to select by timestamp. Max versions defaults to 1.

Attributes:

  • StartRow
  • StopRow
  • Columns
  • Caching
  • MaxVersions
  • TimeRange
  • FilterString
  • BatchSize
  • Attributes
  • Authorizations
  • Reversed
  • CacheBlocks
  • ColFamTimeRangeMap
  • ReadType
  • Limit
  • Consistency
  • TargetReplicaId
  • FilterBytes
var THBaseServiceGetScannerResultsArgs_Tscan_DEFAULT *TScan
var THBaseServiceOpenScannerArgs_Tscan_DEFAULT *TScan

func NewTScan

func NewTScan() *TScan

func (*TScan) Equals

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

func (*TScan) GetAttributes

func (p *TScan) GetAttributes() map[string][]byte

func (*TScan) GetAuthorizations

func (p *TScan) GetAuthorizations() *TAuthorization

func (*TScan) GetBatchSize

func (p *TScan) GetBatchSize() int32

func (*TScan) GetCacheBlocks

func (p *TScan) GetCacheBlocks() bool

func (*TScan) GetCaching

func (p *TScan) GetCaching() int32

func (*TScan) GetColFamTimeRangeMap

func (p *TScan) GetColFamTimeRangeMap() map[string]*TTimeRange

func (*TScan) GetColumns

func (p *TScan) GetColumns() []*TColumn

func (*TScan) GetConsistency

func (p *TScan) GetConsistency() TConsistency

func (*TScan) GetFilterBytes

func (p *TScan) GetFilterBytes() []byte

func (*TScan) GetFilterString

func (p *TScan) GetFilterString() []byte

func (*TScan) GetLimit

func (p *TScan) GetLimit() int32

func (*TScan) GetMaxVersions

func (p *TScan) GetMaxVersions() int32

func (*TScan) GetReadType

func (p *TScan) GetReadType() TReadType

func (*TScan) GetReversed

func (p *TScan) GetReversed() bool

func (*TScan) GetStartRow

func (p *TScan) GetStartRow() []byte

func (*TScan) GetStopRow

func (p *TScan) GetStopRow() []byte

func (*TScan) GetTargetReplicaId

func (p *TScan) GetTargetReplicaId() int32

func (*TScan) GetTimeRange

func (p *TScan) GetTimeRange() *TTimeRange

func (*TScan) IsSetAttributes

func (p *TScan) IsSetAttributes() bool

func (*TScan) IsSetAuthorizations

func (p *TScan) IsSetAuthorizations() bool

func (*TScan) IsSetBatchSize

func (p *TScan) IsSetBatchSize() bool

func (*TScan) IsSetCacheBlocks

func (p *TScan) IsSetCacheBlocks() bool

func (*TScan) IsSetCaching

func (p *TScan) IsSetCaching() bool

func (*TScan) IsSetColFamTimeRangeMap

func (p *TScan) IsSetColFamTimeRangeMap() bool

func (*TScan) IsSetColumns

func (p *TScan) IsSetColumns() bool

func (*TScan) IsSetConsistency

func (p *TScan) IsSetConsistency() bool

func (*TScan) IsSetFilterBytes

func (p *TScan) IsSetFilterBytes() bool

func (*TScan) IsSetFilterString

func (p *TScan) IsSetFilterString() bool

func (*TScan) IsSetLimit

func (p *TScan) IsSetLimit() bool

func (*TScan) IsSetMaxVersions

func (p *TScan) IsSetMaxVersions() bool

func (*TScan) IsSetReadType

func (p *TScan) IsSetReadType() bool

func (*TScan) IsSetReversed

func (p *TScan) IsSetReversed() bool

func (*TScan) IsSetStartRow

func (p *TScan) IsSetStartRow() bool

func (*TScan) IsSetStopRow

func (p *TScan) IsSetStopRow() bool

func (*TScan) IsSetTargetReplicaId

func (p *TScan) IsSetTargetReplicaId() bool

func (*TScan) IsSetTimeRange

func (p *TScan) IsSetTimeRange() bool

func (*TScan) Read

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

func (*TScan) ReadField1

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

func (*TScan) ReadField10

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

func (*TScan) ReadField11

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

func (*TScan) ReadField12

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

func (*TScan) ReadField13

func (p *TScan) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*TScan) ReadField14

func (p *TScan) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*TScan) ReadField15

func (p *TScan) ReadField15(ctx context.Context, iprot thrift.TProtocol) error

func (*TScan) ReadField16

func (p *TScan) ReadField16(ctx context.Context, iprot thrift.TProtocol) error

func (*TScan) ReadField17

func (p *TScan) ReadField17(ctx context.Context, iprot thrift.TProtocol) error

func (*TScan) ReadField18

func (p *TScan) ReadField18(ctx context.Context, iprot thrift.TProtocol) error

func (*TScan) ReadField2

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

func (*TScan) ReadField3

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

func (*TScan) ReadField4

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

func (*TScan) ReadField5

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

func (*TScan) ReadField6

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

func (*TScan) ReadField7

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

func (*TScan) ReadField8

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

func (*TScan) ReadField9

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

func (*TScan) String

func (p *TScan) String() string

func (*TScan) Write

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

type TServerName

type TServerName struct {
	HostName  string `thrift:"hostName,1,required" db:"hostName" json:"hostName"`
	Port      *int32 `thrift:"port,2" db:"port" json:"port,omitempty"`
	StartCode *int64 `thrift:"startCode,3" db:"startCode" json:"startCode,omitempty"`
}

Attributes:

  • HostName
  • Port
  • StartCode
var THRegionLocation_ServerName_DEFAULT *TServerName

func NewTServerName

func NewTServerName() *TServerName

func (*TServerName) Equals

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

func (*TServerName) GetHostName

func (p *TServerName) GetHostName() string

func (*TServerName) GetPort

func (p *TServerName) GetPort() int32

func (*TServerName) GetStartCode

func (p *TServerName) GetStartCode() int64

func (*TServerName) IsSetPort

func (p *TServerName) IsSetPort() bool

func (*TServerName) IsSetStartCode

func (p *TServerName) IsSetStartCode() bool

func (*TServerName) Read

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

func (*TServerName) ReadField1

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

func (*TServerName) ReadField2

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

func (*TServerName) ReadField3

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

func (*TServerName) String

func (p *TServerName) String() string

func (*TServerName) Write

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

type TTableDescriptor

type TTableDescriptor struct {
	TableName  *TTableName                `thrift:"tableName,1,required" db:"tableName" json:"tableName"`
	Columns    []*TColumnFamilyDescriptor `thrift:"columns,2" db:"columns" json:"columns,omitempty"`
	Attributes map[string][]byte          `thrift:"attributes,3" db:"attributes" json:"attributes,omitempty"`
	Durability *TDurability               `thrift:"durability,4" db:"durability" json:"durability,omitempty"`
}

Thrift wrapper around org.apache.hadoop.hbase.client.TableDescriptor

Attributes:

  • TableName
  • Columns
  • Attributes
  • Durability
var THBaseServiceCreateTableArgs_Desc_DEFAULT *TTableDescriptor
var THBaseServiceGetTableDescriptorResult_Success_DEFAULT *TTableDescriptor
var THBaseServiceModifyTableArgs_Desc_DEFAULT *TTableDescriptor

func NewTTableDescriptor

func NewTTableDescriptor() *TTableDescriptor

func (*TTableDescriptor) Equals

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

func (*TTableDescriptor) GetAttributes

func (p *TTableDescriptor) GetAttributes() map[string][]byte

func (*TTableDescriptor) GetColumns

func (p *TTableDescriptor) GetColumns() []*TColumnFamilyDescriptor

func (*TTableDescriptor) GetDurability

func (p *TTableDescriptor) GetDurability() TDurability

func (*TTableDescriptor) GetTableName

func (p *TTableDescriptor) GetTableName() *TTableName

func (*TTableDescriptor) IsSetAttributes

func (p *TTableDescriptor) IsSetAttributes() bool

func (*TTableDescriptor) IsSetColumns

func (p *TTableDescriptor) IsSetColumns() bool

func (*TTableDescriptor) IsSetDurability

func (p *TTableDescriptor) IsSetDurability() bool

func (*TTableDescriptor) IsSetTableName

func (p *TTableDescriptor) IsSetTableName() bool

func (*TTableDescriptor) Read

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

func (*TTableDescriptor) ReadField1

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

func (*TTableDescriptor) ReadField2

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

func (*TTableDescriptor) ReadField3

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

func (*TTableDescriptor) ReadField4

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

func (*TTableDescriptor) String

func (p *TTableDescriptor) String() string

func (*TTableDescriptor) Write

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

type TTableName

type TTableName struct {
	Ns        []byte `thrift:"ns,1" db:"ns" json:"ns,omitempty"`
	Qualifier []byte `thrift:"qualifier,2,required" db:"qualifier" json:"qualifier"`
}

Thrift wrapper around org.apache.hadoop.hbase.TableName

Attributes:

  • Ns: namespace name
  • Qualifier: tablename
var THBaseServiceAddColumnFamilyArgs_TableName_DEFAULT *TTableName
var THBaseServiceDeleteColumnFamilyArgs_TableName_DEFAULT *TTableName
var THBaseServiceDeleteTableArgs_TableName_DEFAULT *TTableName
var THBaseServiceDisableTableArgs_TableName_DEFAULT *TTableName
var THBaseServiceEnableTableArgs_TableName_DEFAULT *TTableName
var THBaseServiceGetTableDescriptorArgs_Table_DEFAULT *TTableName
var THBaseServiceIsTableAvailableArgs_TableName_DEFAULT *TTableName
var THBaseServiceIsTableAvailableWithSplitArgs_TableName_DEFAULT *TTableName
var THBaseServiceIsTableDisabledArgs_TableName_DEFAULT *TTableName
var THBaseServiceIsTableEnabledArgs_TableName_DEFAULT *TTableName
var THBaseServiceModifyColumnFamilyArgs_TableName_DEFAULT *TTableName
var THBaseServiceTableExistsArgs_TableName_DEFAULT *TTableName
var THBaseServiceTruncateTableArgs_TableName_DEFAULT *TTableName
var TTableDescriptor_TableName_DEFAULT *TTableName

func NewTTableName

func NewTTableName() *TTableName

func (*TTableName) Equals

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

func (*TTableName) GetNs

func (p *TTableName) GetNs() []byte

func (*TTableName) GetQualifier

func (p *TTableName) GetQualifier() []byte

func (*TTableName) IsSetNs

func (p *TTableName) IsSetNs() bool

func (*TTableName) Read

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

func (*TTableName) ReadField1

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

func (*TTableName) ReadField2

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

func (*TTableName) String

func (p *TTableName) String() string

func (*TTableName) Write

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

type TThriftServerType

type TThriftServerType int64

Specify type of thrift server: thrift and thrift2

const (
	TThriftServerType_ONE TThriftServerType = 1
	TThriftServerType_TWO TThriftServerType = 2
)
var THBaseServiceGetThriftServerTypeResult_Success_DEFAULT TThriftServerType

func TThriftServerTypeFromString

func TThriftServerTypeFromString(s string) (TThriftServerType, error)

func TThriftServerTypePtr

func TThriftServerTypePtr(v TThriftServerType) *TThriftServerType

func (TThriftServerType) MarshalText

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

func (*TThriftServerType) Scan

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

func (TThriftServerType) String

func (p TThriftServerType) String() string

func (*TThriftServerType) UnmarshalText

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

func (*TThriftServerType) Value

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

type TTimeRange

type TTimeRange struct {
	MinStamp int64 `thrift:"minStamp,1,required" db:"minStamp" json:"minStamp"`
	MaxStamp int64 `thrift:"maxStamp,2,required" db:"maxStamp" json:"maxStamp"`
}

Attributes:

  • MinStamp
  • MaxStamp
var TGet_TimeRange_DEFAULT *TTimeRange
var TScan_TimeRange_DEFAULT *TTimeRange

func NewTTimeRange

func NewTTimeRange() *TTimeRange

func (*TTimeRange) Equals

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

func (*TTimeRange) GetMaxStamp

func (p *TTimeRange) GetMaxStamp() int64

func (*TTimeRange) GetMinStamp

func (p *TTimeRange) GetMinStamp() int64

func (*TTimeRange) Read

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

func (*TTimeRange) ReadField1

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

func (*TTimeRange) ReadField2

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

func (*TTimeRange) String

func (p *TTimeRange) String() string

func (*TTimeRange) Write

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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