hbase

package
v2.2.2 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
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 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 THBaseServiceGetMultipleResult_Success_DEFAULT []*TResult_
View Source 
var THBaseServiceGetScannerResultsResult_Success_DEFAULT []*TResult_
View Source 
var THBaseServiceGetScannerRowsResult_Success_DEFAULT []*TResult_
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 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 THBaseServiceOpenScannerResult_Success_DEFAULT int32
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_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 TNamespaceDescriptor_Configuration_DEFAULT map[string]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 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 (p *TColumnFamilyDescriptor) Equals(other *TColumnFamilyDescriptor) bool

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 (p *TColumnFamilyDescriptor) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TCompareOp 

type TCompareOp int64

Thrift wrapper around org.apache.hadoop.hbase.filter.CompareFilter$CompareOp. 

const (
	TCompareOp_LESS             TCompareOp = 0
	TCompareOp_LESS_OR_EQUAL    TCompareOp = 1
	TCompareOp_EQUAL            TCompareOp = 2
	TCompareOp_NOT_EQUAL        TCompareOp = 3
	TCompareOp_GREATER_OR_EQUAL TCompareOp = 4
	TCompareOp_GREATER          TCompareOp = 5
	TCompareOp_NO_OP            TCompareOp = 6
)

func TCompareOpFromString 

func TCompareOpFromString(s string) (TCompareOp, error)

func TCompareOpPtr 

func TCompareOpPtr(v TCompareOp) *TCompareOp

func (TCompareOp) MarshalText 

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

func (*TCompareOp) Scan 

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

func (TCompareOp) String 

func (p TCompareOp) String() string

func (*TCompareOp) UnmarshalText 

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

func (*TCompareOp) Value 

func (p *TCompareOp) 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 TCompressionAlgorithmPtr 

func TCompressionAlgorithmPtr(v TCompressionAlgorithm) *TCompressionAlgorithm

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 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
	//  - CompareOp: 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, compareOp TCompareOp, 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
	// *
	//
	// 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)
}

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 (p *THBaseServiceAddColumnFamilyArgs) GetColumn() *TColumnFamilyDescriptor

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 (p *THBaseServiceAddColumnFamilyArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceAddColumnFamilyArgs) ReadField1 

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

func (*THBaseServiceAddColumnFamilyArgs) ReadField2 

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

func (*THBaseServiceAddColumnFamilyArgs) String 

func (p *THBaseServiceAddColumnFamilyArgs) String() string

func (*THBaseServiceAddColumnFamilyArgs) Write 

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

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 (p *THBaseServiceAddColumnFamilyResult) GetIo() *TIOError

func (*THBaseServiceAddColumnFamilyResult) IsSetIo 

func (p *THBaseServiceAddColumnFamilyResult) IsSetIo() bool

func (*THBaseServiceAddColumnFamilyResult) Read 

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

func (*THBaseServiceAddColumnFamilyResult) ReadField1 

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

func (*THBaseServiceAddColumnFamilyResult) String 

func (p *THBaseServiceAddColumnFamilyResult) String() string

func (*THBaseServiceAddColumnFamilyResult) Write 

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

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 (p *THBaseServiceAppendArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceAppendResult) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceCheckAndDeleteArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndDeleteArgs) ReadField1 

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

func (*THBaseServiceCheckAndDeleteArgs) ReadField2 

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

func (*THBaseServiceCheckAndDeleteArgs) ReadField3 

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

func (*THBaseServiceCheckAndDeleteArgs) ReadField4 

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

func (*THBaseServiceCheckAndDeleteArgs) ReadField5 

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

func (*THBaseServiceCheckAndDeleteArgs) ReadField6 

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

func (*THBaseServiceCheckAndDeleteArgs) String 

func (p *THBaseServiceCheckAndDeleteArgs) String() string

func (*THBaseServiceCheckAndDeleteArgs) Write 

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

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 (p *THBaseServiceCheckAndDeleteResult) GetIo() *TIOError

func (*THBaseServiceCheckAndDeleteResult) GetSuccess 

func (p *THBaseServiceCheckAndDeleteResult) GetSuccess() bool

func (*THBaseServiceCheckAndDeleteResult) IsSetIo 

func (p *THBaseServiceCheckAndDeleteResult) IsSetIo() bool

func (*THBaseServiceCheckAndDeleteResult) IsSetSuccess 

func (p *THBaseServiceCheckAndDeleteResult) IsSetSuccess() bool

func (*THBaseServiceCheckAndDeleteResult) Read 

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

func (*THBaseServiceCheckAndDeleteResult) ReadField0 

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

func (*THBaseServiceCheckAndDeleteResult) ReadField1 

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

func (*THBaseServiceCheckAndDeleteResult) String 

func (p *THBaseServiceCheckAndDeleteResult) String() string

func (*THBaseServiceCheckAndDeleteResult) Write 

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

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"`
	CompareOp    TCompareOp     `thrift:"compareOp,5,required" db:"compareOp" json:"compareOp"`
	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
  • CompareOp: 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) GetCompareOp 

func (p *THBaseServiceCheckAndMutateArgs) GetCompareOp() TCompareOp

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 (p *THBaseServiceCheckAndMutateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndMutateArgs) ReadField1 

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

func (*THBaseServiceCheckAndMutateArgs) ReadField2 

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

func (*THBaseServiceCheckAndMutateArgs) ReadField3 

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

func (*THBaseServiceCheckAndMutateArgs) ReadField4 

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

func (*THBaseServiceCheckAndMutateArgs) ReadField5 

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

func (*THBaseServiceCheckAndMutateArgs) ReadField6 

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

func (*THBaseServiceCheckAndMutateArgs) ReadField7 

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

func (*THBaseServiceCheckAndMutateArgs) String 

func (p *THBaseServiceCheckAndMutateArgs) String() string

func (*THBaseServiceCheckAndMutateArgs) Write 

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

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 (p *THBaseServiceCheckAndMutateResult) GetIo() *TIOError

func (*THBaseServiceCheckAndMutateResult) GetSuccess 

func (p *THBaseServiceCheckAndMutateResult) GetSuccess() bool

func (*THBaseServiceCheckAndMutateResult) IsSetIo 

func (p *THBaseServiceCheckAndMutateResult) IsSetIo() bool

func (*THBaseServiceCheckAndMutateResult) IsSetSuccess 

func (p *THBaseServiceCheckAndMutateResult) IsSetSuccess() bool

func (*THBaseServiceCheckAndMutateResult) Read 

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

func (*THBaseServiceCheckAndMutateResult) ReadField0 

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

func (*THBaseServiceCheckAndMutateResult) ReadField1 

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

func (*THBaseServiceCheckAndMutateResult) String 

func (p *THBaseServiceCheckAndMutateResult) String() string

func (*THBaseServiceCheckAndMutateResult) Write 

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

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 (p *THBaseServiceCheckAndPutArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndPutArgs) ReadField1 

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

func (*THBaseServiceCheckAndPutArgs) ReadField2 

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

func (*THBaseServiceCheckAndPutArgs) ReadField3 

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

func (*THBaseServiceCheckAndPutArgs) ReadField4 

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

func (*THBaseServiceCheckAndPutArgs) ReadField5 

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

func (*THBaseServiceCheckAndPutArgs) ReadField6 

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

func (*THBaseServiceCheckAndPutArgs) String 

func (p *THBaseServiceCheckAndPutArgs) String() string

func (*THBaseServiceCheckAndPutArgs) Write 

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

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 (p *THBaseServiceCheckAndPutResult) GetIo() *TIOError

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 (p *THBaseServiceCheckAndPutResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndPutResult) ReadField0 

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

func (*THBaseServiceCheckAndPutResult) ReadField1 

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

func (*THBaseServiceCheckAndPutResult) String 

func (p *THBaseServiceCheckAndPutResult) String() string

func (*THBaseServiceCheckAndPutResult) Write 

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

type THBaseServiceClient 

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

func NewTHBaseServiceClient 

func NewTHBaseServiceClient(c thrift.TClient) *THBaseServiceClient

func NewTHBaseServiceClientFactory 

func NewTHBaseServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *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, compareOp TCompareOp, 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
  • CompareOp: 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) 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) 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) 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) 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

*

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) 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) 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 (p *THBaseServiceCloseScannerArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceCloseScannerArgs) ReadField1 

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

func (*THBaseServiceCloseScannerArgs) String 

func (p *THBaseServiceCloseScannerArgs) String() string

func (*THBaseServiceCloseScannerArgs) Write 

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

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 (p *THBaseServiceCloseScannerResult) GetIa() *TIllegalArgument

func (*THBaseServiceCloseScannerResult) GetIo 

func (p *THBaseServiceCloseScannerResult) GetIo() *TIOError

func (*THBaseServiceCloseScannerResult) IsSetIa 

func (p *THBaseServiceCloseScannerResult) IsSetIa() bool

func (*THBaseServiceCloseScannerResult) IsSetIo 

func (p *THBaseServiceCloseScannerResult) IsSetIo() bool

func (*THBaseServiceCloseScannerResult) Read 

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

func (*THBaseServiceCloseScannerResult) ReadField1 

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

func (*THBaseServiceCloseScannerResult) ReadField2 

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

func (*THBaseServiceCloseScannerResult) String 

func (p *THBaseServiceCloseScannerResult) String() string

func (*THBaseServiceCloseScannerResult) Write 

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

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 (p *THBaseServiceCreateNamespaceArgs) GetNamespaceDesc() *TNamespaceDescriptor

func (*THBaseServiceCreateNamespaceArgs) IsSetNamespaceDesc 

func (p *THBaseServiceCreateNamespaceArgs) IsSetNamespaceDesc() bool

func (*THBaseServiceCreateNamespaceArgs) Read 

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

func (*THBaseServiceCreateNamespaceArgs) ReadField1 

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

func (*THBaseServiceCreateNamespaceArgs) String 

func (p *THBaseServiceCreateNamespaceArgs) String() string

func (*THBaseServiceCreateNamespaceArgs) Write 

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

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 (p *THBaseServiceCreateNamespaceResult) GetIo() *TIOError

func (*THBaseServiceCreateNamespaceResult) IsSetIo 

func (p *THBaseServiceCreateNamespaceResult) IsSetIo() bool

func (*THBaseServiceCreateNamespaceResult) Read 

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

func (*THBaseServiceCreateNamespaceResult) ReadField1 

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

func (*THBaseServiceCreateNamespaceResult) String 

func (p *THBaseServiceCreateNamespaceResult) String() string

func (*THBaseServiceCreateNamespaceResult) Write 

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

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 (p *THBaseServiceCreateTableArgs) GetDesc() *TTableDescriptor

func (*THBaseServiceCreateTableArgs) GetSplitKeys 

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

func (*THBaseServiceCreateTableArgs) IsSetDesc 

func (p *THBaseServiceCreateTableArgs) IsSetDesc() bool

func (*THBaseServiceCreateTableArgs) Read 

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

func (*THBaseServiceCreateTableArgs) ReadField1 

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

func (*THBaseServiceCreateTableArgs) ReadField2 

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

func (*THBaseServiceCreateTableArgs) String 

func (p *THBaseServiceCreateTableArgs) String() string

func (*THBaseServiceCreateTableArgs) Write 

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

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 (p *THBaseServiceCreateTableResult) GetIo() *TIOError

func (*THBaseServiceCreateTableResult) IsSetIo 

func (p *THBaseServiceCreateTableResult) IsSetIo() bool

func (*THBaseServiceCreateTableResult) Read 

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

func (*THBaseServiceCreateTableResult) ReadField1 

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

func (*THBaseServiceCreateTableResult) String 

func (p *THBaseServiceCreateTableResult) String() string

func (*THBaseServiceCreateTableResult) Write 

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

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 (p *THBaseServiceDeleteColumnFamilyArgs) GetTableName() *TTableName

func (*THBaseServiceDeleteColumnFamilyArgs) IsSetTableName 

func (p *THBaseServiceDeleteColumnFamilyArgs) IsSetTableName() bool

func (*THBaseServiceDeleteColumnFamilyArgs) Read 

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

func (*THBaseServiceDeleteColumnFamilyArgs) ReadField1 

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

func (*THBaseServiceDeleteColumnFamilyArgs) ReadField2 

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

func (*THBaseServiceDeleteColumnFamilyArgs) String 

func (p *THBaseServiceDeleteColumnFamilyArgs) String() string

func (*THBaseServiceDeleteColumnFamilyArgs) Write 

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

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 (p *THBaseServiceDeleteColumnFamilyResult) GetIo() *TIOError

func (*THBaseServiceDeleteColumnFamilyResult) IsSetIo 

func (p *THBaseServiceDeleteColumnFamilyResult) IsSetIo() bool

func (*THBaseServiceDeleteColumnFamilyResult) Read 

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

func (*THBaseServiceDeleteColumnFamilyResult) ReadField1 

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

func (*THBaseServiceDeleteColumnFamilyResult) String 

func (p *THBaseServiceDeleteColumnFamilyResult) String() string

func (*THBaseServiceDeleteColumnFamilyResult) Write 

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

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 (p *THBaseServiceDeleteMultipleArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceDeleteMultipleArgs) ReadField1 

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

func (*THBaseServiceDeleteMultipleArgs) ReadField2 

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

func (*THBaseServiceDeleteMultipleArgs) String 

func (p *THBaseServiceDeleteMultipleArgs) String() string

func (*THBaseServiceDeleteMultipleArgs) Write 

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

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 (p *THBaseServiceDeleteMultipleResult) GetIo() *TIOError

func (*THBaseServiceDeleteMultipleResult) GetSuccess 

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

func (*THBaseServiceDeleteMultipleResult) IsSetIo 

func (p *THBaseServiceDeleteMultipleResult) IsSetIo() bool

func (*THBaseServiceDeleteMultipleResult) IsSetSuccess 

func (p *THBaseServiceDeleteMultipleResult) IsSetSuccess() bool

func (*THBaseServiceDeleteMultipleResult) Read 

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

func (*THBaseServiceDeleteMultipleResult) ReadField0 

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

func (*THBaseServiceDeleteMultipleResult) ReadField1 

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

func (*THBaseServiceDeleteMultipleResult) String 

func (p *THBaseServiceDeleteMultipleResult) String() string

func (*THBaseServiceDeleteMultipleResult) Write 

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

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 (p *THBaseServiceDeleteNamespaceArgs) GetName() string

func (*THBaseServiceDeleteNamespaceArgs) Read 

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

func (*THBaseServiceDeleteNamespaceArgs) ReadField1 

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

func (*THBaseServiceDeleteNamespaceArgs) String 

func (p *THBaseServiceDeleteNamespaceArgs) String() string

func (*THBaseServiceDeleteNamespaceArgs) Write 

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

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 (p *THBaseServiceDeleteNamespaceResult) GetIo() *TIOError

func (*THBaseServiceDeleteNamespaceResult) IsSetIo 

func (p *THBaseServiceDeleteNamespaceResult) IsSetIo() bool

func (*THBaseServiceDeleteNamespaceResult) Read 

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

func (*THBaseServiceDeleteNamespaceResult) ReadField1 

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

func (*THBaseServiceDeleteNamespaceResult) String 

func (p *THBaseServiceDeleteNamespaceResult) String() string

func (*THBaseServiceDeleteNamespaceResult) Write 

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

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 (p *THBaseServiceDeleteSingleArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceDeleteSingleArgs) ReadField1 

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

func (*THBaseServiceDeleteSingleArgs) ReadField2 

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

func (*THBaseServiceDeleteSingleArgs) String 

func (p *THBaseServiceDeleteSingleArgs) String() string

func (*THBaseServiceDeleteSingleArgs) Write 

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

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 (p *THBaseServiceDeleteSingleResult) GetIo() *TIOError

func (*THBaseServiceDeleteSingleResult) IsSetIo 

func (p *THBaseServiceDeleteSingleResult) IsSetIo() bool

func (*THBaseServiceDeleteSingleResult) Read 

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

func (*THBaseServiceDeleteSingleResult) ReadField1 

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

func (*THBaseServiceDeleteSingleResult) String 

func (p *THBaseServiceDeleteSingleResult) String() string

func (*THBaseServiceDeleteSingleResult) Write 

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

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 (p *THBaseServiceDeleteTableArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceDeleteTableArgs) ReadField1 

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

func (*THBaseServiceDeleteTableArgs) String 

func (p *THBaseServiceDeleteTableArgs) String() string

func (*THBaseServiceDeleteTableArgs) Write 

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

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 (p *THBaseServiceDeleteTableResult) GetIo() *TIOError

func (*THBaseServiceDeleteTableResult) IsSetIo 

func (p *THBaseServiceDeleteTableResult) IsSetIo() bool

func (*THBaseServiceDeleteTableResult) Read 

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

func (*THBaseServiceDeleteTableResult) ReadField1 

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

func (*THBaseServiceDeleteTableResult) String 

func (p *THBaseServiceDeleteTableResult) String() string

func (*THBaseServiceDeleteTableResult) Write 

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

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 (p *THBaseServiceDisableTableArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceDisableTableArgs) ReadField1 

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

func (*THBaseServiceDisableTableArgs) String 

func (p *THBaseServiceDisableTableArgs) String() string

func (*THBaseServiceDisableTableArgs) Write 

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

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 (p *THBaseServiceDisableTableResult) GetIo() *TIOError

func (*THBaseServiceDisableTableResult) IsSetIo 

func (p *THBaseServiceDisableTableResult) IsSetIo() bool

func (*THBaseServiceDisableTableResult) Read 

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

func (*THBaseServiceDisableTableResult) ReadField1 

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

func (*THBaseServiceDisableTableResult) String 

func (p *THBaseServiceDisableTableResult) String() string

func (*THBaseServiceDisableTableResult) Write 

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

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 (p *THBaseServiceEnableTableArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceEnableTableArgs) ReadField1 

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

func (*THBaseServiceEnableTableArgs) String 

func (p *THBaseServiceEnableTableArgs) String() string

func (*THBaseServiceEnableTableArgs) Write 

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

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 (p *THBaseServiceEnableTableResult) GetIo() *TIOError

func (*THBaseServiceEnableTableResult) IsSetIo 

func (p *THBaseServiceEnableTableResult) IsSetIo() bool

func (*THBaseServiceEnableTableResult) Read 

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

func (*THBaseServiceEnableTableResult) ReadField1 

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

func (*THBaseServiceEnableTableResult) String 

func (p *THBaseServiceEnableTableResult) String() string

func (*THBaseServiceEnableTableResult) Write 

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

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 (p *THBaseServiceExistsAllArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceExistsAllResult) GetIo() *TIOError

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 (p *THBaseServiceExistsAllResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceExistsAllResult) ReadField0 

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

func (*THBaseServiceExistsAllResult) ReadField1 

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

func (*THBaseServiceExistsAllResult) String 

func (p *THBaseServiceExistsAllResult) String() string

func (*THBaseServiceExistsAllResult) Write 

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

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 (p *THBaseServiceExistsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceExistsResult) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceGetAllRegionLocationsArgs) GetTable() []byte

func (*THBaseServiceGetAllRegionLocationsArgs) Read 

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

func (*THBaseServiceGetAllRegionLocationsArgs) ReadField1 

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

func (*THBaseServiceGetAllRegionLocationsArgs) String 

func (p *THBaseServiceGetAllRegionLocationsArgs) String() string

func (*THBaseServiceGetAllRegionLocationsArgs) Write 

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

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 (p *THBaseServiceGetAllRegionLocationsResult) GetIo() *TIOError

func (*THBaseServiceGetAllRegionLocationsResult) GetSuccess 

func (p *THBaseServiceGetAllRegionLocationsResult) GetSuccess() []*THRegionLocation

func (*THBaseServiceGetAllRegionLocationsResult) IsSetIo 

func (p *THBaseServiceGetAllRegionLocationsResult) IsSetIo() bool

func (*THBaseServiceGetAllRegionLocationsResult) IsSetSuccess 

func (p *THBaseServiceGetAllRegionLocationsResult) IsSetSuccess() bool

func (*THBaseServiceGetAllRegionLocationsResult) Read 

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

func (*THBaseServiceGetAllRegionLocationsResult) ReadField0 

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

func (*THBaseServiceGetAllRegionLocationsResult) ReadField1 

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

func (*THBaseServiceGetAllRegionLocationsResult) String 

func (p *THBaseServiceGetAllRegionLocationsResult) String() string

func (*THBaseServiceGetAllRegionLocationsResult) Write 

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

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 (p *THBaseServiceGetArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceGetMultipleArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceGetMultipleArgs) ReadField1 

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

func (*THBaseServiceGetMultipleArgs) ReadField2 

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

func (*THBaseServiceGetMultipleArgs) String 

func (p *THBaseServiceGetMultipleArgs) String() string

func (*THBaseServiceGetMultipleArgs) Write 

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

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 (p *THBaseServiceGetMultipleResult) GetIo() *TIOError

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 (p *THBaseServiceGetMultipleResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceGetMultipleResult) ReadField0 

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

func (*THBaseServiceGetMultipleResult) ReadField1 

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

func (*THBaseServiceGetMultipleResult) String 

func (p *THBaseServiceGetMultipleResult) String() string

func (*THBaseServiceGetMultipleResult) Write 

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

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 (p *THBaseServiceGetNamespaceDescriptorArgs) GetName() string

func (*THBaseServiceGetNamespaceDescriptorArgs) Read 

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

func (*THBaseServiceGetNamespaceDescriptorArgs) ReadField1 

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

func (*THBaseServiceGetNamespaceDescriptorArgs) String 

func (p *THBaseServiceGetNamespaceDescriptorArgs) String() string

func (*THBaseServiceGetNamespaceDescriptorArgs) Write 

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

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 (p *THBaseServiceGetNamespaceDescriptorResult) GetIo() *TIOError

func (*THBaseServiceGetNamespaceDescriptorResult) GetSuccess 

func (p *THBaseServiceGetNamespaceDescriptorResult) GetSuccess() *TNamespaceDescriptor

func (*THBaseServiceGetNamespaceDescriptorResult) IsSetIo 

func (p *THBaseServiceGetNamespaceDescriptorResult) IsSetIo() bool

func (*THBaseServiceGetNamespaceDescriptorResult) IsSetSuccess 

func (p *THBaseServiceGetNamespaceDescriptorResult) IsSetSuccess() bool

func (*THBaseServiceGetNamespaceDescriptorResult) Read 

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

func (*THBaseServiceGetNamespaceDescriptorResult) ReadField0 

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

func (*THBaseServiceGetNamespaceDescriptorResult) ReadField1 

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

func (*THBaseServiceGetNamespaceDescriptorResult) String 

func (p *THBaseServiceGetNamespaceDescriptorResult) String() string

func (*THBaseServiceGetNamespaceDescriptorResult) Write 

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

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 (p *THBaseServiceGetRegionLocationArgs) GetReload() bool

func (*THBaseServiceGetRegionLocationArgs) GetRow 

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

func (*THBaseServiceGetRegionLocationArgs) GetTable 

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

func (*THBaseServiceGetRegionLocationArgs) Read 

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

func (*THBaseServiceGetRegionLocationArgs) ReadField1 

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

func (*THBaseServiceGetRegionLocationArgs) ReadField2 

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

func (*THBaseServiceGetRegionLocationArgs) ReadField3 

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

func (*THBaseServiceGetRegionLocationArgs) String 

func (p *THBaseServiceGetRegionLocationArgs) String() string

func (*THBaseServiceGetRegionLocationArgs) Write 

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

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 (p *THBaseServiceGetRegionLocationResult) GetIo() *TIOError

func (*THBaseServiceGetRegionLocationResult) GetSuccess 

func (p *THBaseServiceGetRegionLocationResult) GetSuccess() *THRegionLocation

func (*THBaseServiceGetRegionLocationResult) IsSetIo 

func (p *THBaseServiceGetRegionLocationResult) IsSetIo() bool

func (*THBaseServiceGetRegionLocationResult) IsSetSuccess 

func (p *THBaseServiceGetRegionLocationResult) IsSetSuccess() bool

func (*THBaseServiceGetRegionLocationResult) Read 

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

func (*THBaseServiceGetRegionLocationResult) ReadField0 

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

func (*THBaseServiceGetRegionLocationResult) ReadField1 

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

func (*THBaseServiceGetRegionLocationResult) String 

func (p *THBaseServiceGetRegionLocationResult) String() string

func (*THBaseServiceGetRegionLocationResult) Write 

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

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 (p *THBaseServiceGetResult) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceGetScannerResultsArgs) GetTscan() *TScan

func (*THBaseServiceGetScannerResultsArgs) IsSetTscan 

func (p *THBaseServiceGetScannerResultsArgs) IsSetTscan() bool

func (*THBaseServiceGetScannerResultsArgs) Read 

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

func (*THBaseServiceGetScannerResultsArgs) ReadField1 

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

func (*THBaseServiceGetScannerResultsArgs) ReadField2 

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

func (*THBaseServiceGetScannerResultsArgs) ReadField3 

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

func (*THBaseServiceGetScannerResultsArgs) String 

func (p *THBaseServiceGetScannerResultsArgs) String() string

func (*THBaseServiceGetScannerResultsArgs) Write 

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

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 (p *THBaseServiceGetScannerResultsResult) GetIo() *TIOError

func (*THBaseServiceGetScannerResultsResult) GetSuccess 

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

func (*THBaseServiceGetScannerResultsResult) IsSetIo 

func (p *THBaseServiceGetScannerResultsResult) IsSetIo() bool

func (*THBaseServiceGetScannerResultsResult) IsSetSuccess 

func (p *THBaseServiceGetScannerResultsResult) IsSetSuccess() bool

func (*THBaseServiceGetScannerResultsResult) Read 

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

func (*THBaseServiceGetScannerResultsResult) ReadField0 

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

func (*THBaseServiceGetScannerResultsResult) ReadField1 

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

func (*THBaseServiceGetScannerResultsResult) String 

func (p *THBaseServiceGetScannerResultsResult) String() string

func (*THBaseServiceGetScannerResultsResult) Write 

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

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 (p *THBaseServiceGetScannerRowsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceGetScannerRowsArgs) ReadField1 

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

func (*THBaseServiceGetScannerRowsArgs) ReadField2 

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

func (*THBaseServiceGetScannerRowsArgs) String 

func (p *THBaseServiceGetScannerRowsArgs) String() string

func (*THBaseServiceGetScannerRowsArgs) Write 

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

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 (p *THBaseServiceGetScannerRowsResult) GetIa() *TIllegalArgument

func (*THBaseServiceGetScannerRowsResult) GetIo 

func (p *THBaseServiceGetScannerRowsResult) GetIo() *TIOError

func (*THBaseServiceGetScannerRowsResult) GetSuccess 

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

func (*THBaseServiceGetScannerRowsResult) IsSetIa 

func (p *THBaseServiceGetScannerRowsResult) IsSetIa() bool

func (*THBaseServiceGetScannerRowsResult) IsSetIo 

func (p *THBaseServiceGetScannerRowsResult) IsSetIo() bool

func (*THBaseServiceGetScannerRowsResult) IsSetSuccess 

func (p *THBaseServiceGetScannerRowsResult) IsSetSuccess() bool

func (*THBaseServiceGetScannerRowsResult) Read 

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

func (*THBaseServiceGetScannerRowsResult) ReadField0 

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

func (*THBaseServiceGetScannerRowsResult) ReadField1 

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

func (*THBaseServiceGetScannerRowsResult) ReadField2 

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

func (*THBaseServiceGetScannerRowsResult) String 

func (p *THBaseServiceGetScannerRowsResult) String() string

func (*THBaseServiceGetScannerRowsResult) Write 

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

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 (p *THBaseServiceGetTableDescriptorArgs) GetTable() *TTableName

func (*THBaseServiceGetTableDescriptorArgs) IsSetTable 

func (p *THBaseServiceGetTableDescriptorArgs) IsSetTable() bool

func (*THBaseServiceGetTableDescriptorArgs) Read 

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

func (*THBaseServiceGetTableDescriptorArgs) ReadField1 

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

func (*THBaseServiceGetTableDescriptorArgs) String 

func (p *THBaseServiceGetTableDescriptorArgs) String() string

func (*THBaseServiceGetTableDescriptorArgs) Write 

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

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 (p *THBaseServiceGetTableDescriptorResult) GetIo() *TIOError

func (*THBaseServiceGetTableDescriptorResult) GetSuccess 

func (p *THBaseServiceGetTableDescriptorResult) GetSuccess() *TTableDescriptor

func (*THBaseServiceGetTableDescriptorResult) IsSetIo 

func (p *THBaseServiceGetTableDescriptorResult) IsSetIo() bool

func (*THBaseServiceGetTableDescriptorResult) IsSetSuccess 

func (p *THBaseServiceGetTableDescriptorResult) IsSetSuccess() bool

func (*THBaseServiceGetTableDescriptorResult) Read 

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

func (*THBaseServiceGetTableDescriptorResult) ReadField0 

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

func (*THBaseServiceGetTableDescriptorResult) ReadField1 

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

func (*THBaseServiceGetTableDescriptorResult) String 

func (p *THBaseServiceGetTableDescriptorResult) String() string

func (*THBaseServiceGetTableDescriptorResult) Write 

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

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 (p *THBaseServiceGetTableDescriptorsArgs) GetTables() []*TTableName

func (*THBaseServiceGetTableDescriptorsArgs) Read 

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

func (*THBaseServiceGetTableDescriptorsArgs) ReadField1 

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

func (*THBaseServiceGetTableDescriptorsArgs) String 

func (p *THBaseServiceGetTableDescriptorsArgs) String() string

func (*THBaseServiceGetTableDescriptorsArgs) Write 

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

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 (p *THBaseServiceGetTableDescriptorsByNamespaceArgs) GetName() string

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) Read 

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

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) ReadField1 

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

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) String 

func (p *THBaseServiceGetTableDescriptorsByNamespaceArgs) String() string

func (*THBaseServiceGetTableDescriptorsByNamespaceArgs) Write 

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

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 (p *THBaseServiceGetTableDescriptorsByNamespaceResult) GetIo() *TIOError

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) GetSuccess 

func (p *THBaseServiceGetTableDescriptorsByNamespaceResult) GetSuccess() []*TTableDescriptor

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) IsSetIo 

func (p *THBaseServiceGetTableDescriptorsByNamespaceResult) IsSetIo() bool

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) IsSetSuccess 

func (p *THBaseServiceGetTableDescriptorsByNamespaceResult) IsSetSuccess() bool

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) Read 

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

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) ReadField0 

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

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) ReadField1 

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

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) String 

func (p *THBaseServiceGetTableDescriptorsByNamespaceResult) String() string

func (*THBaseServiceGetTableDescriptorsByNamespaceResult) Write 

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

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 (p *THBaseServiceGetTableDescriptorsByPatternArgs) GetRegex() string

func (*THBaseServiceGetTableDescriptorsByPatternArgs) Read 

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

func (*THBaseServiceGetTableDescriptorsByPatternArgs) ReadField1 

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

func (*THBaseServiceGetTableDescriptorsByPatternArgs) ReadField2 

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

func (*THBaseServiceGetTableDescriptorsByPatternArgs) String 

func (p *THBaseServiceGetTableDescriptorsByPatternArgs) String() string

func (*THBaseServiceGetTableDescriptorsByPatternArgs) Write 

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

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 (p *THBaseServiceGetTableDescriptorsByPatternResult) GetIo() *TIOError

func (*THBaseServiceGetTableDescriptorsByPatternResult) GetSuccess 

func (p *THBaseServiceGetTableDescriptorsByPatternResult) GetSuccess() []*TTableDescriptor

func (*THBaseServiceGetTableDescriptorsByPatternResult) IsSetIo 

func (p *THBaseServiceGetTableDescriptorsByPatternResult) IsSetIo() bool

func (*THBaseServiceGetTableDescriptorsByPatternResult) IsSetSuccess 

func (p *THBaseServiceGetTableDescriptorsByPatternResult) IsSetSuccess() bool

func (*THBaseServiceGetTableDescriptorsByPatternResult) Read 

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

func (*THBaseServiceGetTableDescriptorsByPatternResult) ReadField0 

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

func (*THBaseServiceGetTableDescriptorsByPatternResult) ReadField1 

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

func (*THBaseServiceGetTableDescriptorsByPatternResult) String 

func (p *THBaseServiceGetTableDescriptorsByPatternResult) String() string

func (*THBaseServiceGetTableDescriptorsByPatternResult) Write 

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

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 (p *THBaseServiceGetTableDescriptorsResult) GetIo() *TIOError

func (*THBaseServiceGetTableDescriptorsResult) GetSuccess 

func (p *THBaseServiceGetTableDescriptorsResult) GetSuccess() []*TTableDescriptor

func (*THBaseServiceGetTableDescriptorsResult) IsSetIo 

func (p *THBaseServiceGetTableDescriptorsResult) IsSetIo() bool

func (*THBaseServiceGetTableDescriptorsResult) IsSetSuccess 

func (p *THBaseServiceGetTableDescriptorsResult) IsSetSuccess() bool

func (*THBaseServiceGetTableDescriptorsResult) Read 

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

func (*THBaseServiceGetTableDescriptorsResult) ReadField0 

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

func (*THBaseServiceGetTableDescriptorsResult) ReadField1 

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

func (*THBaseServiceGetTableDescriptorsResult) String 

func (p *THBaseServiceGetTableDescriptorsResult) String() string

func (*THBaseServiceGetTableDescriptorsResult) Write 

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

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 (p *THBaseServiceGetTableNamesByNamespaceArgs) GetName() string

func (*THBaseServiceGetTableNamesByNamespaceArgs) Read 

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

func (*THBaseServiceGetTableNamesByNamespaceArgs) ReadField1 

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

func (*THBaseServiceGetTableNamesByNamespaceArgs) String 

func (p *THBaseServiceGetTableNamesByNamespaceArgs) String() string

func (*THBaseServiceGetTableNamesByNamespaceArgs) Write 

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

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 (p *THBaseServiceGetTableNamesByNamespaceResult) GetIo() *TIOError

func (*THBaseServiceGetTableNamesByNamespaceResult) GetSuccess 

func (p *THBaseServiceGetTableNamesByNamespaceResult) GetSuccess() []*TTableName

func (*THBaseServiceGetTableNamesByNamespaceResult) IsSetIo 

func (p *THBaseServiceGetTableNamesByNamespaceResult) IsSetIo() bool

func (*THBaseServiceGetTableNamesByNamespaceResult) IsSetSuccess 

func (p *THBaseServiceGetTableNamesByNamespaceResult) IsSetSuccess() bool

func (*THBaseServiceGetTableNamesByNamespaceResult) Read 

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

func (*THBaseServiceGetTableNamesByNamespaceResult) ReadField0 

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

func (*THBaseServiceGetTableNamesByNamespaceResult) ReadField1 

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

func (*THBaseServiceGetTableNamesByNamespaceResult) String 

func (p *THBaseServiceGetTableNamesByNamespaceResult) String() string

func (*THBaseServiceGetTableNamesByNamespaceResult) Write 

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

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 (p *THBaseServiceGetTableNamesByPatternArgs) GetRegex() string

func (*THBaseServiceGetTableNamesByPatternArgs) Read 

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

func (*THBaseServiceGetTableNamesByPatternArgs) ReadField1 

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

func (*THBaseServiceGetTableNamesByPatternArgs) ReadField2 

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

func (*THBaseServiceGetTableNamesByPatternArgs) String 

func (p *THBaseServiceGetTableNamesByPatternArgs) String() string

func (*THBaseServiceGetTableNamesByPatternArgs) Write 

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

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 (p *THBaseServiceGetTableNamesByPatternResult) GetIo() *TIOError

func (*THBaseServiceGetTableNamesByPatternResult) GetSuccess 

func (p *THBaseServiceGetTableNamesByPatternResult) GetSuccess() []*TTableName

func (*THBaseServiceGetTableNamesByPatternResult) IsSetIo 

func (p *THBaseServiceGetTableNamesByPatternResult) IsSetIo() bool

func (*THBaseServiceGetTableNamesByPatternResult) IsSetSuccess 

func (p *THBaseServiceGetTableNamesByPatternResult) IsSetSuccess() bool

func (*THBaseServiceGetTableNamesByPatternResult) Read 

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

func (*THBaseServiceGetTableNamesByPatternResult) ReadField0 

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

func (*THBaseServiceGetTableNamesByPatternResult) ReadField1 

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

func (*THBaseServiceGetTableNamesByPatternResult) String 

func (p *THBaseServiceGetTableNamesByPatternResult) String() string

func (*THBaseServiceGetTableNamesByPatternResult) Write 

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

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 (p *THBaseServiceIncrementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceIncrementResult) GetIo() *TIOError

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 (p *THBaseServiceIncrementResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceIncrementResult) ReadField0 

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

func (*THBaseServiceIncrementResult) ReadField1 

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

func (*THBaseServiceIncrementResult) String 

func (p *THBaseServiceIncrementResult) String() string

func (*THBaseServiceIncrementResult) Write 

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

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 (p *THBaseServiceIsTableAvailableArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceIsTableAvailableArgs) ReadField1 

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

func (*THBaseServiceIsTableAvailableArgs) String 

func (p *THBaseServiceIsTableAvailableArgs) String() string

func (*THBaseServiceIsTableAvailableArgs) Write 

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

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 (p *THBaseServiceIsTableAvailableResult) GetIo() *TIOError

func (*THBaseServiceIsTableAvailableResult) GetSuccess 

func (p *THBaseServiceIsTableAvailableResult) GetSuccess() bool

func (*THBaseServiceIsTableAvailableResult) IsSetIo 

func (p *THBaseServiceIsTableAvailableResult) IsSetIo() bool

func (*THBaseServiceIsTableAvailableResult) IsSetSuccess 

func (p *THBaseServiceIsTableAvailableResult) IsSetSuccess() bool

func (*THBaseServiceIsTableAvailableResult) Read 

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

func (*THBaseServiceIsTableAvailableResult) ReadField0 

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

func (*THBaseServiceIsTableAvailableResult) ReadField1 

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

func (*THBaseServiceIsTableAvailableResult) String 

func (p *THBaseServiceIsTableAvailableResult) String() string

func (*THBaseServiceIsTableAvailableResult) Write 

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

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 (p *THBaseServiceIsTableAvailableWithSplitArgs) GetTableName() *TTableName

func (*THBaseServiceIsTableAvailableWithSplitArgs) IsSetTableName 

func (p *THBaseServiceIsTableAvailableWithSplitArgs) IsSetTableName() bool

func (*THBaseServiceIsTableAvailableWithSplitArgs) Read 

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

func (*THBaseServiceIsTableAvailableWithSplitArgs) ReadField1 

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

func (*THBaseServiceIsTableAvailableWithSplitArgs) ReadField2 

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

func (*THBaseServiceIsTableAvailableWithSplitArgs) String 

func (p *THBaseServiceIsTableAvailableWithSplitArgs) String() string

func (*THBaseServiceIsTableAvailableWithSplitArgs) Write 

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

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 (p *THBaseServiceIsTableAvailableWithSplitResult) GetIo() *TIOError

func (*THBaseServiceIsTableAvailableWithSplitResult) GetSuccess 

func (p *THBaseServiceIsTableAvailableWithSplitResult) GetSuccess() bool

func (*THBaseServiceIsTableAvailableWithSplitResult) IsSetIo 

func (p *THBaseServiceIsTableAvailableWithSplitResult) IsSetIo() bool

func (*THBaseServiceIsTableAvailableWithSplitResult) IsSetSuccess 

func (p *THBaseServiceIsTableAvailableWithSplitResult) IsSetSuccess() bool

func (*THBaseServiceIsTableAvailableWithSplitResult) Read 

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

func (*THBaseServiceIsTableAvailableWithSplitResult) ReadField0 

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

func (*THBaseServiceIsTableAvailableWithSplitResult) ReadField1 

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

func (*THBaseServiceIsTableAvailableWithSplitResult) String 

func (p *THBaseServiceIsTableAvailableWithSplitResult) String() string

func (*THBaseServiceIsTableAvailableWithSplitResult) Write 

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

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 (p *THBaseServiceIsTableDisabledArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceIsTableDisabledArgs) ReadField1 

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

func (*THBaseServiceIsTableDisabledArgs) String 

func (p *THBaseServiceIsTableDisabledArgs) String() string

func (*THBaseServiceIsTableDisabledArgs) Write 

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

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 (p *THBaseServiceIsTableDisabledResult) GetIo() *TIOError

func (*THBaseServiceIsTableDisabledResult) GetSuccess 

func (p *THBaseServiceIsTableDisabledResult) GetSuccess() bool

func (*THBaseServiceIsTableDisabledResult) IsSetIo 

func (p *THBaseServiceIsTableDisabledResult) IsSetIo() bool

func (*THBaseServiceIsTableDisabledResult) IsSetSuccess 

func (p *THBaseServiceIsTableDisabledResult) IsSetSuccess() bool

func (*THBaseServiceIsTableDisabledResult) Read 

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

func (*THBaseServiceIsTableDisabledResult) ReadField0 

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

func (*THBaseServiceIsTableDisabledResult) ReadField1 

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

func (*THBaseServiceIsTableDisabledResult) String 

func (p *THBaseServiceIsTableDisabledResult) String() string

func (*THBaseServiceIsTableDisabledResult) Write 

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

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 (p *THBaseServiceIsTableEnabledArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceIsTableEnabledArgs) ReadField1 

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

func (*THBaseServiceIsTableEnabledArgs) String 

func (p *THBaseServiceIsTableEnabledArgs) String() string

func (*THBaseServiceIsTableEnabledArgs) Write 

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

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 (p *THBaseServiceIsTableEnabledResult) GetIo() *TIOError

func (*THBaseServiceIsTableEnabledResult) GetSuccess 

func (p *THBaseServiceIsTableEnabledResult) GetSuccess() bool

func (*THBaseServiceIsTableEnabledResult) IsSetIo 

func (p *THBaseServiceIsTableEnabledResult) IsSetIo() bool

func (*THBaseServiceIsTableEnabledResult) IsSetSuccess 

func (p *THBaseServiceIsTableEnabledResult) IsSetSuccess() bool

func (*THBaseServiceIsTableEnabledResult) Read 

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

func (*THBaseServiceIsTableEnabledResult) ReadField0 

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

func (*THBaseServiceIsTableEnabledResult) ReadField1 

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

func (*THBaseServiceIsTableEnabledResult) String 

func (p *THBaseServiceIsTableEnabledResult) String() string

func (*THBaseServiceIsTableEnabledResult) Write 

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

type THBaseServiceListNamespaceDescriptorsArgs 

type THBaseServiceListNamespaceDescriptorsArgs struct {
}

func NewTHBaseServiceListNamespaceDescriptorsArgs 

func NewTHBaseServiceListNamespaceDescriptorsArgs() *THBaseServiceListNamespaceDescriptorsArgs

func (*THBaseServiceListNamespaceDescriptorsArgs) Read 

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

func (*THBaseServiceListNamespaceDescriptorsArgs) String 

func (p *THBaseServiceListNamespaceDescriptorsArgs) String() string

func (*THBaseServiceListNamespaceDescriptorsArgs) Write 

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

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 (p *THBaseServiceListNamespaceDescriptorsResult) GetIo() *TIOError

func (*THBaseServiceListNamespaceDescriptorsResult) GetSuccess 

func (p *THBaseServiceListNamespaceDescriptorsResult) GetSuccess() []*TNamespaceDescriptor

func (*THBaseServiceListNamespaceDescriptorsResult) IsSetIo 

func (p *THBaseServiceListNamespaceDescriptorsResult) IsSetIo() bool

func (*THBaseServiceListNamespaceDescriptorsResult) IsSetSuccess 

func (p *THBaseServiceListNamespaceDescriptorsResult) IsSetSuccess() bool

func (*THBaseServiceListNamespaceDescriptorsResult) Read 

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

func (*THBaseServiceListNamespaceDescriptorsResult) ReadField0 

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

func (*THBaseServiceListNamespaceDescriptorsResult) ReadField1 

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

func (*THBaseServiceListNamespaceDescriptorsResult) String 

func (p *THBaseServiceListNamespaceDescriptorsResult) String() string

func (*THBaseServiceListNamespaceDescriptorsResult) Write 

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

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 (p *THBaseServiceModifyColumnFamilyArgs) GetColumn() *TColumnFamilyDescriptor

func (*THBaseServiceModifyColumnFamilyArgs) GetTableName 

func (p *THBaseServiceModifyColumnFamilyArgs) GetTableName() *TTableName

func (*THBaseServiceModifyColumnFamilyArgs) IsSetColumn 

func (p *THBaseServiceModifyColumnFamilyArgs) IsSetColumn() bool

func (*THBaseServiceModifyColumnFamilyArgs) IsSetTableName 

func (p *THBaseServiceModifyColumnFamilyArgs) IsSetTableName() bool

func (*THBaseServiceModifyColumnFamilyArgs) Read 

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

func (*THBaseServiceModifyColumnFamilyArgs) ReadField1 

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

func (*THBaseServiceModifyColumnFamilyArgs) ReadField2 

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

func (*THBaseServiceModifyColumnFamilyArgs) String 

func (p *THBaseServiceModifyColumnFamilyArgs) String() string

func (*THBaseServiceModifyColumnFamilyArgs) Write 

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

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 (p *THBaseServiceModifyColumnFamilyResult) GetIo() *TIOError

func (*THBaseServiceModifyColumnFamilyResult) IsSetIo 

func (p *THBaseServiceModifyColumnFamilyResult) IsSetIo() bool

func (*THBaseServiceModifyColumnFamilyResult) Read 

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

func (*THBaseServiceModifyColumnFamilyResult) ReadField1 

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

func (*THBaseServiceModifyColumnFamilyResult) String 

func (p *THBaseServiceModifyColumnFamilyResult) String() string

func (*THBaseServiceModifyColumnFamilyResult) Write 

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

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 (p *THBaseServiceModifyNamespaceArgs) GetNamespaceDesc() *TNamespaceDescriptor

func (*THBaseServiceModifyNamespaceArgs) IsSetNamespaceDesc 

func (p *THBaseServiceModifyNamespaceArgs) IsSetNamespaceDesc() bool

func (*THBaseServiceModifyNamespaceArgs) Read 

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

func (*THBaseServiceModifyNamespaceArgs) ReadField1 

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

func (*THBaseServiceModifyNamespaceArgs) String 

func (p *THBaseServiceModifyNamespaceArgs) String() string

func (*THBaseServiceModifyNamespaceArgs) Write 

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

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 (p *THBaseServiceModifyNamespaceResult) GetIo() *TIOError

func (*THBaseServiceModifyNamespaceResult) IsSetIo 

func (p *THBaseServiceModifyNamespaceResult) IsSetIo() bool

func (*THBaseServiceModifyNamespaceResult) Read 

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

func (*THBaseServiceModifyNamespaceResult) ReadField1 

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

func (*THBaseServiceModifyNamespaceResult) String 

func (p *THBaseServiceModifyNamespaceResult) String() string

func (*THBaseServiceModifyNamespaceResult) Write 

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

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 (p *THBaseServiceModifyTableArgs) GetDesc() *TTableDescriptor

func (*THBaseServiceModifyTableArgs) IsSetDesc 

func (p *THBaseServiceModifyTableArgs) IsSetDesc() bool

func (*THBaseServiceModifyTableArgs) Read 

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

func (*THBaseServiceModifyTableArgs) ReadField1 

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

func (*THBaseServiceModifyTableArgs) String 

func (p *THBaseServiceModifyTableArgs) String() string

func (*THBaseServiceModifyTableArgs) Write 

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

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 (p *THBaseServiceModifyTableResult) GetIo() *TIOError

func (*THBaseServiceModifyTableResult) IsSetIo 

func (p *THBaseServiceModifyTableResult) IsSetIo() bool

func (*THBaseServiceModifyTableResult) Read 

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

func (*THBaseServiceModifyTableResult) ReadField1 

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

func (*THBaseServiceModifyTableResult) String 

func (p *THBaseServiceModifyTableResult) String() string

func (*THBaseServiceModifyTableResult) Write 

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

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 (p *THBaseServiceMutateRowArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceMutateRowResult) GetIo() *TIOError

func (*THBaseServiceMutateRowResult) IsSetIo 

func (p *THBaseServiceMutateRowResult) IsSetIo() bool

func (*THBaseServiceMutateRowResult) Read 

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

func (*THBaseServiceMutateRowResult) ReadField1 

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

func (*THBaseServiceMutateRowResult) String 

func (p *THBaseServiceMutateRowResult) String() string

func (*THBaseServiceMutateRowResult) Write 

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

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 (p *THBaseServiceOpenScannerArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceOpenScannerArgs) ReadField1 

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

func (*THBaseServiceOpenScannerArgs) ReadField2 

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

func (*THBaseServiceOpenScannerArgs) String 

func (p *THBaseServiceOpenScannerArgs) String() string

func (*THBaseServiceOpenScannerArgs) Write 

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

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 (p *THBaseServiceOpenScannerResult) GetIo() *TIOError

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 (p *THBaseServiceOpenScannerResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceOpenScannerResult) ReadField0 

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

func (*THBaseServiceOpenScannerResult) ReadField1 

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

func (*THBaseServiceOpenScannerResult) String 

func (p *THBaseServiceOpenScannerResult) String() string

func (*THBaseServiceOpenScannerResult) Write 

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

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 

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

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 (p *THBaseServicePutArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServicePutMultipleArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServicePutMultipleArgs) ReadField1 

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

func (*THBaseServicePutMultipleArgs) ReadField2 

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

func (*THBaseServicePutMultipleArgs) String 

func (p *THBaseServicePutMultipleArgs) String() string

func (*THBaseServicePutMultipleArgs) Write 

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

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 (p *THBaseServicePutMultipleResult) GetIo() *TIOError

func (*THBaseServicePutMultipleResult) IsSetIo 

func (p *THBaseServicePutMultipleResult) IsSetIo() bool

func (*THBaseServicePutMultipleResult) Read 

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

func (*THBaseServicePutMultipleResult) ReadField1 

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

func (*THBaseServicePutMultipleResult) String 

func (p *THBaseServicePutMultipleResult) String() string

func (*THBaseServicePutMultipleResult) Write 

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

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 (p *THBaseServicePutResult) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *THBaseServiceTableExistsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceTableExistsArgs) ReadField1 

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

func (*THBaseServiceTableExistsArgs) String 

func (p *THBaseServiceTableExistsArgs) String() string

func (*THBaseServiceTableExistsArgs) Write 

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

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 (p *THBaseServiceTableExistsResult) GetIo() *TIOError

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 (p *THBaseServiceTableExistsResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceTableExistsResult) ReadField0 

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

func (*THBaseServiceTableExistsResult) ReadField1 

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

func (*THBaseServiceTableExistsResult) String 

func (p *THBaseServiceTableExistsResult) String() string

func (*THBaseServiceTableExistsResult) Write 

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

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 (p *THBaseServiceTruncateTableArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*THBaseServiceTruncateTableArgs) ReadField1 

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

func (*THBaseServiceTruncateTableArgs) ReadField2 

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

func (*THBaseServiceTruncateTableArgs) String 

func (p *THBaseServiceTruncateTableArgs) String() string

func (*THBaseServiceTruncateTableArgs) Write 

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

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 (p *THBaseServiceTruncateTableResult) GetIo() *TIOError

func (*THBaseServiceTruncateTableResult) IsSetIo 

func (p *THBaseServiceTruncateTableResult) IsSetIo() bool

func (*THBaseServiceTruncateTableResult) Read 

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

func (*THBaseServiceTruncateTableResult) ReadField1 

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

func (*THBaseServiceTruncateTableResult) String 

func (p *THBaseServiceTruncateTableResult) String() string

func (*THBaseServiceTruncateTableResult) Write 

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

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"`
}

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
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 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 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 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 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 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) GetMessage 

func (p *TIOError) GetMessage() string

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) 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 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 (p *TNamespaceDescriptor) Equals(other *TNamespaceDescriptor) bool

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 (p *TNamespaceDescriptor) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

func (p *TNamespaceDescriptor) Write(ctx context.Context, oprot thrift.TProtocol) 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 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.