hbase

package
v1.3.2 Latest Latest
Warning

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

 Go to latest Published: May 6, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var HbasePool *pool.ObjectPool
View Source 
var TAppend_Attributes_DEFAULT map[string][]byte
View Source 
var TAuthorization_Labels_DEFAULT []string
View Source 
var TCellVisibility_Expression_DEFAULT string
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 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_Columns_DEFAULT []*TColumn
View Source 
var TGet_FilterString_DEFAULT []byte
View Source 
var TGet_MaxVersions_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 THBaseServiceOpenScannerResult_Success_DEFAULT int32
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 TPut_Attributes_DEFAULT map[string][]byte
View Source 
var TPut_Timestamp_DEFAULT int64
View Source 
var TResult__Row_DEFAULT []byte
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_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 TServerName_Port_DEFAULT int32
View Source 
var TServerName_StartCode_DEFAULT int64

Functions

func NewHbase 

func NewHbase() error

Types

type RpcHbaseClient 

type RpcHbaseClient struct{}
var HbaseClinet *RpcHbaseClient

func (RpcHbaseClient) Delete 

func (h RpcHbaseClient) Delete(table string, tdelete *TDelete) (err error)

func (RpcHbaseClient) Exists 

func (h RpcHbaseClient) Exists(table string, tget *TGet) (r bool, err error)

func (RpcHbaseClient) Get 

func (h RpcHbaseClient) Get(table string, tget *TGet) (r *TResult_, err error)

func (RpcHbaseClient) Put 

func (h RpcHbaseClient) Put(table string, tput *TPut) (err error)

type TAppend 

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

Attributes:

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

func NewTAppend 

func NewTAppend() *TAppend

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

func (p *TAppend) Read(iprot thrift.TProtocol) error

func (*TAppend) String 

func (p *TAppend) String() string

func (*TAppend) Write 

func (p *TAppend) Write(oprot thrift.TProtocol) error

type TAuthorization 

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

Attributes:

  • Labels
var TGet_Authorizations_DEFAULT *TAuthorization
var TScan_Authorizations_DEFAULT *TAuthorization

func NewTAuthorization 

func NewTAuthorization() *TAuthorization

func (*TAuthorization) GetLabels 

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

func (*TAuthorization) IsSetLabels 

func (p *TAuthorization) IsSetLabels() bool

func (*TAuthorization) Read 

func (p *TAuthorization) Read(iprot thrift.TProtocol) error

func (*TAuthorization) String 

func (p *TAuthorization) String() string

func (*TAuthorization) Write 

func (p *TAuthorization) Write(oprot thrift.TProtocol) error

type TCellVisibility 

type TCellVisibility struct {
	Expression *string `thrift:"expression,1" 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) GetExpression 

func (p *TCellVisibility) GetExpression() string

func (*TCellVisibility) IsSetExpression 

func (p *TCellVisibility) IsSetExpression() bool

func (*TCellVisibility) Read 

func (p *TCellVisibility) Read(iprot thrift.TProtocol) error

func (*TCellVisibility) String 

func (p *TCellVisibility) String() string

func (*TCellVisibility) Write 

func (p *TCellVisibility) Write(oprot thrift.TProtocol) error

type TColumn 

type TColumn struct {
	Family    []byte `thrift:"family,1,required" json:"family"`
	Qualifier []byte `thrift:"qualifier,2" json:"qualifier,omitempty"`
	Timestamp *int64 `thrift:"timestamp,3" 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) 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(iprot thrift.TProtocol) error

func (*TColumn) String 

func (p *TColumn) String() string

func (*TColumn) Write 

func (p *TColumn) Write(oprot thrift.TProtocol) error

type TColumnIncrement 

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

Represents a single cell and the amount to increment it by

Attributes:

  • Family
  • Qualifier
  • Amount

func NewTColumnIncrement 

func NewTColumnIncrement() *TColumnIncrement

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(iprot thrift.TProtocol) error

func (*TColumnIncrement) String 

func (p *TColumnIncrement) String() string

func (*TColumnIncrement) Write 

func (p *TColumnIncrement) Write(oprot thrift.TProtocol) error

type TColumnValue 

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

Represents a single cell and its value.

Attributes:

  • Family
  • Qualifier
  • Value
  • Timestamp
  • Tags

func NewTColumnValue 

func NewTColumnValue() *TColumnValue

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

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

func (*TColumnValue) IsSetTags 

func (p *TColumnValue) IsSetTags() bool

func (*TColumnValue) IsSetTimestamp 

func (p *TColumnValue) IsSetTimestamp() bool

func (*TColumnValue) Read 

func (p *TColumnValue) Read(iprot thrift.TProtocol) error

func (*TColumnValue) String 

func (p *TColumnValue) String() string

func (*TColumnValue) Write 

func (p *TColumnValue) Write(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) String 

func (p TCompareOp) String() string

func (*TCompareOp) UnmarshalText 

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

type TDelete 

type TDelete struct {
	Row        []byte      `thrift:"row,1,required" json:"row"`
	Columns    []*TColumn  `thrift:"columns,2" json:"columns,omitempty"`
	Timestamp  *int64      `thrift:"timestamp,3" json:"timestamp,omitempty"`
	DeleteType TDeleteType `thrift:"deleteType,4" json:"deleteType,omitempty"`
	// unused field # 5
	Attributes map[string][]byte `thrift:"attributes,6" json:"attributes,omitempty"`
	Durability *TDurability      `thrift:"durability,7" 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) 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(iprot thrift.TProtocol) error

func (*TDelete) String 

func (p *TDelete) String() string

func (*TDelete) Write 

func (p *TDelete) Write(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) String 

func (p TDeleteType) String() string

func (*TDeleteType) UnmarshalText 

func (p *TDeleteType) UnmarshalText(text []byte) 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_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

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

func (p TDurability) String() string

func (*TDurability) UnmarshalText 

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

type TGet 

type TGet struct {
	Row            []byte            `thrift:"row,1,required" json:"row"`
	Columns        []*TColumn        `thrift:"columns,2" json:"columns,omitempty"`
	Timestamp      *int64            `thrift:"timestamp,3" json:"timestamp,omitempty"`
	TimeRange      *TTimeRange       `thrift:"timeRange,4" json:"timeRange,omitempty"`
	MaxVersions    *int32            `thrift:"maxVersions,5" json:"maxVersions,omitempty"`
	FilterString   []byte            `thrift:"filterString,6" json:"filterString,omitempty"`
	Attributes     map[string][]byte `thrift:"attributes,7" json:"attributes,omitempty"`
	Authorizations *TAuthorization   `thrift:"authorizations,8" json:"authorizations,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
var THBaseServiceExistsArgs_Tget_DEFAULT *TGet
var THBaseServiceGetArgs_Tget_DEFAULT *TGet

func NewTGet 

func NewTGet() *TGet

func (*TGet) GetAttributes 

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

func (*TGet) GetAuthorizations 

func (p *TGet) GetAuthorizations() *TAuthorization

func (*TGet) GetColumns 

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

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

func (p *TGet) IsSetColumns() bool

func (*TGet) IsSetFilterString 

func (p *TGet) IsSetFilterString() bool

func (*TGet) IsSetMaxVersions 

func (p *TGet) IsSetMaxVersions() bool

func (*TGet) IsSetTimeRange 

func (p *TGet) IsSetTimeRange() bool

func (*TGet) IsSetTimestamp 

func (p *TGet) IsSetTimestamp() bool

func (*TGet) Read 

func (p *TGet) Read(iprot thrift.TProtocol) error

func (*TGet) String 

func (p *TGet) String() string

func (*TGet) Write 

func (p *TGet) Write(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(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(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(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(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(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(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(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(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(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(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(table []byte, tincrement *TIncrement) (r *TResult_, err error)
	// Parameters:
	//  - Table: the table to append the value on
	//  - Tappend: the TAppend to append
	Append(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(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(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(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(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(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(table []byte, row []byte, reload bool) (r *THRegionLocation, err error)
	// Get all of the region locations for a given table.
	//
	//
	// Parameters:
	//  - Table
	GetAllRegionLocations(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(table []byte, row []byte, family []byte, qualifier []byte, compareOp TCompareOp, value []byte, rowMutations *TRowMutations) (r bool, err error)
}

type THBaseServiceAppendArgs 

type THBaseServiceAppendArgs struct {
	Table   []byte   `thrift:"table,1,required" json:"table"`
	Tappend *TAppend `thrift:"tappend,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceAppendArgs) String 

func (p *THBaseServiceAppendArgs) String() string

func (*THBaseServiceAppendArgs) Write 

func (p *THBaseServiceAppendArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceAppendResult 

type THBaseServiceAppendResult struct {
	Success *TResult_ `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceAppendResult) String 

func (p *THBaseServiceAppendResult) String() string

func (*THBaseServiceAppendResult) Write 

func (p *THBaseServiceAppendResult) Write(oprot thrift.TProtocol) error

type THBaseServiceCheckAndDeleteArgs 

type THBaseServiceCheckAndDeleteArgs struct {
	Table     []byte   `thrift:"table,1,required" json:"table"`
	Row       []byte   `thrift:"row,2,required" json:"row"`
	Family    []byte   `thrift:"family,3,required" json:"family"`
	Qualifier []byte   `thrift:"qualifier,4,required" json:"qualifier"`
	Value     []byte   `thrift:"value,5" json:"value"`
	Tdelete   *TDelete `thrift:"tdelete,6,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndDeleteArgs) String 

func (p *THBaseServiceCheckAndDeleteArgs) String() string

func (*THBaseServiceCheckAndDeleteArgs) Write 

func (p *THBaseServiceCheckAndDeleteArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceCheckAndDeleteResult 

type THBaseServiceCheckAndDeleteResult struct {
	Success *bool     `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndDeleteResult) String 

func (p *THBaseServiceCheckAndDeleteResult) String() string

func (*THBaseServiceCheckAndDeleteResult) Write 

func (p *THBaseServiceCheckAndDeleteResult) Write(oprot thrift.TProtocol) error

type THBaseServiceCheckAndMutateArgs 

type THBaseServiceCheckAndMutateArgs struct {
	Table        []byte         `thrift:"table,1,required" json:"table"`
	Row          []byte         `thrift:"row,2,required" json:"row"`
	Family       []byte         `thrift:"family,3,required" json:"family"`
	Qualifier    []byte         `thrift:"qualifier,4,required" json:"qualifier"`
	CompareOp    TCompareOp     `thrift:"compareOp,5,required" json:"compareOp"`
	Value        []byte         `thrift:"value,6" json:"value"`
	RowMutations *TRowMutations `thrift:"rowMutations,7,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndMutateArgs) String 

func (p *THBaseServiceCheckAndMutateArgs) String() string

func (*THBaseServiceCheckAndMutateArgs) Write 

func (p *THBaseServiceCheckAndMutateArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceCheckAndMutateResult 

type THBaseServiceCheckAndMutateResult struct {
	Success *bool     `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndMutateResult) String 

func (p *THBaseServiceCheckAndMutateResult) String() string

func (*THBaseServiceCheckAndMutateResult) Write 

func (p *THBaseServiceCheckAndMutateResult) Write(oprot thrift.TProtocol) error

type THBaseServiceCheckAndPutArgs 

type THBaseServiceCheckAndPutArgs struct {
	Table     []byte `thrift:"table,1,required" json:"table"`
	Row       []byte `thrift:"row,2,required" json:"row"`
	Family    []byte `thrift:"family,3,required" json:"family"`
	Qualifier []byte `thrift:"qualifier,4,required" json:"qualifier"`
	Value     []byte `thrift:"value,5" json:"value"`
	Tput      *TPut  `thrift:"tput,6,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndPutArgs) String 

func (p *THBaseServiceCheckAndPutArgs) String() string

func (*THBaseServiceCheckAndPutArgs) Write 

func (p *THBaseServiceCheckAndPutArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceCheckAndPutResult 

type THBaseServiceCheckAndPutResult struct {
	Success *bool     `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCheckAndPutResult) String 

func (p *THBaseServiceCheckAndPutResult) String() string

func (*THBaseServiceCheckAndPutResult) Write 

func (p *THBaseServiceCheckAndPutResult) Write(oprot thrift.TProtocol) error

type THBaseServiceClient 

type THBaseServiceClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func LinkHbase 

func LinkHbase() (*THBaseServiceClient, error)

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

func (p *THBaseServiceClient) Append(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(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(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(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) CloseScanner 

func (p *THBaseServiceClient) CloseScanner(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) DeleteMultiple 

func (p *THBaseServiceClient) DeleteMultiple(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) DeleteSingle 

func (p *THBaseServiceClient) DeleteSingle(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) Exists 

func (p *THBaseServiceClient) Exists(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(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(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(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(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) GetRegionLocation 

func (p *THBaseServiceClient) GetRegionLocation(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(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(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) Increment 

func (p *THBaseServiceClient) Increment(table []byte, tincrement *TIncrement) (r *TResult_, err error)

Parameters:

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

func (*THBaseServiceClient) MutateRow 

func (p *THBaseServiceClient) MutateRow(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(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(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(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

type THBaseServiceCloseScannerArgs 

type THBaseServiceCloseScannerArgs struct {
	ScannerId int32 `thrift:"scannerId,1,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCloseScannerArgs) String 

func (p *THBaseServiceCloseScannerArgs) String() string

func (*THBaseServiceCloseScannerArgs) Write 

func (p *THBaseServiceCloseScannerArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceCloseScannerResult 

type THBaseServiceCloseScannerResult struct {
	Io *TIOError         `thrift:"io,1" json:"io,omitempty"`
	Ia *TIllegalArgument `thrift:"ia,2" 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(iprot thrift.TProtocol) error

func (*THBaseServiceCloseScannerResult) String 

func (p *THBaseServiceCloseScannerResult) String() string

func (*THBaseServiceCloseScannerResult) Write 

func (p *THBaseServiceCloseScannerResult) Write(oprot thrift.TProtocol) error

type THBaseServiceDeleteMultipleArgs 

type THBaseServiceDeleteMultipleArgs struct {
	Table    []byte     `thrift:"table,1,required" json:"table"`
	Tdeletes []*TDelete `thrift:"tdeletes,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceDeleteMultipleArgs) String 

func (p *THBaseServiceDeleteMultipleArgs) String() string

func (*THBaseServiceDeleteMultipleArgs) Write 

func (p *THBaseServiceDeleteMultipleArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceDeleteMultipleResult 

type THBaseServiceDeleteMultipleResult struct {
	Success []*TDelete `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError  `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceDeleteMultipleResult) String 

func (p *THBaseServiceDeleteMultipleResult) String() string

func (*THBaseServiceDeleteMultipleResult) Write 

func (p *THBaseServiceDeleteMultipleResult) Write(oprot thrift.TProtocol) error

type THBaseServiceDeleteSingleArgs 

type THBaseServiceDeleteSingleArgs struct {
	Table   []byte   `thrift:"table,1,required" json:"table"`
	Tdelete *TDelete `thrift:"tdelete,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceDeleteSingleArgs) String 

func (p *THBaseServiceDeleteSingleArgs) String() string

func (*THBaseServiceDeleteSingleArgs) Write 

func (p *THBaseServiceDeleteSingleArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceDeleteSingleResult 

type THBaseServiceDeleteSingleResult struct {
	Io *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceDeleteSingleResult) String 

func (p *THBaseServiceDeleteSingleResult) String() string

func (*THBaseServiceDeleteSingleResult) Write 

func (p *THBaseServiceDeleteSingleResult) Write(oprot thrift.TProtocol) error

type THBaseServiceExistsAllArgs 

type THBaseServiceExistsAllArgs struct {
	Table []byte  `thrift:"table,1,required" json:"table"`
	Tgets []*TGet `thrift:"tgets,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceExistsAllArgs) String 

func (p *THBaseServiceExistsAllArgs) String() string

func (*THBaseServiceExistsAllArgs) Write 

func (p *THBaseServiceExistsAllArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceExistsAllResult 

type THBaseServiceExistsAllResult struct {
	Success []bool    `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceExistsAllResult) String 

func (p *THBaseServiceExistsAllResult) String() string

func (*THBaseServiceExistsAllResult) Write 

func (p *THBaseServiceExistsAllResult) Write(oprot thrift.TProtocol) error

type THBaseServiceExistsArgs 

type THBaseServiceExistsArgs struct {
	Table []byte `thrift:"table,1,required" json:"table"`
	Tget  *TGet  `thrift:"tget,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceExistsArgs) String 

func (p *THBaseServiceExistsArgs) String() string

func (*THBaseServiceExistsArgs) Write 

func (p *THBaseServiceExistsArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceExistsResult 

type THBaseServiceExistsResult struct {
	Success *bool     `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceExistsResult) String 

func (p *THBaseServiceExistsResult) String() string

func (*THBaseServiceExistsResult) Write 

func (p *THBaseServiceExistsResult) Write(oprot thrift.TProtocol) error

type THBaseServiceGetAllRegionLocationsArgs 

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

Attributes:

  • Table

func NewTHBaseServiceGetAllRegionLocationsArgs 

func NewTHBaseServiceGetAllRegionLocationsArgs() *THBaseServiceGetAllRegionLocationsArgs

func (*THBaseServiceGetAllRegionLocationsArgs) GetTable 

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

func (*THBaseServiceGetAllRegionLocationsArgs) Read 

func (p *THBaseServiceGetAllRegionLocationsArgs) Read(iprot thrift.TProtocol) error

func (*THBaseServiceGetAllRegionLocationsArgs) String 

func (p *THBaseServiceGetAllRegionLocationsArgs) String() string

func (*THBaseServiceGetAllRegionLocationsArgs) Write 

func (p *THBaseServiceGetAllRegionLocationsArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceGetAllRegionLocationsResult 

type THBaseServiceGetAllRegionLocationsResult struct {
	Success []*THRegionLocation `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError           `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetAllRegionLocationsResult) String 

func (p *THBaseServiceGetAllRegionLocationsResult) String() string

func (*THBaseServiceGetAllRegionLocationsResult) Write 

func (p *THBaseServiceGetAllRegionLocationsResult) Write(oprot thrift.TProtocol) error

type THBaseServiceGetArgs 

type THBaseServiceGetArgs struct {
	Table []byte `thrift:"table,1,required" json:"table"`
	Tget  *TGet  `thrift:"tget,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetArgs) String 

func (p *THBaseServiceGetArgs) String() string

func (*THBaseServiceGetArgs) Write 

func (p *THBaseServiceGetArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceGetMultipleArgs 

type THBaseServiceGetMultipleArgs struct {
	Table []byte  `thrift:"table,1,required" json:"table"`
	Tgets []*TGet `thrift:"tgets,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetMultipleArgs) String 

func (p *THBaseServiceGetMultipleArgs) String() string

func (*THBaseServiceGetMultipleArgs) Write 

func (p *THBaseServiceGetMultipleArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceGetMultipleResult 

type THBaseServiceGetMultipleResult struct {
	Success []*TResult_ `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError   `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetMultipleResult) String 

func (p *THBaseServiceGetMultipleResult) String() string

func (*THBaseServiceGetMultipleResult) Write 

func (p *THBaseServiceGetMultipleResult) Write(oprot thrift.TProtocol) error

type THBaseServiceGetRegionLocationArgs 

type THBaseServiceGetRegionLocationArgs struct {
	Table  []byte `thrift:"table,1,required" json:"table"`
	Row    []byte `thrift:"row,2,required" json:"row"`
	Reload bool   `thrift:"reload,3" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetRegionLocationArgs) String 

func (p *THBaseServiceGetRegionLocationArgs) String() string

func (*THBaseServiceGetRegionLocationArgs) Write 

func (p *THBaseServiceGetRegionLocationArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceGetRegionLocationResult 

type THBaseServiceGetRegionLocationResult struct {
	Success *THRegionLocation `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError         `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetRegionLocationResult) String 

func (p *THBaseServiceGetRegionLocationResult) String() string

func (*THBaseServiceGetRegionLocationResult) Write 

func (p *THBaseServiceGetRegionLocationResult) Write(oprot thrift.TProtocol) error

type THBaseServiceGetResult 

type THBaseServiceGetResult struct {
	Success *TResult_ `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetResult) String 

func (p *THBaseServiceGetResult) String() string

func (*THBaseServiceGetResult) Write 

func (p *THBaseServiceGetResult) Write(oprot thrift.TProtocol) error

type THBaseServiceGetScannerResultsArgs 

type THBaseServiceGetScannerResultsArgs struct {
	Table   []byte `thrift:"table,1,required" json:"table"`
	Tscan   *TScan `thrift:"tscan,2,required" json:"tscan"`
	NumRows int32  `thrift:"numRows,3" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetScannerResultsArgs) String 

func (p *THBaseServiceGetScannerResultsArgs) String() string

func (*THBaseServiceGetScannerResultsArgs) Write 

func (p *THBaseServiceGetScannerResultsArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceGetScannerResultsResult 

type THBaseServiceGetScannerResultsResult struct {
	Success []*TResult_ `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError   `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetScannerResultsResult) String 

func (p *THBaseServiceGetScannerResultsResult) String() string

func (*THBaseServiceGetScannerResultsResult) Write 

func (p *THBaseServiceGetScannerResultsResult) Write(oprot thrift.TProtocol) error

type THBaseServiceGetScannerRowsArgs 

type THBaseServiceGetScannerRowsArgs struct {
	ScannerId int32 `thrift:"scannerId,1,required" json:"scannerId"`
	NumRows   int32 `thrift:"numRows,2" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetScannerRowsArgs) String 

func (p *THBaseServiceGetScannerRowsArgs) String() string

func (*THBaseServiceGetScannerRowsArgs) Write 

func (p *THBaseServiceGetScannerRowsArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceGetScannerRowsResult 

type THBaseServiceGetScannerRowsResult struct {
	Success []*TResult_       `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError         `thrift:"io,1" json:"io,omitempty"`
	Ia      *TIllegalArgument `thrift:"ia,2" 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(iprot thrift.TProtocol) error

func (*THBaseServiceGetScannerRowsResult) String 

func (p *THBaseServiceGetScannerRowsResult) String() string

func (*THBaseServiceGetScannerRowsResult) Write 

func (p *THBaseServiceGetScannerRowsResult) Write(oprot thrift.TProtocol) error

type THBaseServiceIncrementArgs 

type THBaseServiceIncrementArgs struct {
	Table      []byte      `thrift:"table,1,required" json:"table"`
	Tincrement *TIncrement `thrift:"tincrement,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceIncrementArgs) String 

func (p *THBaseServiceIncrementArgs) String() string

func (*THBaseServiceIncrementArgs) Write 

func (p *THBaseServiceIncrementArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceIncrementResult 

type THBaseServiceIncrementResult struct {
	Success *TResult_ `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceIncrementResult) String 

func (p *THBaseServiceIncrementResult) String() string

func (*THBaseServiceIncrementResult) Write 

func (p *THBaseServiceIncrementResult) Write(oprot thrift.TProtocol) error

type THBaseServiceMutateRowArgs 

type THBaseServiceMutateRowArgs struct {
	Table         []byte         `thrift:"table,1,required" json:"table"`
	TrowMutations *TRowMutations `thrift:"trowMutations,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceMutateRowArgs) String 

func (p *THBaseServiceMutateRowArgs) String() string

func (*THBaseServiceMutateRowArgs) Write 

func (p *THBaseServiceMutateRowArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceMutateRowResult 

type THBaseServiceMutateRowResult struct {
	Io *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceMutateRowResult) String 

func (p *THBaseServiceMutateRowResult) String() string

func (*THBaseServiceMutateRowResult) Write 

func (p *THBaseServiceMutateRowResult) Write(oprot thrift.TProtocol) error

type THBaseServiceOpenScannerArgs 

type THBaseServiceOpenScannerArgs struct {
	Table []byte `thrift:"table,1,required" json:"table"`
	Tscan *TScan `thrift:"tscan,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServiceOpenScannerArgs) String 

func (p *THBaseServiceOpenScannerArgs) String() string

func (*THBaseServiceOpenScannerArgs) Write 

func (p *THBaseServiceOpenScannerArgs) Write(oprot thrift.TProtocol) error

type THBaseServiceOpenScannerResult 

type THBaseServiceOpenScannerResult struct {
	Success *int32    `thrift:"success,0" json:"success,omitempty"`
	Io      *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServiceOpenScannerResult) String 

func (p *THBaseServiceOpenScannerResult) String() string

func (*THBaseServiceOpenScannerResult) Write 

func (p *THBaseServiceOpenScannerResult) Write(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(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" json:"table"`
	Tput  *TPut  `thrift:"tput,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServicePutArgs) String 

func (p *THBaseServicePutArgs) String() string

func (*THBaseServicePutArgs) Write 

func (p *THBaseServicePutArgs) Write(oprot thrift.TProtocol) error

type THBaseServicePutMultipleArgs 

type THBaseServicePutMultipleArgs struct {
	Table []byte  `thrift:"table,1,required" json:"table"`
	Tputs []*TPut `thrift:"tputs,2,required" 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(iprot thrift.TProtocol) error

func (*THBaseServicePutMultipleArgs) String 

func (p *THBaseServicePutMultipleArgs) String() string

func (*THBaseServicePutMultipleArgs) Write 

func (p *THBaseServicePutMultipleArgs) Write(oprot thrift.TProtocol) error

type THBaseServicePutMultipleResult 

type THBaseServicePutMultipleResult struct {
	Io *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServicePutMultipleResult) String 

func (p *THBaseServicePutMultipleResult) String() string

func (*THBaseServicePutMultipleResult) Write 

func (p *THBaseServicePutMultipleResult) Write(oprot thrift.TProtocol) error

type THBaseServicePutResult 

type THBaseServicePutResult struct {
	Io *TIOError `thrift:"io,1" 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(iprot thrift.TProtocol) error

func (*THBaseServicePutResult) String 

func (p *THBaseServicePutResult) String() string

func (*THBaseServicePutResult) Write 

func (p *THBaseServicePutResult) Write(oprot thrift.TProtocol) error

type THRegionInfo 

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

Attributes:

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

func NewTHRegionInfo 

func NewTHRegionInfo() *THRegionInfo

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(iprot thrift.TProtocol) error

func (*THRegionInfo) String 

func (p *THRegionInfo) String() string

func (*THRegionInfo) Write 

func (p *THRegionInfo) Write(oprot thrift.TProtocol) error

type THRegionLocation 

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

Attributes:

  • ServerName
  • RegionInfo
var THBaseServiceGetRegionLocationResult_Success_DEFAULT *THRegionLocation

func NewTHRegionLocation 

func NewTHRegionLocation() *THRegionLocation

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(iprot thrift.TProtocol) error

func (*THRegionLocation) String 

func (p *THRegionLocation) String() string

func (*THRegionLocation) Write 

func (p *THRegionLocation) Write(oprot thrift.TProtocol) error

type TIOError 

type TIOError struct {
	Message *string `thrift:"message,1" 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 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 THBaseServiceDeleteMultipleResult_Io_DEFAULT *TIOError
var THBaseServiceDeleteSingleResult_Io_DEFAULT *TIOError
var THBaseServiceExistsAllResult_Io_DEFAULT *TIOError
var THBaseServiceExistsResult_Io_DEFAULT *TIOError
var THBaseServiceGetAllRegionLocationsResult_Io_DEFAULT *TIOError
var THBaseServiceGetMultipleResult_Io_DEFAULT *TIOError
var THBaseServiceGetRegionLocationResult_Io_DEFAULT *TIOError
var THBaseServiceGetResult_Io_DEFAULT *TIOError
var THBaseServiceGetScannerResultsResult_Io_DEFAULT *TIOError
var THBaseServiceGetScannerRowsResult_Io_DEFAULT *TIOError
var THBaseServiceIncrementResult_Io_DEFAULT *TIOError
var THBaseServiceMutateRowResult_Io_DEFAULT *TIOError
var THBaseServiceOpenScannerResult_Io_DEFAULT *TIOError
var THBaseServicePutMultipleResult_Io_DEFAULT *TIOError
var THBaseServicePutResult_Io_DEFAULT *TIOError

func NewTIOError 

func NewTIOError() *TIOError

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(iprot thrift.TProtocol) error

func (*TIOError) String 

func (p *TIOError) String() string

func (*TIOError) Write 

func (p *TIOError) Write(oprot thrift.TProtocol) error

type TIllegalArgument 

type TIllegalArgument struct {
	Message *string `thrift:"message,1" 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) 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(iprot thrift.TProtocol) error

func (*TIllegalArgument) String 

func (p *TIllegalArgument) String() string

func (*TIllegalArgument) Write 

func (p *TIllegalArgument) Write(oprot thrift.TProtocol) error

type TIncrement 

type TIncrement struct {
	Row     []byte              `thrift:"row,1,required" json:"row"`
	Columns []*TColumnIncrement `thrift:"columns,2,required" json:"columns"`
	// unused field # 3
	Attributes     map[string][]byte `thrift:"attributes,4" json:"attributes,omitempty"`
	Durability     *TDurability      `thrift:"durability,5" json:"durability,omitempty"`
	CellVisibility *TCellVisibility  `thrift:"cellVisibility,6" json:"cellVisibility,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
var THBaseServiceIncrementArgs_Tincrement_DEFAULT *TIncrement

func NewTIncrement 

func NewTIncrement() *TIncrement

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

func (p *TIncrement) Read(iprot thrift.TProtocol) error

func (*TIncrement) String 

func (p *TIncrement) String() string

func (*TIncrement) Write 

func (p *TIncrement) Write(oprot thrift.TProtocol) error

type TMutation 

type TMutation struct {
	Put          *TPut    `thrift:"put,1" json:"put,omitempty"`
	DeleteSingle *TDelete `thrift:"deleteSingle,2" 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) 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(iprot thrift.TProtocol) error

func (*TMutation) String 

func (p *TMutation) String() string

func (*TMutation) Write 

func (p *TMutation) Write(oprot thrift.TProtocol) error

type TPut 

type TPut struct {
	Row          []byte          `thrift:"row,1,required" json:"row"`
	ColumnValues []*TColumnValue `thrift:"columnValues,2,required" json:"columnValues"`
	Timestamp    *int64          `thrift:"timestamp,3" json:"timestamp,omitempty"`
	// unused field # 4
	Attributes     map[string][]byte `thrift:"attributes,5" json:"attributes,omitempty"`
	Durability     *TDurability      `thrift:"durability,6" json:"durability,omitempty"`
	CellVisibility *TCellVisibility  `thrift:"cellVisibility,7" 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) 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(iprot thrift.TProtocol) error

func (*TPut) String 

func (p *TPut) String() string

func (*TPut) Write 

func (p *TPut) Write(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) String 

func (p TReadType) String() string

func (*TReadType) UnmarshalText 

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

type TResult_ 

type TResult_ struct {
	Row          []byte          `thrift:"row,1" json:"row,omitempty"`
	ColumnValues []*TColumnValue `thrift:"columnValues,2,required" json:"columnValues"`
}

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

Attributes:

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

func NewTResult_ 

func NewTResult_() *TResult_

func (*TResult_) GetColumnValues 

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

func (*TResult_) GetRow 

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

func (*TResult_) IsSetRow 

func (p *TResult_) IsSetRow() bool

func (*TResult_) Read 

func (p *TResult_) Read(iprot thrift.TProtocol) error

func (*TResult_) String 

func (p *TResult_) String() string

func (*TResult_) Write 

func (p *TResult_) Write(oprot thrift.TProtocol) error

type TRowMutations 

type TRowMutations struct {
	Row       []byte       `thrift:"row,1,required" json:"row"`
	Mutations []*TMutation `thrift:"mutations,2,required" 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) GetMutations 

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

func (*TRowMutations) GetRow 

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

func (*TRowMutations) Read 

func (p *TRowMutations) Read(iprot thrift.TProtocol) error

func (*TRowMutations) String 

func (p *TRowMutations) String() string

func (*TRowMutations) Write 

func (p *TRowMutations) Write(oprot thrift.TProtocol) error

type TScan 

type TScan struct {
	StartRow           []byte                 `thrift:"startRow,1" json:"startRow,omitempty"`
	StopRow            []byte                 `thrift:"stopRow,2" json:"stopRow,omitempty"`
	Columns            []*TColumn             `thrift:"columns,3" json:"columns,omitempty"`
	Caching            *int32                 `thrift:"caching,4" json:"caching,omitempty"`
	MaxVersions        int32                  `thrift:"maxVersions,5" json:"maxVersions,omitempty"`
	TimeRange          *TTimeRange            `thrift:"timeRange,6" json:"timeRange,omitempty"`
	FilterString       []byte                 `thrift:"filterString,7" json:"filterString,omitempty"`
	BatchSize          *int32                 `thrift:"batchSize,8" json:"batchSize,omitempty"`
	Attributes         map[string][]byte      `thrift:"attributes,9" json:"attributes,omitempty"`
	Authorizations     *TAuthorization        `thrift:"authorizations,10" json:"authorizations,omitempty"`
	Reversed           *bool                  `thrift:"reversed,11" json:"reversed,omitempty"`
	CacheBlocks        *bool                  `thrift:"cacheBlocks,12" json:"cacheBlocks,omitempty"`
	ColFamTimeRangeMap map[string]*TTimeRange `thrift:"colFamTimeRangeMap,13" json:"colFamTimeRangeMap,omitempty"`
	ReadType           *TReadType             `thrift:"readType,14" json:"readType,omitempty"`
	Limit              *int32                 `thrift:"limit,15" json:"limit,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
var THBaseServiceGetScannerResultsArgs_Tscan_DEFAULT *TScan
var THBaseServiceOpenScannerArgs_Tscan_DEFAULT *TScan

func NewTScan 

func NewTScan() *TScan

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

func (p *TScan) IsSetTimeRange() bool

func (*TScan) Read 

func (p *TScan) Read(iprot thrift.TProtocol) error

func (*TScan) String 

func (p *TScan) String() string

func (*TScan) Write 

func (p *TScan) Write(oprot thrift.TProtocol) error

type TServerName 

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

Attributes:

  • HostName
  • Port
  • StartCode
var THRegionLocation_ServerName_DEFAULT *TServerName

func NewTServerName 

func NewTServerName() *TServerName

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(iprot thrift.TProtocol) error

func (*TServerName) String 

func (p *TServerName) String() string

func (*TServerName) Write 

func (p *TServerName) Write(oprot thrift.TProtocol) error

type TTimeRange 

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

Attributes:

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

func NewTTimeRange 

func NewTTimeRange() *TTimeRange

func (*TTimeRange) GetMaxStamp 

func (p *TTimeRange) GetMaxStamp() int64

func (*TTimeRange) GetMinStamp 

func (p *TTimeRange) GetMinStamp() int64

func (*TTimeRange) Read 

func (p *TTimeRange) Read(iprot thrift.TProtocol) error

func (*TTimeRange) String 

func (p *TTimeRange) String() string

func (*TTimeRange) Write 

func (p *TTimeRange) Write(oprot thrift.TProtocol) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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