hbase

package
v0.0.0-...-3903214 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var HbaseAppendResult_Success_DEFAULT []*TCell
View Source 
var HbaseAtomicIncrementResult_Success_DEFAULT int64
View Source 
var HbaseCheckAndPutResult_Success_DEFAULT bool
View Source 
var HbaseGetColumnDescriptorsResult_Success_DEFAULT map[string]*ColumnDescriptor
View Source 
var HbaseGetResult_Success_DEFAULT []*TCell
View Source 
var HbaseGetRowOrBeforeResult_Success_DEFAULT []*TCell
View Source 
var HbaseGetRowResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowTsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowWithColumnsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowWithColumnsTsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowsTsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowsWithColumnsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetRowsWithColumnsTsResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseGetTableNamesResult_Success_DEFAULT []Text
View Source 
var HbaseGetTableRegionsResult_Success_DEFAULT []*TRegionInfo
View Source 
var HbaseGetVerResult_Success_DEFAULT []*TCell
View Source 
var HbaseGetVerTsResult_Success_DEFAULT []*TCell
View Source 
var HbaseIsTableEnabledResult_Success_DEFAULT bool
View Source 
var HbaseScannerGetListResult_Success_DEFAULT []*TRowResult_
View Source 
var HbaseScannerGetResult_Success_DEFAULT []*TRowResult_
View Source 
var TRowResult__Columns_DEFAULT map[string]*TCell
View Source 
var TRowResult__SortedColumns_DEFAULT []*TColumn
View Source 
var TScan_BatchSize_DEFAULT int32
View Source 
var TScan_Caching_DEFAULT int32
View Source 
var TScan_Columns_DEFAULT []Text
View Source 
var TScan_Reversed_DEFAULT bool
View Source 
var TScan_SortColumns_DEFAULT bool
View Source 
var TScan_Timestamp_DEFAULT int64

Functions

This section is empty.

Types

type AlreadyExists 

type AlreadyExists struct {
	Message string `thrift:"message,1" db:"message" json:"message"`
}

An AlreadyExists exceptions signals that a table with the specified name already exists

Attributes:

  • Message
var HbaseCreateTableResult_Exist_DEFAULT *AlreadyExists

func NewAlreadyExists 

func NewAlreadyExists() *AlreadyExists

func (*AlreadyExists) Error 

func (p *AlreadyExists) Error() string

func (*AlreadyExists) GetMessage 

func (p *AlreadyExists) GetMessage() string

func (*AlreadyExists) Read 

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

func (*AlreadyExists) ReadField1 

func (p *AlreadyExists) ReadField1(iprot thrift.TProtocol) error

func (*AlreadyExists) String 

func (p *AlreadyExists) String() string

func (*AlreadyExists) Write 

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

type BatchMutation 

type BatchMutation struct {
	Row       Text        `thrift:"row,1" db:"row" json:"row"`
	Mutations []*Mutation `thrift:"mutations,2" db:"mutations" json:"mutations"`
}

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

Attributes:

  • Row
  • Mutations

func NewBatchMutation 

func NewBatchMutation() *BatchMutation

func (*BatchMutation) GetMutations 

func (p *BatchMutation) GetMutations() []*Mutation

func (*BatchMutation) GetRow 

func (p *BatchMutation) GetRow() Text

func (*BatchMutation) Read 

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

func (*BatchMutation) ReadField1 

func (p *BatchMutation) ReadField1(iprot thrift.TProtocol) error

func (*BatchMutation) ReadField2 

func (p *BatchMutation) ReadField2(iprot thrift.TProtocol) error

func (*BatchMutation) String 

func (p *BatchMutation) String() string

func (*BatchMutation) Write 

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

type Bytes 

type Bytes []byte

func BytesPtr 

func BytesPtr(v Bytes) *Bytes

type ColumnDescriptor 

type ColumnDescriptor struct {
	Name                  Text   `thrift:"name,1" db:"name" json:"name"`
	MaxVersions           int32  `thrift:"maxVersions,2" db:"maxVersions" json:"maxVersions"`
	Compression           string `thrift:"compression,3" db:"compression" json:"compression"`
	InMemory              bool   `thrift:"inMemory,4" db:"inMemory" json:"inMemory"`
	BloomFilterType       string `thrift:"bloomFilterType,5" db:"bloomFilterType" json:"bloomFilterType"`
	BloomFilterVectorSize int32  `thrift:"bloomFilterVectorSize,6" db:"bloomFilterVectorSize" json:"bloomFilterVectorSize"`
	BloomFilterNbHashes   int32  `thrift:"bloomFilterNbHashes,7" db:"bloomFilterNbHashes" json:"bloomFilterNbHashes"`
	BlockCacheEnabled     bool   `thrift:"blockCacheEnabled,8" db:"blockCacheEnabled" json:"blockCacheEnabled"`
	TimeToLive            int32  `thrift:"timeToLive,9" db:"timeToLive" json:"timeToLive"`
}

An HColumnDescriptor contains information about a column family such as the number of versions, compression settings, etc. It is used as input when creating a table or adding a column.

Attributes:

  • Name
  • MaxVersions
  • Compression
  • InMemory
  • BloomFilterType
  • BloomFilterVectorSize
  • BloomFilterNbHashes
  • BlockCacheEnabled
  • TimeToLive

func NewColumnDescriptor 

func NewColumnDescriptor() *ColumnDescriptor

func (*ColumnDescriptor) GetBlockCacheEnabled 

func (p *ColumnDescriptor) GetBlockCacheEnabled() bool

func (*ColumnDescriptor) GetBloomFilterNbHashes 

func (p *ColumnDescriptor) GetBloomFilterNbHashes() int32

func (*ColumnDescriptor) GetBloomFilterType 

func (p *ColumnDescriptor) GetBloomFilterType() string

func (*ColumnDescriptor) GetBloomFilterVectorSize 

func (p *ColumnDescriptor) GetBloomFilterVectorSize() int32

func (*ColumnDescriptor) GetCompression 

func (p *ColumnDescriptor) GetCompression() string

func (*ColumnDescriptor) GetInMemory 

func (p *ColumnDescriptor) GetInMemory() bool

func (*ColumnDescriptor) GetMaxVersions 

func (p *ColumnDescriptor) GetMaxVersions() int32

func (*ColumnDescriptor) GetName 

func (p *ColumnDescriptor) GetName() Text

func (*ColumnDescriptor) GetTimeToLive 

func (p *ColumnDescriptor) GetTimeToLive() int32

func (*ColumnDescriptor) Read 

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

func (*ColumnDescriptor) ReadField1 

func (p *ColumnDescriptor) ReadField1(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField2 

func (p *ColumnDescriptor) ReadField2(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField3 

func (p *ColumnDescriptor) ReadField3(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField4 

func (p *ColumnDescriptor) ReadField4(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField5 

func (p *ColumnDescriptor) ReadField5(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField6 

func (p *ColumnDescriptor) ReadField6(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField7 

func (p *ColumnDescriptor) ReadField7(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField8 

func (p *ColumnDescriptor) ReadField8(iprot thrift.TProtocol) error

func (*ColumnDescriptor) ReadField9 

func (p *ColumnDescriptor) ReadField9(iprot thrift.TProtocol) error

func (*ColumnDescriptor) String 

func (p *ColumnDescriptor) String() string

func (*ColumnDescriptor) Write 

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

type Hbase 

type Hbase interface {
	// Brings a table on-line (enables it)
	//
	// Parameters:
	//  - TableName: name of the table
	EnableTable(ctx context.Context, tableName Bytes) (err error)
	// Disables a table (takes it off-line) If it is being served, the master
	// will tell the servers to stop serving it.
	//
	// Parameters:
	//  - TableName: name of the table
	DisableTable(ctx context.Context, tableName Bytes) (err error)
	// @return true if table is on-line
	//
	// Parameters:
	//  - TableName: name of the table to check
	IsTableEnabled(ctx context.Context, tableName Bytes) (r bool, err error)
	// Parameters:
	//  - TableNameOrRegionName
	Compact(ctx context.Context, tableNameOrRegionName Bytes) (err error)
	// Parameters:
	//  - TableNameOrRegionName
	MajorCompact(ctx context.Context, tableNameOrRegionName Bytes) (err error)
	// List all the userspace tables.
	//
	// @return returns a list of names
	GetTableNames(ctx context.Context) (r []Text, err error)
	// List all the column families assoicated with a table.
	//
	// @return list of column family descriptors
	//
	// Parameters:
	//  - TableName: table name
	GetColumnDescriptors(ctx context.Context, tableName Text) (r map[string]*ColumnDescriptor, err error)
	// List the regions associated with a table.
	//
	// @return list of region descriptors
	//
	// Parameters:
	//  - TableName: table name
	GetTableRegions(ctx context.Context, tableName Text) (r []*TRegionInfo, err error)
	// Create a table with the specified column families.  The name
	// field for each ColumnDescriptor must be set and must end in a
	// colon (:). All other fields are optional and will get default
	// values if not explicitly specified.
	//
	// @throws IllegalArgument if an input parameter is invalid
	//
	// @throws AlreadyExists if the table name already exists
	//
	// Parameters:
	//  - TableName: name of table to create
	//  - ColumnFamilies: list of column family descriptors
	CreateTable(ctx context.Context, tableName Text, columnFamilies []*ColumnDescriptor) (err error)
	// Deletes a table
	//
	// @throws IOError if table doesn't exist on server or there was some other
	// problem
	//
	// Parameters:
	//  - TableName: name of table to delete
	DeleteTable(ctx context.Context, tableName Text) (err error)
	// Get a single TCell for the specified table, row, and column at the
	// latest timestamp. Returns an empty list if no such value exists.
	//
	// @return value for specified row/column
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Column: column name
	//  - Attributes: Get attributes
	Get(ctx context.Context, tableName Text, row Text, column Text, attributes map[string]Text) (r []*TCell, err error)
	// Get the specified number of versions for the specified table,
	// row, and column.
	//
	// @return list of cells for specified row/column
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Column: column name
	//  - NumVersions: number of versions to retrieve
	//  - Attributes: Get attributes
	GetVer(ctx context.Context, tableName Text, row Text, column Text, numVersions int32, attributes map[string]Text) (r []*TCell, err error)
	// Get the specified number of versions for the specified table,
	// row, and column.  Only versions less than or equal to the specified
	// timestamp will be returned.
	//
	// @return list of cells for specified row/column
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Column: column name
	//  - Timestamp: timestamp
	//  - NumVersions: number of versions to retrieve
	//  - Attributes: Get attributes
	GetVerTs(ctx context.Context, tableName Text, row Text, column Text, timestamp int64, numVersions int32, attributes map[string]Text) (r []*TCell, err error)
	// Get all the data for the specified table and row at the latest
	// timestamp. Returns an empty list if the row does not exist.
	//
	// @return TRowResult containing the row and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Attributes: Get attributes
	GetRow(ctx context.Context, tableName Text, row Text, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get the specified columns for the specified table and row at the latest
	// timestamp. Returns an empty list if the row does not exist.
	//
	// @return TRowResult containing the row and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Columns: List of columns to return, null for all columns
	//  - Attributes: Get attributes
	GetRowWithColumns(ctx context.Context, tableName Text, row Text, columns []Text, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get all the data for the specified table and row at the specified
	// timestamp. Returns an empty list if the row does not exist.
	//
	// @return TRowResult containing the row and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of the table
	//  - Row: row key
	//  - Timestamp: timestamp
	//  - Attributes: Get attributes
	GetRowTs(ctx context.Context, tableName Text, row Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get the specified columns for the specified table and row at the specified
	// timestamp. Returns an empty list if the row does not exist.
	//
	// @return TRowResult containing the row and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Columns: List of columns to return, null for all columns
	//  - Timestamp
	//  - Attributes: Get attributes
	GetRowWithColumnsTs(ctx context.Context, tableName Text, row Text, columns []Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get all the data for the specified table and rows at the latest
	// timestamp. Returns an empty list if no rows exist.
	//
	// @return TRowResult containing the rows and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of table
	//  - Rows: row keys
	//  - Attributes: Get attributes
	GetRows(ctx context.Context, tableName Text, rows []Text, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get the specified columns for the specified table and rows at the latest
	// timestamp. Returns an empty list if no rows exist.
	//
	// @return TRowResult containing the rows and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of table
	//  - Rows: row keys
	//  - Columns: List of columns to return, null for all columns
	//  - Attributes: Get attributes
	GetRowsWithColumns(ctx context.Context, tableName Text, rows []Text, columns []Text, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get all the data for the specified table and rows at the specified
	// timestamp. Returns an empty list if no rows exist.
	//
	// @return TRowResult containing the rows and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of the table
	//  - Rows: row keys
	//  - Timestamp: timestamp
	//  - Attributes: Get attributes
	GetRowsTs(ctx context.Context, tableName Text, rows []Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)
	// Get the specified columns for the specified table and rows at the specified
	// timestamp. Returns an empty list if no rows exist.
	//
	// @return TRowResult containing the rows and map of columns to TCells
	//
	// Parameters:
	//  - TableName: name of table
	//  - Rows: row keys
	//  - Columns: List of columns to return, null for all columns
	//  - Timestamp
	//  - Attributes: Get attributes
	GetRowsWithColumnsTs(ctx context.Context, tableName Text, rows []Text, columns []Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)
	// Apply a series of mutations (updates/deletes) to a row in a
	// single transaction.  If an exception is thrown, then the
	// transaction is aborted.  Default current timestamp is used, and
	// all entries will have an identical timestamp.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Mutations: list of mutation commands
	//  - Attributes: Mutation attributes
	MutateRow(ctx context.Context, tableName Text, row Text, mutations []*Mutation, attributes map[string]Text) (err error)
	// Apply a series of mutations (updates/deletes) to a row in a
	// single transaction.  If an exception is thrown, then the
	// transaction is aborted.  The specified timestamp is used, and
	// all entries will have an identical timestamp.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Mutations: list of mutation commands
	//  - Timestamp: timestamp
	//  - Attributes: Mutation attributes
	MutateRowTs(ctx context.Context, tableName Text, row Text, mutations []*Mutation, timestamp int64, attributes map[string]Text) (err error)
	// Apply a series of batches (each a series of mutations on a single row)
	// in a single transaction.  If an exception is thrown, then the
	// transaction is aborted.  Default current timestamp is used, and
	// all entries will have an identical timestamp.
	//
	// Parameters:
	//  - TableName: name of table
	//  - RowBatches: list of row batches
	//  - Attributes: Mutation attributes
	MutateRows(ctx context.Context, tableName Text, rowBatches []*BatchMutation, attributes map[string]Text) (err error)
	// Apply a series of batches (each a series of mutations on a single row)
	// in a single transaction.  If an exception is thrown, then the
	// transaction is aborted.  The specified timestamp is used, and
	// all entries will have an identical timestamp.
	//
	// Parameters:
	//  - TableName: name of table
	//  - RowBatches: list of row batches
	//  - Timestamp: timestamp
	//  - Attributes: Mutation attributes
	MutateRowsTs(ctx context.Context, tableName Text, rowBatches []*BatchMutation, timestamp int64, attributes map[string]Text) (err error)
	// Atomically increment the column value specified.  Returns the next value post increment.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row to increment
	//  - Column: name of column
	//  - Value: amount to increment by
	AtomicIncrement(ctx context.Context, tableName Text, row Text, column Text, value int64) (r int64, err error)
	// Delete all cells that match the passed row and column.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: Row to update
	//  - Column: name of column whose value is to be deleted
	//  - Attributes: Delete attributes
	DeleteAll(ctx context.Context, tableName Text, row Text, column Text, attributes map[string]Text) (err error)
	// Delete all cells that match the passed row and column and whose
	// timestamp is equal-to or older than the passed timestamp.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: Row to update
	//  - Column: name of column whose value is to be deleted
	//  - Timestamp: timestamp
	//  - Attributes: Delete attributes
	DeleteAllTs(ctx context.Context, tableName Text, row Text, column Text, timestamp int64, attributes map[string]Text) (err error)
	// Completely delete the row's cells.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: key of the row to be completely deleted.
	//  - Attributes: Delete attributes
	DeleteAllRow(ctx context.Context, tableName Text, row Text, attributes map[string]Text) (err error)
	// Increment a cell by the ammount.
	// Increments can be applied async if hbase.regionserver.thrift.coalesceIncrement is set to true.
	// False is the default.  Turn to true if you need the extra performance and can accept some
	// data loss if a thrift server dies with increments still in the queue.
	//
	// Parameters:
	//  - Increment: The single increment to apply
	Increment(ctx context.Context, increment *TIncrement) (err error)
	// Parameters:
	//  - Increments: The list of increments
	IncrementRows(ctx context.Context, increments []*TIncrement) (err error)
	// Completely delete the row's cells marked with a timestamp
	// equal-to or older than the passed timestamp.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: key of the row to be completely deleted.
	//  - Timestamp: timestamp
	//  - Attributes: Delete attributes
	DeleteAllRowTs(ctx context.Context, tableName Text, row Text, timestamp int64, attributes map[string]Text) (err error)
	// Get a scanner on the current table, using the Scan instance
	// for the scan parameters.
	//
	// Parameters:
	//  - TableName: name of table
	//  - Scan: Scan instance
	//  - Attributes: Scan attributes
	ScannerOpenWithScan(ctx context.Context, tableName Text, scan *TScan, attributes map[string]Text) (r ScannerID, err error)
	// Get a scanner on the current table starting at the specified row and
	// ending at the last row in the table.  Return the specified columns.
	//
	// @return scanner id to be used with other scanner procedures
	//
	// Parameters:
	//  - TableName: name of table
	//  - StartRow: Starting row in table to scan.
	// Send "" (empty string) to start at the first row.
	//  - Columns: columns to scan. If column name is a column family, all
	// columns of the specified column family are returned. It's also possible
	// to pass a regex in the column qualifier.
	//  - Attributes: Scan attributes
	ScannerOpen(ctx context.Context, tableName Text, startRow Text, columns []Text, attributes map[string]Text) (r ScannerID, err error)
	// Get a scanner on the current table starting and stopping at the
	// specified rows.  ending at the last row in the table.  Return the
	// specified columns.
	//
	// @return scanner id to be used with other scanner procedures
	//
	// Parameters:
	//  - TableName: name of table
	//  - StartRow: Starting row in table to scan.
	// Send "" (empty string) to start at the first row.
	//  - StopRow: row to stop scanning on. This row is *not* included in the
	// scanner's results
	//  - Columns: columns to scan. If column name is a column family, all
	// columns of the specified column family are returned. It's also possible
	// to pass a regex in the column qualifier.
	//  - Attributes: Scan attributes
	ScannerOpenWithStop(ctx context.Context, tableName Text, startRow Text, stopRow Text, columns []Text, attributes map[string]Text) (r ScannerID, err error)
	// Open a scanner for a given prefix.  That is all rows will have the specified
	// prefix. No other rows will be returned.
	//
	// @return scanner id to use with other scanner calls
	//
	// Parameters:
	//  - TableName: name of table
	//  - StartAndPrefix: the prefix (and thus start row) of the keys you want
	//  - Columns: the columns you want returned
	//  - Attributes: Scan attributes
	ScannerOpenWithPrefix(ctx context.Context, tableName Text, startAndPrefix Text, columns []Text, attributes map[string]Text) (r ScannerID, err error)
	// Get a scanner on the current table starting at the specified row and
	// ending at the last row in the table.  Return the specified columns.
	// Only values with the specified timestamp are returned.
	//
	// @return scanner id to be used with other scanner procedures
	//
	// Parameters:
	//  - TableName: name of table
	//  - StartRow: Starting row in table to scan.
	// Send "" (empty string) to start at the first row.
	//  - Columns: columns to scan. If column name is a column family, all
	// columns of the specified column family are returned. It's also possible
	// to pass a regex in the column qualifier.
	//  - Timestamp: timestamp
	//  - Attributes: Scan attributes
	ScannerOpenTs(ctx context.Context, tableName Text, startRow Text, columns []Text, timestamp int64, attributes map[string]Text) (r ScannerID, err error)
	// Get a scanner on the current table starting and stopping at the
	// specified rows.  ending at the last row in the table.  Return the
	// specified columns.  Only values with the specified timestamp are
	// returned.
	//
	// @return scanner id to be used with other scanner procedures
	//
	// Parameters:
	//  - TableName: name of table
	//  - StartRow: Starting row in table to scan.
	// Send "" (empty string) to start at the first row.
	//  - StopRow: row to stop scanning on. This row is *not* included in the
	// scanner's results
	//  - Columns: columns to scan. If column name is a column family, all
	// columns of the specified column family are returned. It's also possible
	// to pass a regex in the column qualifier.
	//  - Timestamp: timestamp
	//  - Attributes: Scan attributes
	ScannerOpenWithStopTs(ctx context.Context, tableName Text, startRow Text, stopRow Text, columns []Text, timestamp int64, attributes map[string]Text) (r ScannerID, err error)
	// Returns the scanner's current row value and advances to the next
	// row in the table.  When there are no more rows in the table, or a key
	// greater-than-or-equal-to the scanner's specified stopRow is reached,
	// an empty list is returned.
	//
	// @return a TRowResult containing the current row and a map of the columns to TCells.
	//
	// @throws IllegalArgument if ScannerID is invalid
	//
	// @throws NotFound when the scanner reaches the end
	//
	// Parameters:
	//  - ID: id of a scanner returned by scannerOpen
	ScannerGet(ctx context.Context, id ScannerID) (r []*TRowResult_, err error)
	// Returns, starting at the scanner's current row value nbRows worth of
	// rows and advances to the next row in the table.  When there are no more
	// rows in the table, or a key greater-than-or-equal-to the scanner's
	// specified stopRow is reached,  an empty list is returned.
	//
	// @return a TRowResult containing the current row and a map of the columns to TCells.
	//
	// @throws IllegalArgument if ScannerID is invalid
	//
	// @throws NotFound when the scanner reaches the end
	//
	// Parameters:
	//  - ID: id of a scanner returned by scannerOpen
	//  - NbRows: number of results to return
	ScannerGetList(ctx context.Context, id ScannerID, nbRows int32) (r []*TRowResult_, err error)
	// Closes the server-state associated with an open scanner.
	//
	// @throws IllegalArgument if ScannerID is invalid
	//
	// Parameters:
	//  - ID: id of a scanner returned by scannerOpen
	ScannerClose(ctx context.Context, id ScannerID) (err error)
	// Get the row just before the specified one.
	//
	// @return value for specified row/column
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Family: column name
	GetRowOrBefore(ctx context.Context, tableName Text, row Text, family Text) (r []*TCell, err error)
	// Get the regininfo for the specified row. It scans
	// the metatable to find region's start and end keys.
	//
	// @return value for specified row/column
	//
	// Parameters:
	//  - Row: row key
	GetRegionInfo(ctx context.Context, row Text) (r *TRegionInfo, err error)
	// Appends values to one or more columns within a single row.
	//
	// @return values of columns after the append operation.
	//
	// Parameters:
	//  - Append: The single append operation to apply
	Append(ctx context.Context, append *TAppend) (r []*TCell, err error)
	// Atomically checks if a row/family/qualifier value matches the expected
	// value. If it does, it adds the corresponding mutation operation for put.
	//
	// @return true if the new put was executed, false otherwise
	//
	// Parameters:
	//  - TableName: name of table
	//  - Row: row key
	//  - Column: column name
	//  - Value: the expected value for the column parameter, if not
	// provided the check is for the non-existence of the
	// column in question
	//  - Mput: mutation for the put
	//  - Attributes: Mutation attributes
	CheckAndPut(ctx context.Context, tableName Text, row Text, column Text, value Text, mput *Mutation, attributes map[string]Text) (r bool, err error)
}

type HbaseAppendArgs 

type HbaseAppendArgs struct {
	Append *TAppend `thrift:"append,1" db:"append" json:"append"`
}

Attributes:

  • Append: The single append operation to apply

func NewHbaseAppendArgs 

func NewHbaseAppendArgs() *HbaseAppendArgs

func (*HbaseAppendArgs) GetAppend 

func (p *HbaseAppendArgs) GetAppend() *TAppend

func (*HbaseAppendArgs) IsSetAppend 

func (p *HbaseAppendArgs) IsSetAppend() bool

func (*HbaseAppendArgs) Read 

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

func (*HbaseAppendArgs) ReadField1 

func (p *HbaseAppendArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseAppendArgs) String 

func (p *HbaseAppendArgs) String() string

func (*HbaseAppendArgs) Write 

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

type HbaseAppendResult 

type HbaseAppendResult struct {
	Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseAppendResult 

func NewHbaseAppendResult() *HbaseAppendResult

func (*HbaseAppendResult) GetIo 

func (p *HbaseAppendResult) GetIo() *IOError

func (*HbaseAppendResult) GetSuccess 

func (p *HbaseAppendResult) GetSuccess() []*TCell

func (*HbaseAppendResult) IsSetIo 

func (p *HbaseAppendResult) IsSetIo() bool

func (*HbaseAppendResult) IsSetSuccess 

func (p *HbaseAppendResult) IsSetSuccess() bool

func (*HbaseAppendResult) Read 

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

func (*HbaseAppendResult) ReadField0 

func (p *HbaseAppendResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseAppendResult) ReadField1 

func (p *HbaseAppendResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseAppendResult) String 

func (p *HbaseAppendResult) String() string

func (*HbaseAppendResult) Write 

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

type HbaseAtomicIncrementArgs 

type HbaseAtomicIncrementArgs struct {
	TableName Text  `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row       Text  `thrift:"row,2" db:"row" json:"row"`
	Column    Text  `thrift:"column,3" db:"column" json:"column"`
	Value     int64 `thrift:"value,4" db:"value" json:"value"`
}

Attributes:

  • TableName: name of table
  • Row: row to increment
  • Column: name of column
  • Value: amount to increment by

func NewHbaseAtomicIncrementArgs 

func NewHbaseAtomicIncrementArgs() *HbaseAtomicIncrementArgs

func (*HbaseAtomicIncrementArgs) GetColumn 

func (p *HbaseAtomicIncrementArgs) GetColumn() Text

func (*HbaseAtomicIncrementArgs) GetRow 

func (p *HbaseAtomicIncrementArgs) GetRow() Text

func (*HbaseAtomicIncrementArgs) GetTableName 

func (p *HbaseAtomicIncrementArgs) GetTableName() Text

func (*HbaseAtomicIncrementArgs) GetValue 

func (p *HbaseAtomicIncrementArgs) GetValue() int64

func (*HbaseAtomicIncrementArgs) Read 

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

func (*HbaseAtomicIncrementArgs) ReadField1 

func (p *HbaseAtomicIncrementArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementArgs) ReadField2 

func (p *HbaseAtomicIncrementArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementArgs) ReadField3 

func (p *HbaseAtomicIncrementArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementArgs) ReadField4 

func (p *HbaseAtomicIncrementArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementArgs) String 

func (p *HbaseAtomicIncrementArgs) String() string

func (*HbaseAtomicIncrementArgs) Write 

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

type HbaseAtomicIncrementResult 

type HbaseAtomicIncrementResult struct {
	Success *int64           `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Success
  • Io
  • Ia

func NewHbaseAtomicIncrementResult 

func NewHbaseAtomicIncrementResult() *HbaseAtomicIncrementResult

func (*HbaseAtomicIncrementResult) GetIa 

func (p *HbaseAtomicIncrementResult) GetIa() *IllegalArgument

func (*HbaseAtomicIncrementResult) GetIo 

func (p *HbaseAtomicIncrementResult) GetIo() *IOError

func (*HbaseAtomicIncrementResult) GetSuccess 

func (p *HbaseAtomicIncrementResult) GetSuccess() int64

func (*HbaseAtomicIncrementResult) IsSetIa 

func (p *HbaseAtomicIncrementResult) IsSetIa() bool

func (*HbaseAtomicIncrementResult) IsSetIo 

func (p *HbaseAtomicIncrementResult) IsSetIo() bool

func (*HbaseAtomicIncrementResult) IsSetSuccess 

func (p *HbaseAtomicIncrementResult) IsSetSuccess() bool

func (*HbaseAtomicIncrementResult) Read 

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

func (*HbaseAtomicIncrementResult) ReadField0 

func (p *HbaseAtomicIncrementResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementResult) ReadField1 

func (p *HbaseAtomicIncrementResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementResult) ReadField2 

func (p *HbaseAtomicIncrementResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseAtomicIncrementResult) String 

func (p *HbaseAtomicIncrementResult) String() string

func (*HbaseAtomicIncrementResult) Write 

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

type HbaseCheckAndPutArgs 

type HbaseCheckAndPutArgs struct {
	TableName Text `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row       Text `thrift:"row,2" db:"row" json:"row"`
	Column    Text `thrift:"column,3" db:"column" json:"column"`
	// unused field # 4
	Value      Text            `thrift:"value,5" db:"value" json:"value"`
	Mput       *Mutation       `thrift:"mput,6" db:"mput" json:"mput"`
	Attributes map[string]Text `thrift:"attributes,7" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • Value: the expected value for the column parameter, if not

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

  • Mput: mutation for the put
  • Attributes: Mutation attributes

func NewHbaseCheckAndPutArgs 

func NewHbaseCheckAndPutArgs() *HbaseCheckAndPutArgs

func (*HbaseCheckAndPutArgs) GetAttributes 

func (p *HbaseCheckAndPutArgs) GetAttributes() map[string]Text

func (*HbaseCheckAndPutArgs) GetColumn 

func (p *HbaseCheckAndPutArgs) GetColumn() Text

func (*HbaseCheckAndPutArgs) GetMput 

func (p *HbaseCheckAndPutArgs) GetMput() *Mutation

func (*HbaseCheckAndPutArgs) GetRow 

func (p *HbaseCheckAndPutArgs) GetRow() Text

func (*HbaseCheckAndPutArgs) GetTableName 

func (p *HbaseCheckAndPutArgs) GetTableName() Text

func (*HbaseCheckAndPutArgs) GetValue 

func (p *HbaseCheckAndPutArgs) GetValue() Text

func (*HbaseCheckAndPutArgs) IsSetMput 

func (p *HbaseCheckAndPutArgs) IsSetMput() bool

func (*HbaseCheckAndPutArgs) Read 

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

func (*HbaseCheckAndPutArgs) ReadField1 

func (p *HbaseCheckAndPutArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutArgs) ReadField2 

func (p *HbaseCheckAndPutArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutArgs) ReadField3 

func (p *HbaseCheckAndPutArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutArgs) ReadField5 

func (p *HbaseCheckAndPutArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutArgs) ReadField6 

func (p *HbaseCheckAndPutArgs) ReadField6(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutArgs) ReadField7 

func (p *HbaseCheckAndPutArgs) ReadField7(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutArgs) String 

func (p *HbaseCheckAndPutArgs) String() string

func (*HbaseCheckAndPutArgs) Write 

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

type HbaseCheckAndPutResult 

type HbaseCheckAndPutResult struct {
	Success *bool            `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Success
  • Io
  • Ia

func NewHbaseCheckAndPutResult 

func NewHbaseCheckAndPutResult() *HbaseCheckAndPutResult

func (*HbaseCheckAndPutResult) GetIa 

func (p *HbaseCheckAndPutResult) GetIa() *IllegalArgument

func (*HbaseCheckAndPutResult) GetIo 

func (p *HbaseCheckAndPutResult) GetIo() *IOError

func (*HbaseCheckAndPutResult) GetSuccess 

func (p *HbaseCheckAndPutResult) GetSuccess() bool

func (*HbaseCheckAndPutResult) IsSetIa 

func (p *HbaseCheckAndPutResult) IsSetIa() bool

func (*HbaseCheckAndPutResult) IsSetIo 

func (p *HbaseCheckAndPutResult) IsSetIo() bool

func (*HbaseCheckAndPutResult) IsSetSuccess 

func (p *HbaseCheckAndPutResult) IsSetSuccess() bool

func (*HbaseCheckAndPutResult) Read 

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

func (*HbaseCheckAndPutResult) ReadField0 

func (p *HbaseCheckAndPutResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutResult) ReadField1 

func (p *HbaseCheckAndPutResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutResult) ReadField2 

func (p *HbaseCheckAndPutResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseCheckAndPutResult) String 

func (p *HbaseCheckAndPutResult) String() string

func (*HbaseCheckAndPutResult) Write 

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

type HbaseClient 

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

func NewHbaseClient 

func NewHbaseClient(c thrift.TClient) *HbaseClient

func NewHbaseClientFactory 

func NewHbaseClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *HbaseClient

func NewHbaseClientProtocol 

func NewHbaseClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *HbaseClient

func (*HbaseClient) Append 

func (p *HbaseClient) Append(ctx context.Context, append *TAppend) (r []*TCell, err error)

Appends values to one or more columns within a single row.

@return values of columns after the append operation.

Parameters:

  • Append: The single append operation to apply

func (*HbaseClient) AtomicIncrement 

func (p *HbaseClient) AtomicIncrement(ctx context.Context, tableName Text, row Text, column Text, value int64) (r int64, err error)

Atomically increment the column value specified. Returns the next value post increment.

Parameters:

  • TableName: name of table
  • Row: row to increment
  • Column: name of column
  • Value: amount to increment by

func (*HbaseClient) CheckAndPut 

func (p *HbaseClient) CheckAndPut(ctx context.Context, tableName Text, row Text, column Text, value Text, mput *Mutation, attributes map[string]Text) (r bool, err error)

Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the corresponding mutation operation for put.

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

Parameters:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • Value: the expected value for the column parameter, if not

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

  • Mput: mutation for the put
  • Attributes: Mutation attributes

func (*HbaseClient) Client_ 

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

func (*HbaseClient) Compact 

func (p *HbaseClient) Compact(ctx context.Context, tableNameOrRegionName Bytes) (err error)

Parameters:

  • TableNameOrRegionName

func (*HbaseClient) CreateTable 

func (p *HbaseClient) CreateTable(ctx context.Context, tableName Text, columnFamilies []*ColumnDescriptor) (err error)

Create a table with the specified column families. The name field for each ColumnDescriptor must be set and must end in a colon (:). All other fields are optional and will get default values if not explicitly specified.

@throws IllegalArgument if an input parameter is invalid

@throws AlreadyExists if the table name already exists

Parameters:

  • TableName: name of table to create
  • ColumnFamilies: list of column family descriptors

func (*HbaseClient) DeleteAll 

func (p *HbaseClient) DeleteAll(ctx context.Context, tableName Text, row Text, column Text, attributes map[string]Text) (err error)

Delete all cells that match the passed row and column.

Parameters:

  • TableName: name of table
  • Row: Row to update
  • Column: name of column whose value is to be deleted
  • Attributes: Delete attributes

func (*HbaseClient) DeleteAllRow 

func (p *HbaseClient) DeleteAllRow(ctx context.Context, tableName Text, row Text, attributes map[string]Text) (err error)

Completely delete the row's cells.

Parameters:

  • TableName: name of table
  • Row: key of the row to be completely deleted.
  • Attributes: Delete attributes

func (*HbaseClient) DeleteAllRowTs 

func (p *HbaseClient) DeleteAllRowTs(ctx context.Context, tableName Text, row Text, timestamp int64, attributes map[string]Text) (err error)

Completely delete the row's cells marked with a timestamp equal-to or older than the passed timestamp.

Parameters:

  • TableName: name of table
  • Row: key of the row to be completely deleted.
  • Timestamp: timestamp
  • Attributes: Delete attributes

func (*HbaseClient) DeleteAllTs 

func (p *HbaseClient) DeleteAllTs(ctx context.Context, tableName Text, row Text, column Text, timestamp int64, attributes map[string]Text) (err error)

Delete all cells that match the passed row and column and whose timestamp is equal-to or older than the passed timestamp.

Parameters:

  • TableName: name of table
  • Row: Row to update
  • Column: name of column whose value is to be deleted
  • Timestamp: timestamp
  • Attributes: Delete attributes

func (*HbaseClient) DeleteTable 

func (p *HbaseClient) DeleteTable(ctx context.Context, tableName Text) (err error)

Deletes a table

@throws IOError if table doesn't exist on server or there was some other problem

Parameters:

  • TableName: name of table to delete

func (*HbaseClient) DisableTable 

func (p *HbaseClient) DisableTable(ctx context.Context, tableName Bytes) (err error)

Disables a table (takes it off-line) If it is being served, the master will tell the servers to stop serving it.

Parameters:

  • TableName: name of the table

func (*HbaseClient) EnableTable 

func (p *HbaseClient) EnableTable(ctx context.Context, tableName Bytes) (err error)

Brings a table on-line (enables it)

Parameters:

  • TableName: name of the table

func (*HbaseClient) Get 

func (p *HbaseClient) Get(ctx context.Context, tableName Text, row Text, column Text, attributes map[string]Text) (r []*TCell, err error)

Get a single TCell for the specified table, row, and column at the latest timestamp. Returns an empty list if no such value exists.

@return value for specified row/column

Parameters:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • Attributes: Get attributes

func (*HbaseClient) GetColumnDescriptors 

func (p *HbaseClient) GetColumnDescriptors(ctx context.Context, tableName Text) (r map[string]*ColumnDescriptor, err error)

List all the column families assoicated with a table.

@return list of column family descriptors

Parameters:

  • TableName: table name

func (*HbaseClient) GetRegionInfo 

func (p *HbaseClient) GetRegionInfo(ctx context.Context, row Text) (r *TRegionInfo, err error)

Get the regininfo for the specified row. It scans the metatable to find region's start and end keys.

@return value for specified row/column

Parameters:

  • Row: row key

func (*HbaseClient) GetRow 

func (p *HbaseClient) GetRow(ctx context.Context, tableName Text, row Text, attributes map[string]Text) (r []*TRowResult_, err error)

Get all the data for the specified table and row at the latest timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

  • TableName: name of table
  • Row: row key
  • Attributes: Get attributes

func (*HbaseClient) GetRowOrBefore 

func (p *HbaseClient) GetRowOrBefore(ctx context.Context, tableName Text, row Text, family Text) (r []*TCell, err error)

Get the row just before the specified one.

@return value for specified row/column

Parameters:

  • TableName: name of table
  • Row: row key
  • Family: column name

func (*HbaseClient) GetRowTs 

func (p *HbaseClient) GetRowTs(ctx context.Context, tableName Text, row Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)

Get all the data for the specified table and row at the specified timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

  • TableName: name of the table
  • Row: row key
  • Timestamp: timestamp
  • Attributes: Get attributes

func (*HbaseClient) GetRowWithColumns 

func (p *HbaseClient) GetRowWithColumns(ctx context.Context, tableName Text, row Text, columns []Text, attributes map[string]Text) (r []*TRowResult_, err error)

Get the specified columns for the specified table and row at the latest timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

  • TableName: name of table
  • Row: row key
  • Columns: List of columns to return, null for all columns
  • Attributes: Get attributes

func (*HbaseClient) GetRowWithColumnsTs 

func (p *HbaseClient) GetRowWithColumnsTs(ctx context.Context, tableName Text, row Text, columns []Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)

Get the specified columns for the specified table and row at the specified timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

  • TableName: name of table
  • Row: row key
  • Columns: List of columns to return, null for all columns
  • Timestamp
  • Attributes: Get attributes

func (*HbaseClient) GetRows 

func (p *HbaseClient) GetRows(ctx context.Context, tableName Text, rows []Text, attributes map[string]Text) (r []*TRowResult_, err error)

Get all the data for the specified table and rows at the latest timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

  • TableName: name of table
  • Rows: row keys
  • Attributes: Get attributes

func (*HbaseClient) GetRowsTs 

func (p *HbaseClient) GetRowsTs(ctx context.Context, tableName Text, rows []Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)

Get all the data for the specified table and rows at the specified timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

  • TableName: name of the table
  • Rows: row keys
  • Timestamp: timestamp
  • Attributes: Get attributes

func (*HbaseClient) GetRowsWithColumns 

func (p *HbaseClient) GetRowsWithColumns(ctx context.Context, tableName Text, rows []Text, columns []Text, attributes map[string]Text) (r []*TRowResult_, err error)

Get the specified columns for the specified table and rows at the latest timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

  • TableName: name of table
  • Rows: row keys
  • Columns: List of columns to return, null for all columns
  • Attributes: Get attributes

func (*HbaseClient) GetRowsWithColumnsTs 

func (p *HbaseClient) GetRowsWithColumnsTs(ctx context.Context, tableName Text, rows []Text, columns []Text, timestamp int64, attributes map[string]Text) (r []*TRowResult_, err error)

Get the specified columns for the specified table and rows at the specified timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

  • TableName: name of table
  • Rows: row keys
  • Columns: List of columns to return, null for all columns
  • Timestamp
  • Attributes: Get attributes

func (*HbaseClient) GetTableNames 

func (p *HbaseClient) GetTableNames(ctx context.Context) (r []Text, err error)

List all the userspace tables.

@return returns a list of names

func (*HbaseClient) GetTableRegions 

func (p *HbaseClient) GetTableRegions(ctx context.Context, tableName Text) (r []*TRegionInfo, err error)

List the regions associated with a table.

@return list of region descriptors

Parameters:

  • TableName: table name

func (*HbaseClient) GetVer 

func (p *HbaseClient) GetVer(ctx context.Context, tableName Text, row Text, column Text, numVersions int32, attributes map[string]Text) (r []*TCell, err error)

Get the specified number of versions for the specified table, row, and column.

@return list of cells for specified row/column

Parameters:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • NumVersions: number of versions to retrieve
  • Attributes: Get attributes

func (*HbaseClient) GetVerTs 

func (p *HbaseClient) GetVerTs(ctx context.Context, tableName Text, row Text, column Text, timestamp int64, numVersions int32, attributes map[string]Text) (r []*TCell, err error)

Get the specified number of versions for the specified table, row, and column. Only versions less than or equal to the specified timestamp will be returned.

@return list of cells for specified row/column

Parameters:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • Timestamp: timestamp
  • NumVersions: number of versions to retrieve
  • Attributes: Get attributes

func (*HbaseClient) Increment 

func (p *HbaseClient) Increment(ctx context.Context, increment *TIncrement) (err error)

Increment a cell by the ammount. Increments can be applied async if hbase.regionserver.thrift.coalesceIncrement is set to true. False is the default. Turn to true if you need the extra performance and can accept some data loss if a thrift server dies with increments still in the queue.

Parameters:

  • Increment: The single increment to apply

func (*HbaseClient) IncrementRows 

func (p *HbaseClient) IncrementRows(ctx context.Context, increments []*TIncrement) (err error)

Parameters:

  • Increments: The list of increments

func (*HbaseClient) IsTableEnabled 

func (p *HbaseClient) IsTableEnabled(ctx context.Context, tableName Bytes) (r bool, err error)

@return true if table is on-line

Parameters:

  • TableName: name of the table to check

func (*HbaseClient) MajorCompact 

func (p *HbaseClient) MajorCompact(ctx context.Context, tableNameOrRegionName Bytes) (err error)

Parameters:

  • TableNameOrRegionName

func (*HbaseClient) MutateRow 

func (p *HbaseClient) MutateRow(ctx context.Context, tableName Text, row Text, mutations []*Mutation, attributes map[string]Text) (err error)

Apply a series of mutations (updates/deletes) to a row in a single transaction. If an exception is thrown, then the transaction is aborted. Default current timestamp is used, and all entries will have an identical timestamp.

Parameters:

  • TableName: name of table
  • Row: row key
  • Mutations: list of mutation commands
  • Attributes: Mutation attributes

func (*HbaseClient) MutateRowTs 

func (p *HbaseClient) MutateRowTs(ctx context.Context, tableName Text, row Text, mutations []*Mutation, timestamp int64, attributes map[string]Text) (err error)

Apply a series of mutations (updates/deletes) to a row in a single transaction. If an exception is thrown, then the transaction is aborted. The specified timestamp is used, and all entries will have an identical timestamp.

Parameters:

  • TableName: name of table
  • Row: row key
  • Mutations: list of mutation commands
  • Timestamp: timestamp
  • Attributes: Mutation attributes

func (*HbaseClient) MutateRows 

func (p *HbaseClient) MutateRows(ctx context.Context, tableName Text, rowBatches []*BatchMutation, attributes map[string]Text) (err error)

Apply a series of batches (each a series of mutations on a single row) in a single transaction. If an exception is thrown, then the transaction is aborted. Default current timestamp is used, and all entries will have an identical timestamp.

Parameters:

  • TableName: name of table
  • RowBatches: list of row batches
  • Attributes: Mutation attributes

func (*HbaseClient) MutateRowsTs 

func (p *HbaseClient) MutateRowsTs(ctx context.Context, tableName Text, rowBatches []*BatchMutation, timestamp int64, attributes map[string]Text) (err error)

Apply a series of batches (each a series of mutations on a single row) in a single transaction. If an exception is thrown, then the transaction is aborted. The specified timestamp is used, and all entries will have an identical timestamp.

Parameters:

  • TableName: name of table
  • RowBatches: list of row batches
  • Timestamp: timestamp
  • Attributes: Mutation attributes

func (*HbaseClient) ScannerClose 

func (p *HbaseClient) ScannerClose(ctx context.Context, id ScannerID) (err error)

Closes the server-state associated with an open scanner.

@throws IllegalArgument if ScannerID is invalid

Parameters:

  • ID: id of a scanner returned by scannerOpen

func (*HbaseClient) ScannerGet 

func (p *HbaseClient) ScannerGet(ctx context.Context, id ScannerID) (r []*TRowResult_, err error)

Returns the scanner's current row value and advances to the next row in the table. When there are no more rows in the table, or a key greater-than-or-equal-to the scanner's specified stopRow is reached, an empty list is returned.

@return a TRowResult containing the current row and a map of the columns to TCells.

@throws IllegalArgument if ScannerID is invalid

@throws NotFound when the scanner reaches the end

Parameters:

  • ID: id of a scanner returned by scannerOpen

func (*HbaseClient) ScannerGetList 

func (p *HbaseClient) ScannerGetList(ctx context.Context, id ScannerID, nbRows int32) (r []*TRowResult_, err error)

Returns, starting at the scanner's current row value nbRows worth of rows and advances to the next row in the table. When there are no more rows in the table, or a key greater-than-or-equal-to the scanner's specified stopRow is reached, an empty list is returned.

@return a TRowResult containing the current row and a map of the columns to TCells.

@throws IllegalArgument if ScannerID is invalid

@throws NotFound when the scanner reaches the end

Parameters:

  • ID: id of a scanner returned by scannerOpen
  • NbRows: number of results to return

func (*HbaseClient) ScannerOpen 

func (p *HbaseClient) ScannerOpen(ctx context.Context, tableName Text, startRow Text, columns []Text, attributes map[string]Text) (r ScannerID, err error)

Get a scanner on the current table starting at the specified row and ending at the last row in the table. Return the specified columns.

@return scanner id to be used with other scanner procedures

Parameters:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Attributes: Scan attributes

func (*HbaseClient) ScannerOpenTs 

func (p *HbaseClient) ScannerOpenTs(ctx context.Context, tableName Text, startRow Text, columns []Text, timestamp int64, attributes map[string]Text) (r ScannerID, err error)

Get a scanner on the current table starting at the specified row and ending at the last row in the table. Return the specified columns. Only values with the specified timestamp are returned.

@return scanner id to be used with other scanner procedures

Parameters:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Timestamp: timestamp
  • Attributes: Scan attributes

func (*HbaseClient) ScannerOpenWithPrefix 

func (p *HbaseClient) ScannerOpenWithPrefix(ctx context.Context, tableName Text, startAndPrefix Text, columns []Text, attributes map[string]Text) (r ScannerID, err error)

Open a scanner for a given prefix. That is all rows will have the specified prefix. No other rows will be returned.

@return scanner id to use with other scanner calls

Parameters:

  • TableName: name of table
  • StartAndPrefix: the prefix (and thus start row) of the keys you want
  • Columns: the columns you want returned
  • Attributes: Scan attributes

func (*HbaseClient) ScannerOpenWithScan 

func (p *HbaseClient) ScannerOpenWithScan(ctx context.Context, tableName Text, scan *TScan, attributes map[string]Text) (r ScannerID, err error)

Get a scanner on the current table, using the Scan instance for the scan parameters.

Parameters:

  • TableName: name of table
  • Scan: Scan instance
  • Attributes: Scan attributes

func (*HbaseClient) ScannerOpenWithStop 

func (p *HbaseClient) ScannerOpenWithStop(ctx context.Context, tableName Text, startRow Text, stopRow Text, columns []Text, attributes map[string]Text) (r ScannerID, err error)

Get a scanner on the current table starting and stopping at the specified rows. ending at the last row in the table. Return the specified columns.

@return scanner id to be used with other scanner procedures

Parameters:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • StopRow: row to stop scanning on. This row is *not* included in the

scanner's results

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Attributes: Scan attributes

func (*HbaseClient) ScannerOpenWithStopTs 

func (p *HbaseClient) ScannerOpenWithStopTs(ctx context.Context, tableName Text, startRow Text, stopRow Text, columns []Text, timestamp int64, attributes map[string]Text) (r ScannerID, err error)

Get a scanner on the current table starting and stopping at the specified rows. ending at the last row in the table. Return the specified columns. Only values with the specified timestamp are returned.

@return scanner id to be used with other scanner procedures

Parameters:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • StopRow: row to stop scanning on. This row is *not* included in the

scanner's results

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Timestamp: timestamp
  • Attributes: Scan attributes

type HbaseCompactArgs 

type HbaseCompactArgs struct {
	TableNameOrRegionName Bytes `thrift:"tableNameOrRegionName,1" db:"tableNameOrRegionName" json:"tableNameOrRegionName"`
}

Attributes:

  • TableNameOrRegionName

func NewHbaseCompactArgs 

func NewHbaseCompactArgs() *HbaseCompactArgs

func (*HbaseCompactArgs) GetTableNameOrRegionName 

func (p *HbaseCompactArgs) GetTableNameOrRegionName() Bytes

func (*HbaseCompactArgs) Read 

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

func (*HbaseCompactArgs) ReadField1 

func (p *HbaseCompactArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseCompactArgs) String 

func (p *HbaseCompactArgs) String() string

func (*HbaseCompactArgs) Write 

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

type HbaseCompactResult 

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

Attributes:

  • Io

func NewHbaseCompactResult 

func NewHbaseCompactResult() *HbaseCompactResult

func (*HbaseCompactResult) GetIo 

func (p *HbaseCompactResult) GetIo() *IOError

func (*HbaseCompactResult) IsSetIo 

func (p *HbaseCompactResult) IsSetIo() bool

func (*HbaseCompactResult) Read 

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

func (*HbaseCompactResult) ReadField1 

func (p *HbaseCompactResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseCompactResult) String 

func (p *HbaseCompactResult) String() string

func (*HbaseCompactResult) Write 

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

type HbaseCreateTableArgs 

type HbaseCreateTableArgs struct {
	TableName      Text                `thrift:"tableName,1" db:"tableName" json:"tableName"`
	ColumnFamilies []*ColumnDescriptor `thrift:"columnFamilies,2" db:"columnFamilies" json:"columnFamilies"`
}

Attributes:

  • TableName: name of table to create
  • ColumnFamilies: list of column family descriptors

func NewHbaseCreateTableArgs 

func NewHbaseCreateTableArgs() *HbaseCreateTableArgs

func (*HbaseCreateTableArgs) GetColumnFamilies 

func (p *HbaseCreateTableArgs) GetColumnFamilies() []*ColumnDescriptor

func (*HbaseCreateTableArgs) GetTableName 

func (p *HbaseCreateTableArgs) GetTableName() Text

func (*HbaseCreateTableArgs) Read 

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

func (*HbaseCreateTableArgs) ReadField1 

func (p *HbaseCreateTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseCreateTableArgs) ReadField2 

func (p *HbaseCreateTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseCreateTableArgs) String 

func (p *HbaseCreateTableArgs) String() string

func (*HbaseCreateTableArgs) Write 

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

type HbaseCreateTableResult 

type HbaseCreateTableResult struct {
	Io    *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia    *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
	Exist *AlreadyExists   `thrift:"exist,3" db:"exist" json:"exist,omitempty"`
}

Attributes:

  • Io
  • Ia
  • Exist

func NewHbaseCreateTableResult 

func NewHbaseCreateTableResult() *HbaseCreateTableResult

func (*HbaseCreateTableResult) GetExist 

func (p *HbaseCreateTableResult) GetExist() *AlreadyExists

func (*HbaseCreateTableResult) GetIa 

func (p *HbaseCreateTableResult) GetIa() *IllegalArgument

func (*HbaseCreateTableResult) GetIo 

func (p *HbaseCreateTableResult) GetIo() *IOError

func (*HbaseCreateTableResult) IsSetExist 

func (p *HbaseCreateTableResult) IsSetExist() bool

func (*HbaseCreateTableResult) IsSetIa 

func (p *HbaseCreateTableResult) IsSetIa() bool

func (*HbaseCreateTableResult) IsSetIo 

func (p *HbaseCreateTableResult) IsSetIo() bool

func (*HbaseCreateTableResult) Read 

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

func (*HbaseCreateTableResult) ReadField1 

func (p *HbaseCreateTableResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseCreateTableResult) ReadField2 

func (p *HbaseCreateTableResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseCreateTableResult) ReadField3 

func (p *HbaseCreateTableResult) ReadField3(iprot thrift.TProtocol) error

func (*HbaseCreateTableResult) String 

func (p *HbaseCreateTableResult) String() string

func (*HbaseCreateTableResult) Write 

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

type HbaseDeleteAllArgs 

type HbaseDeleteAllArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Column     Text            `thrift:"column,3" db:"column" json:"column"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: Row to update
  • Column: name of column whose value is to be deleted
  • Attributes: Delete attributes

func NewHbaseDeleteAllArgs 

func NewHbaseDeleteAllArgs() *HbaseDeleteAllArgs

func (*HbaseDeleteAllArgs) GetAttributes 

func (p *HbaseDeleteAllArgs) GetAttributes() map[string]Text

func (*HbaseDeleteAllArgs) GetColumn 

func (p *HbaseDeleteAllArgs) GetColumn() Text

func (*HbaseDeleteAllArgs) GetRow 

func (p *HbaseDeleteAllArgs) GetRow() Text

func (*HbaseDeleteAllArgs) GetTableName 

func (p *HbaseDeleteAllArgs) GetTableName() Text

func (*HbaseDeleteAllArgs) Read 

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

func (*HbaseDeleteAllArgs) ReadField1 

func (p *HbaseDeleteAllArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllArgs) ReadField2 

func (p *HbaseDeleteAllArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseDeleteAllArgs) ReadField3 

func (p *HbaseDeleteAllArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseDeleteAllArgs) ReadField4 

func (p *HbaseDeleteAllArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseDeleteAllArgs) String 

func (p *HbaseDeleteAllArgs) String() string

func (*HbaseDeleteAllArgs) Write 

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

type HbaseDeleteAllResult 

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

Attributes:

  • Io

func NewHbaseDeleteAllResult 

func NewHbaseDeleteAllResult() *HbaseDeleteAllResult

func (*HbaseDeleteAllResult) GetIo 

func (p *HbaseDeleteAllResult) GetIo() *IOError

func (*HbaseDeleteAllResult) IsSetIo 

func (p *HbaseDeleteAllResult) IsSetIo() bool

func (*HbaseDeleteAllResult) Read 

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

func (*HbaseDeleteAllResult) ReadField1 

func (p *HbaseDeleteAllResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllResult) String 

func (p *HbaseDeleteAllResult) String() string

func (*HbaseDeleteAllResult) Write 

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

type HbaseDeleteAllRowArgs 

type HbaseDeleteAllRowArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Attributes map[string]Text `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: key of the row to be completely deleted.
  • Attributes: Delete attributes

func NewHbaseDeleteAllRowArgs 

func NewHbaseDeleteAllRowArgs() *HbaseDeleteAllRowArgs

func (*HbaseDeleteAllRowArgs) GetAttributes 

func (p *HbaseDeleteAllRowArgs) GetAttributes() map[string]Text

func (*HbaseDeleteAllRowArgs) GetRow 

func (p *HbaseDeleteAllRowArgs) GetRow() Text

func (*HbaseDeleteAllRowArgs) GetTableName 

func (p *HbaseDeleteAllRowArgs) GetTableName() Text

func (*HbaseDeleteAllRowArgs) Read 

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

func (*HbaseDeleteAllRowArgs) ReadField1 

func (p *HbaseDeleteAllRowArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowArgs) ReadField2 

func (p *HbaseDeleteAllRowArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowArgs) ReadField3 

func (p *HbaseDeleteAllRowArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowArgs) String 

func (p *HbaseDeleteAllRowArgs) String() string

func (*HbaseDeleteAllRowArgs) Write 

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

type HbaseDeleteAllRowResult 

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

Attributes:

  • Io

func NewHbaseDeleteAllRowResult 

func NewHbaseDeleteAllRowResult() *HbaseDeleteAllRowResult

func (*HbaseDeleteAllRowResult) GetIo 

func (p *HbaseDeleteAllRowResult) GetIo() *IOError

func (*HbaseDeleteAllRowResult) IsSetIo 

func (p *HbaseDeleteAllRowResult) IsSetIo() bool

func (*HbaseDeleteAllRowResult) Read 

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

func (*HbaseDeleteAllRowResult) ReadField1 

func (p *HbaseDeleteAllRowResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowResult) String 

func (p *HbaseDeleteAllRowResult) String() string

func (*HbaseDeleteAllRowResult) Write 

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

type HbaseDeleteAllRowTsArgs 

type HbaseDeleteAllRowTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Timestamp  int64           `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: key of the row to be completely deleted.
  • Timestamp: timestamp
  • Attributes: Delete attributes

func NewHbaseDeleteAllRowTsArgs 

func NewHbaseDeleteAllRowTsArgs() *HbaseDeleteAllRowTsArgs

func (*HbaseDeleteAllRowTsArgs) GetAttributes 

func (p *HbaseDeleteAllRowTsArgs) GetAttributes() map[string]Text

func (*HbaseDeleteAllRowTsArgs) GetRow 

func (p *HbaseDeleteAllRowTsArgs) GetRow() Text

func (*HbaseDeleteAllRowTsArgs) GetTableName 

func (p *HbaseDeleteAllRowTsArgs) GetTableName() Text

func (*HbaseDeleteAllRowTsArgs) GetTimestamp 

func (p *HbaseDeleteAllRowTsArgs) GetTimestamp() int64

func (*HbaseDeleteAllRowTsArgs) Read 

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

func (*HbaseDeleteAllRowTsArgs) ReadField1 

func (p *HbaseDeleteAllRowTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowTsArgs) ReadField2 

func (p *HbaseDeleteAllRowTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowTsArgs) ReadField3 

func (p *HbaseDeleteAllRowTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowTsArgs) ReadField4 

func (p *HbaseDeleteAllRowTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowTsArgs) String 

func (p *HbaseDeleteAllRowTsArgs) String() string

func (*HbaseDeleteAllRowTsArgs) Write 

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

type HbaseDeleteAllRowTsResult 

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

Attributes:

  • Io

func NewHbaseDeleteAllRowTsResult 

func NewHbaseDeleteAllRowTsResult() *HbaseDeleteAllRowTsResult

func (*HbaseDeleteAllRowTsResult) GetIo 

func (p *HbaseDeleteAllRowTsResult) GetIo() *IOError

func (*HbaseDeleteAllRowTsResult) IsSetIo 

func (p *HbaseDeleteAllRowTsResult) IsSetIo() bool

func (*HbaseDeleteAllRowTsResult) Read 

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

func (*HbaseDeleteAllRowTsResult) ReadField1 

func (p *HbaseDeleteAllRowTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllRowTsResult) String 

func (p *HbaseDeleteAllRowTsResult) String() string

func (*HbaseDeleteAllRowTsResult) Write 

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

type HbaseDeleteAllTsArgs 

type HbaseDeleteAllTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Column     Text            `thrift:"column,3" db:"column" json:"column"`
	Timestamp  int64           `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: Row to update
  • Column: name of column whose value is to be deleted
  • Timestamp: timestamp
  • Attributes: Delete attributes

func NewHbaseDeleteAllTsArgs 

func NewHbaseDeleteAllTsArgs() *HbaseDeleteAllTsArgs

func (*HbaseDeleteAllTsArgs) GetAttributes 

func (p *HbaseDeleteAllTsArgs) GetAttributes() map[string]Text

func (*HbaseDeleteAllTsArgs) GetColumn 

func (p *HbaseDeleteAllTsArgs) GetColumn() Text

func (*HbaseDeleteAllTsArgs) GetRow 

func (p *HbaseDeleteAllTsArgs) GetRow() Text

func (*HbaseDeleteAllTsArgs) GetTableName 

func (p *HbaseDeleteAllTsArgs) GetTableName() Text

func (*HbaseDeleteAllTsArgs) GetTimestamp 

func (p *HbaseDeleteAllTsArgs) GetTimestamp() int64

func (*HbaseDeleteAllTsArgs) Read 

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

func (*HbaseDeleteAllTsArgs) ReadField1 

func (p *HbaseDeleteAllTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllTsArgs) ReadField2 

func (p *HbaseDeleteAllTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseDeleteAllTsArgs) ReadField3 

func (p *HbaseDeleteAllTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseDeleteAllTsArgs) ReadField4 

func (p *HbaseDeleteAllTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseDeleteAllTsArgs) ReadField5 

func (p *HbaseDeleteAllTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseDeleteAllTsArgs) String 

func (p *HbaseDeleteAllTsArgs) String() string

func (*HbaseDeleteAllTsArgs) Write 

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

type HbaseDeleteAllTsResult 

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

Attributes:

  • Io

func NewHbaseDeleteAllTsResult 

func NewHbaseDeleteAllTsResult() *HbaseDeleteAllTsResult

func (*HbaseDeleteAllTsResult) GetIo 

func (p *HbaseDeleteAllTsResult) GetIo() *IOError

func (*HbaseDeleteAllTsResult) IsSetIo 

func (p *HbaseDeleteAllTsResult) IsSetIo() bool

func (*HbaseDeleteAllTsResult) Read 

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

func (*HbaseDeleteAllTsResult) ReadField1 

func (p *HbaseDeleteAllTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteAllTsResult) String 

func (p *HbaseDeleteAllTsResult) String() string

func (*HbaseDeleteAllTsResult) Write 

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

type HbaseDeleteTableArgs 

type HbaseDeleteTableArgs struct {
	TableName Text `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: name of table to delete

func NewHbaseDeleteTableArgs 

func NewHbaseDeleteTableArgs() *HbaseDeleteTableArgs

func (*HbaseDeleteTableArgs) GetTableName 

func (p *HbaseDeleteTableArgs) GetTableName() Text

func (*HbaseDeleteTableArgs) Read 

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

func (*HbaseDeleteTableArgs) ReadField1 

func (p *HbaseDeleteTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteTableArgs) String 

func (p *HbaseDeleteTableArgs) String() string

func (*HbaseDeleteTableArgs) Write 

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

type HbaseDeleteTableResult 

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

Attributes:

  • Io

func NewHbaseDeleteTableResult 

func NewHbaseDeleteTableResult() *HbaseDeleteTableResult

func (*HbaseDeleteTableResult) GetIo 

func (p *HbaseDeleteTableResult) GetIo() *IOError

func (*HbaseDeleteTableResult) IsSetIo 

func (p *HbaseDeleteTableResult) IsSetIo() bool

func (*HbaseDeleteTableResult) Read 

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

func (*HbaseDeleteTableResult) ReadField1 

func (p *HbaseDeleteTableResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDeleteTableResult) String 

func (p *HbaseDeleteTableResult) String() string

func (*HbaseDeleteTableResult) Write 

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

type HbaseDisableTableArgs 

type HbaseDisableTableArgs struct {
	TableName Bytes `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: name of the table

func NewHbaseDisableTableArgs 

func NewHbaseDisableTableArgs() *HbaseDisableTableArgs

func (*HbaseDisableTableArgs) GetTableName 

func (p *HbaseDisableTableArgs) GetTableName() Bytes

func (*HbaseDisableTableArgs) Read 

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

func (*HbaseDisableTableArgs) ReadField1 

func (p *HbaseDisableTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDisableTableArgs) String 

func (p *HbaseDisableTableArgs) String() string

func (*HbaseDisableTableArgs) Write 

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

type HbaseDisableTableResult 

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

Attributes:

  • Io

func NewHbaseDisableTableResult 

func NewHbaseDisableTableResult() *HbaseDisableTableResult

func (*HbaseDisableTableResult) GetIo 

func (p *HbaseDisableTableResult) GetIo() *IOError

func (*HbaseDisableTableResult) IsSetIo 

func (p *HbaseDisableTableResult) IsSetIo() bool

func (*HbaseDisableTableResult) Read 

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

func (*HbaseDisableTableResult) ReadField1 

func (p *HbaseDisableTableResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseDisableTableResult) String 

func (p *HbaseDisableTableResult) String() string

func (*HbaseDisableTableResult) Write 

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

type HbaseEnableTableArgs 

type HbaseEnableTableArgs struct {
	TableName Bytes `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: name of the table

func NewHbaseEnableTableArgs 

func NewHbaseEnableTableArgs() *HbaseEnableTableArgs

func (*HbaseEnableTableArgs) GetTableName 

func (p *HbaseEnableTableArgs) GetTableName() Bytes

func (*HbaseEnableTableArgs) Read 

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

func (*HbaseEnableTableArgs) ReadField1 

func (p *HbaseEnableTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseEnableTableArgs) String 

func (p *HbaseEnableTableArgs) String() string

func (*HbaseEnableTableArgs) Write 

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

type HbaseEnableTableResult 

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

Attributes:

  • Io

func NewHbaseEnableTableResult 

func NewHbaseEnableTableResult() *HbaseEnableTableResult

func (*HbaseEnableTableResult) GetIo 

func (p *HbaseEnableTableResult) GetIo() *IOError

func (*HbaseEnableTableResult) IsSetIo 

func (p *HbaseEnableTableResult) IsSetIo() bool

func (*HbaseEnableTableResult) Read 

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

func (*HbaseEnableTableResult) ReadField1 

func (p *HbaseEnableTableResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseEnableTableResult) String 

func (p *HbaseEnableTableResult) String() string

func (*HbaseEnableTableResult) Write 

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

type HbaseGetArgs 

type HbaseGetArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Column     Text            `thrift:"column,3" db:"column" json:"column"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • Attributes: Get attributes

func NewHbaseGetArgs 

func NewHbaseGetArgs() *HbaseGetArgs

func (*HbaseGetArgs) GetAttributes 

func (p *HbaseGetArgs) GetAttributes() map[string]Text

func (*HbaseGetArgs) GetColumn 

func (p *HbaseGetArgs) GetColumn() Text

func (*HbaseGetArgs) GetRow 

func (p *HbaseGetArgs) GetRow() Text

func (*HbaseGetArgs) GetTableName 

func (p *HbaseGetArgs) GetTableName() Text

func (*HbaseGetArgs) Read 

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

func (*HbaseGetArgs) ReadField1 

func (p *HbaseGetArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetArgs) ReadField2 

func (p *HbaseGetArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetArgs) ReadField3 

func (p *HbaseGetArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetArgs) ReadField4 

func (p *HbaseGetArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetArgs) String 

func (p *HbaseGetArgs) String() string

func (*HbaseGetArgs) Write 

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

type HbaseGetColumnDescriptorsArgs 

type HbaseGetColumnDescriptorsArgs struct {
	TableName Text `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: table name

func NewHbaseGetColumnDescriptorsArgs 

func NewHbaseGetColumnDescriptorsArgs() *HbaseGetColumnDescriptorsArgs

func (*HbaseGetColumnDescriptorsArgs) GetTableName 

func (p *HbaseGetColumnDescriptorsArgs) GetTableName() Text

func (*HbaseGetColumnDescriptorsArgs) Read 

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

func (*HbaseGetColumnDescriptorsArgs) ReadField1 

func (p *HbaseGetColumnDescriptorsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetColumnDescriptorsArgs) String 

func (p *HbaseGetColumnDescriptorsArgs) String() string

func (*HbaseGetColumnDescriptorsArgs) Write 

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

type HbaseGetColumnDescriptorsResult 

type HbaseGetColumnDescriptorsResult struct {
	Success map[string]*ColumnDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError                     `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetColumnDescriptorsResult 

func NewHbaseGetColumnDescriptorsResult() *HbaseGetColumnDescriptorsResult

func (*HbaseGetColumnDescriptorsResult) GetIo 

func (p *HbaseGetColumnDescriptorsResult) GetIo() *IOError

func (*HbaseGetColumnDescriptorsResult) GetSuccess 

func (p *HbaseGetColumnDescriptorsResult) GetSuccess() map[string]*ColumnDescriptor

func (*HbaseGetColumnDescriptorsResult) IsSetIo 

func (p *HbaseGetColumnDescriptorsResult) IsSetIo() bool

func (*HbaseGetColumnDescriptorsResult) IsSetSuccess 

func (p *HbaseGetColumnDescriptorsResult) IsSetSuccess() bool

func (*HbaseGetColumnDescriptorsResult) Read 

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

func (*HbaseGetColumnDescriptorsResult) ReadField0 

func (p *HbaseGetColumnDescriptorsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetColumnDescriptorsResult) ReadField1 

func (p *HbaseGetColumnDescriptorsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetColumnDescriptorsResult) String 

func (p *HbaseGetColumnDescriptorsResult) String() string

func (*HbaseGetColumnDescriptorsResult) Write 

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

type HbaseGetRegionInfoArgs 

type HbaseGetRegionInfoArgs struct {
	Row Text `thrift:"row,1" db:"row" json:"row"`
}

Attributes:

  • Row: row key

func NewHbaseGetRegionInfoArgs 

func NewHbaseGetRegionInfoArgs() *HbaseGetRegionInfoArgs

func (*HbaseGetRegionInfoArgs) GetRow 

func (p *HbaseGetRegionInfoArgs) GetRow() Text

func (*HbaseGetRegionInfoArgs) Read 

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

func (*HbaseGetRegionInfoArgs) ReadField1 

func (p *HbaseGetRegionInfoArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRegionInfoArgs) String 

func (p *HbaseGetRegionInfoArgs) String() string

func (*HbaseGetRegionInfoArgs) Write 

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

type HbaseGetRegionInfoResult 

type HbaseGetRegionInfoResult struct {
	Success *TRegionInfo `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError     `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRegionInfoResult 

func NewHbaseGetRegionInfoResult() *HbaseGetRegionInfoResult

func (*HbaseGetRegionInfoResult) GetIo 

func (p *HbaseGetRegionInfoResult) GetIo() *IOError

func (*HbaseGetRegionInfoResult) GetSuccess 

func (p *HbaseGetRegionInfoResult) GetSuccess() *TRegionInfo

func (*HbaseGetRegionInfoResult) IsSetIo 

func (p *HbaseGetRegionInfoResult) IsSetIo() bool

func (*HbaseGetRegionInfoResult) IsSetSuccess 

func (p *HbaseGetRegionInfoResult) IsSetSuccess() bool

func (*HbaseGetRegionInfoResult) Read 

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

func (*HbaseGetRegionInfoResult) ReadField0 

func (p *HbaseGetRegionInfoResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRegionInfoResult) ReadField1 

func (p *HbaseGetRegionInfoResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRegionInfoResult) String 

func (p *HbaseGetRegionInfoResult) String() string

func (*HbaseGetRegionInfoResult) Write 

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

type HbaseGetResult 

type HbaseGetResult struct {
	Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetResult 

func NewHbaseGetResult() *HbaseGetResult

func (*HbaseGetResult) GetIo 

func (p *HbaseGetResult) GetIo() *IOError

func (*HbaseGetResult) GetSuccess 

func (p *HbaseGetResult) GetSuccess() []*TCell

func (*HbaseGetResult) IsSetIo 

func (p *HbaseGetResult) IsSetIo() bool

func (*HbaseGetResult) IsSetSuccess 

func (p *HbaseGetResult) IsSetSuccess() bool

func (*HbaseGetResult) Read 

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

func (*HbaseGetResult) ReadField0 

func (p *HbaseGetResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetResult) ReadField1 

func (p *HbaseGetResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetResult) String 

func (p *HbaseGetResult) String() string

func (*HbaseGetResult) Write 

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

type HbaseGetRowArgs 

type HbaseGetRowArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Attributes map[string]Text `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Attributes: Get attributes

func NewHbaseGetRowArgs 

func NewHbaseGetRowArgs() *HbaseGetRowArgs

func (*HbaseGetRowArgs) GetAttributes 

func (p *HbaseGetRowArgs) GetAttributes() map[string]Text

func (*HbaseGetRowArgs) GetRow 

func (p *HbaseGetRowArgs) GetRow() Text

func (*HbaseGetRowArgs) GetTableName 

func (p *HbaseGetRowArgs) GetTableName() Text

func (*HbaseGetRowArgs) Read 

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

func (*HbaseGetRowArgs) ReadField1 

func (p *HbaseGetRowArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowArgs) ReadField2 

func (p *HbaseGetRowArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowArgs) ReadField3 

func (p *HbaseGetRowArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowArgs) String 

func (p *HbaseGetRowArgs) String() string

func (*HbaseGetRowArgs) Write 

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

type HbaseGetRowOrBeforeArgs 

type HbaseGetRowOrBeforeArgs struct {
	TableName Text `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row       Text `thrift:"row,2" db:"row" json:"row"`
	Family    Text `thrift:"family,3" db:"family" json:"family"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Family: column name

func NewHbaseGetRowOrBeforeArgs 

func NewHbaseGetRowOrBeforeArgs() *HbaseGetRowOrBeforeArgs

func (*HbaseGetRowOrBeforeArgs) GetFamily 

func (p *HbaseGetRowOrBeforeArgs) GetFamily() Text

func (*HbaseGetRowOrBeforeArgs) GetRow 

func (p *HbaseGetRowOrBeforeArgs) GetRow() Text

func (*HbaseGetRowOrBeforeArgs) GetTableName 

func (p *HbaseGetRowOrBeforeArgs) GetTableName() Text

func (*HbaseGetRowOrBeforeArgs) Read 

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

func (*HbaseGetRowOrBeforeArgs) ReadField1 

func (p *HbaseGetRowOrBeforeArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowOrBeforeArgs) ReadField2 

func (p *HbaseGetRowOrBeforeArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowOrBeforeArgs) ReadField3 

func (p *HbaseGetRowOrBeforeArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowOrBeforeArgs) String 

func (p *HbaseGetRowOrBeforeArgs) String() string

func (*HbaseGetRowOrBeforeArgs) Write 

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

type HbaseGetRowOrBeforeResult 

type HbaseGetRowOrBeforeResult struct {
	Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowOrBeforeResult 

func NewHbaseGetRowOrBeforeResult() *HbaseGetRowOrBeforeResult

func (*HbaseGetRowOrBeforeResult) GetIo 

func (p *HbaseGetRowOrBeforeResult) GetIo() *IOError

func (*HbaseGetRowOrBeforeResult) GetSuccess 

func (p *HbaseGetRowOrBeforeResult) GetSuccess() []*TCell

func (*HbaseGetRowOrBeforeResult) IsSetIo 

func (p *HbaseGetRowOrBeforeResult) IsSetIo() bool

func (*HbaseGetRowOrBeforeResult) IsSetSuccess 

func (p *HbaseGetRowOrBeforeResult) IsSetSuccess() bool

func (*HbaseGetRowOrBeforeResult) Read 

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

func (*HbaseGetRowOrBeforeResult) ReadField0 

func (p *HbaseGetRowOrBeforeResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowOrBeforeResult) ReadField1 

func (p *HbaseGetRowOrBeforeResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowOrBeforeResult) String 

func (p *HbaseGetRowOrBeforeResult) String() string

func (*HbaseGetRowOrBeforeResult) Write 

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

type HbaseGetRowResult 

type HbaseGetRowResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowResult 

func NewHbaseGetRowResult() *HbaseGetRowResult

func (*HbaseGetRowResult) GetIo 

func (p *HbaseGetRowResult) GetIo() *IOError

func (*HbaseGetRowResult) GetSuccess 

func (p *HbaseGetRowResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowResult) IsSetIo 

func (p *HbaseGetRowResult) IsSetIo() bool

func (*HbaseGetRowResult) IsSetSuccess 

func (p *HbaseGetRowResult) IsSetSuccess() bool

func (*HbaseGetRowResult) Read 

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

func (*HbaseGetRowResult) ReadField0 

func (p *HbaseGetRowResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowResult) ReadField1 

func (p *HbaseGetRowResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowResult) String 

func (p *HbaseGetRowResult) String() string

func (*HbaseGetRowResult) Write 

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

type HbaseGetRowTsArgs 

type HbaseGetRowTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Timestamp  int64           `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of the table
  • Row: row key
  • Timestamp: timestamp
  • Attributes: Get attributes

func NewHbaseGetRowTsArgs 

func NewHbaseGetRowTsArgs() *HbaseGetRowTsArgs

func (*HbaseGetRowTsArgs) GetAttributes 

func (p *HbaseGetRowTsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowTsArgs) GetRow 

func (p *HbaseGetRowTsArgs) GetRow() Text

func (*HbaseGetRowTsArgs) GetTableName 

func (p *HbaseGetRowTsArgs) GetTableName() Text

func (*HbaseGetRowTsArgs) GetTimestamp 

func (p *HbaseGetRowTsArgs) GetTimestamp() int64

func (*HbaseGetRowTsArgs) Read 

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

func (*HbaseGetRowTsArgs) ReadField1 

func (p *HbaseGetRowTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowTsArgs) ReadField2 

func (p *HbaseGetRowTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowTsArgs) ReadField3 

func (p *HbaseGetRowTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowTsArgs) ReadField4 

func (p *HbaseGetRowTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetRowTsArgs) String 

func (p *HbaseGetRowTsArgs) String() string

func (*HbaseGetRowTsArgs) Write 

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

type HbaseGetRowTsResult 

type HbaseGetRowTsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowTsResult 

func NewHbaseGetRowTsResult() *HbaseGetRowTsResult

func (*HbaseGetRowTsResult) GetIo 

func (p *HbaseGetRowTsResult) GetIo() *IOError

func (*HbaseGetRowTsResult) GetSuccess 

func (p *HbaseGetRowTsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowTsResult) IsSetIo 

func (p *HbaseGetRowTsResult) IsSetIo() bool

func (*HbaseGetRowTsResult) IsSetSuccess 

func (p *HbaseGetRowTsResult) IsSetSuccess() bool

func (*HbaseGetRowTsResult) Read 

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

func (*HbaseGetRowTsResult) ReadField0 

func (p *HbaseGetRowTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowTsResult) ReadField1 

func (p *HbaseGetRowTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowTsResult) String 

func (p *HbaseGetRowTsResult) String() string

func (*HbaseGetRowTsResult) Write 

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

type HbaseGetRowWithColumnsArgs 

type HbaseGetRowWithColumnsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Columns    []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Columns: List of columns to return, null for all columns
  • Attributes: Get attributes

func NewHbaseGetRowWithColumnsArgs 

func NewHbaseGetRowWithColumnsArgs() *HbaseGetRowWithColumnsArgs

func (*HbaseGetRowWithColumnsArgs) GetAttributes 

func (p *HbaseGetRowWithColumnsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowWithColumnsArgs) GetColumns 

func (p *HbaseGetRowWithColumnsArgs) GetColumns() []Text

func (*HbaseGetRowWithColumnsArgs) GetRow 

func (p *HbaseGetRowWithColumnsArgs) GetRow() Text

func (*HbaseGetRowWithColumnsArgs) GetTableName 

func (p *HbaseGetRowWithColumnsArgs) GetTableName() Text

func (*HbaseGetRowWithColumnsArgs) Read 

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

func (*HbaseGetRowWithColumnsArgs) ReadField1 

func (p *HbaseGetRowWithColumnsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsArgs) ReadField2 

func (p *HbaseGetRowWithColumnsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsArgs) ReadField3 

func (p *HbaseGetRowWithColumnsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsArgs) ReadField4 

func (p *HbaseGetRowWithColumnsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsArgs) String 

func (p *HbaseGetRowWithColumnsArgs) String() string

func (*HbaseGetRowWithColumnsArgs) Write 

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

type HbaseGetRowWithColumnsResult 

type HbaseGetRowWithColumnsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowWithColumnsResult 

func NewHbaseGetRowWithColumnsResult() *HbaseGetRowWithColumnsResult

func (*HbaseGetRowWithColumnsResult) GetIo 

func (p *HbaseGetRowWithColumnsResult) GetIo() *IOError

func (*HbaseGetRowWithColumnsResult) GetSuccess 

func (p *HbaseGetRowWithColumnsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowWithColumnsResult) IsSetIo 

func (p *HbaseGetRowWithColumnsResult) IsSetIo() bool

func (*HbaseGetRowWithColumnsResult) IsSetSuccess 

func (p *HbaseGetRowWithColumnsResult) IsSetSuccess() bool

func (*HbaseGetRowWithColumnsResult) Read 

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

func (*HbaseGetRowWithColumnsResult) ReadField0 

func (p *HbaseGetRowWithColumnsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsResult) ReadField1 

func (p *HbaseGetRowWithColumnsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsResult) String 

func (p *HbaseGetRowWithColumnsResult) String() string

func (*HbaseGetRowWithColumnsResult) Write 

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

type HbaseGetRowWithColumnsTsArgs 

type HbaseGetRowWithColumnsTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Columns    []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Timestamp  int64           `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Columns: List of columns to return, null for all columns
  • Timestamp
  • Attributes: Get attributes

func NewHbaseGetRowWithColumnsTsArgs 

func NewHbaseGetRowWithColumnsTsArgs() *HbaseGetRowWithColumnsTsArgs

func (*HbaseGetRowWithColumnsTsArgs) GetAttributes 

func (p *HbaseGetRowWithColumnsTsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowWithColumnsTsArgs) GetColumns 

func (p *HbaseGetRowWithColumnsTsArgs) GetColumns() []Text

func (*HbaseGetRowWithColumnsTsArgs) GetRow 

func (p *HbaseGetRowWithColumnsTsArgs) GetRow() Text

func (*HbaseGetRowWithColumnsTsArgs) GetTableName 

func (p *HbaseGetRowWithColumnsTsArgs) GetTableName() Text

func (*HbaseGetRowWithColumnsTsArgs) GetTimestamp 

func (p *HbaseGetRowWithColumnsTsArgs) GetTimestamp() int64

func (*HbaseGetRowWithColumnsTsArgs) Read 

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

func (*HbaseGetRowWithColumnsTsArgs) ReadField1 

func (p *HbaseGetRowWithColumnsTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsArgs) ReadField2 

func (p *HbaseGetRowWithColumnsTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsArgs) ReadField3 

func (p *HbaseGetRowWithColumnsTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsArgs) ReadField4 

func (p *HbaseGetRowWithColumnsTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsArgs) ReadField5 

func (p *HbaseGetRowWithColumnsTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsArgs) String 

func (p *HbaseGetRowWithColumnsTsArgs) String() string

func (*HbaseGetRowWithColumnsTsArgs) Write 

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

type HbaseGetRowWithColumnsTsResult 

type HbaseGetRowWithColumnsTsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowWithColumnsTsResult 

func NewHbaseGetRowWithColumnsTsResult() *HbaseGetRowWithColumnsTsResult

func (*HbaseGetRowWithColumnsTsResult) GetIo 

func (p *HbaseGetRowWithColumnsTsResult) GetIo() *IOError

func (*HbaseGetRowWithColumnsTsResult) GetSuccess 

func (p *HbaseGetRowWithColumnsTsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowWithColumnsTsResult) IsSetIo 

func (p *HbaseGetRowWithColumnsTsResult) IsSetIo() bool

func (*HbaseGetRowWithColumnsTsResult) IsSetSuccess 

func (p *HbaseGetRowWithColumnsTsResult) IsSetSuccess() bool

func (*HbaseGetRowWithColumnsTsResult) Read 

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

func (*HbaseGetRowWithColumnsTsResult) ReadField0 

func (p *HbaseGetRowWithColumnsTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsResult) ReadField1 

func (p *HbaseGetRowWithColumnsTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowWithColumnsTsResult) String 

func (p *HbaseGetRowWithColumnsTsResult) String() string

func (*HbaseGetRowWithColumnsTsResult) Write 

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

type HbaseGetRowsArgs 

type HbaseGetRowsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Rows       []Text          `thrift:"rows,2" db:"rows" json:"rows"`
	Attributes map[string]Text `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Rows: row keys
  • Attributes: Get attributes

func NewHbaseGetRowsArgs 

func NewHbaseGetRowsArgs() *HbaseGetRowsArgs

func (*HbaseGetRowsArgs) GetAttributes 

func (p *HbaseGetRowsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowsArgs) GetRows 

func (p *HbaseGetRowsArgs) GetRows() []Text

func (*HbaseGetRowsArgs) GetTableName 

func (p *HbaseGetRowsArgs) GetTableName() Text

func (*HbaseGetRowsArgs) Read 

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

func (*HbaseGetRowsArgs) ReadField1 

func (p *HbaseGetRowsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsArgs) ReadField2 

func (p *HbaseGetRowsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowsArgs) ReadField3 

func (p *HbaseGetRowsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowsArgs) String 

func (p *HbaseGetRowsArgs) String() string

func (*HbaseGetRowsArgs) Write 

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

type HbaseGetRowsResult 

type HbaseGetRowsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowsResult 

func NewHbaseGetRowsResult() *HbaseGetRowsResult

func (*HbaseGetRowsResult) GetIo 

func (p *HbaseGetRowsResult) GetIo() *IOError

func (*HbaseGetRowsResult) GetSuccess 

func (p *HbaseGetRowsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowsResult) IsSetIo 

func (p *HbaseGetRowsResult) IsSetIo() bool

func (*HbaseGetRowsResult) IsSetSuccess 

func (p *HbaseGetRowsResult) IsSetSuccess() bool

func (*HbaseGetRowsResult) Read 

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

func (*HbaseGetRowsResult) ReadField0 

func (p *HbaseGetRowsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowsResult) ReadField1 

func (p *HbaseGetRowsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsResult) String 

func (p *HbaseGetRowsResult) String() string

func (*HbaseGetRowsResult) Write 

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

type HbaseGetRowsTsArgs 

type HbaseGetRowsTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Rows       []Text          `thrift:"rows,2" db:"rows" json:"rows"`
	Timestamp  int64           `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of the table
  • Rows: row keys
  • Timestamp: timestamp
  • Attributes: Get attributes

func NewHbaseGetRowsTsArgs 

func NewHbaseGetRowsTsArgs() *HbaseGetRowsTsArgs

func (*HbaseGetRowsTsArgs) GetAttributes 

func (p *HbaseGetRowsTsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowsTsArgs) GetRows 

func (p *HbaseGetRowsTsArgs) GetRows() []Text

func (*HbaseGetRowsTsArgs) GetTableName 

func (p *HbaseGetRowsTsArgs) GetTableName() Text

func (*HbaseGetRowsTsArgs) GetTimestamp 

func (p *HbaseGetRowsTsArgs) GetTimestamp() int64

func (*HbaseGetRowsTsArgs) Read 

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

func (*HbaseGetRowsTsArgs) ReadField1 

func (p *HbaseGetRowsTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsTsArgs) ReadField2 

func (p *HbaseGetRowsTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowsTsArgs) ReadField3 

func (p *HbaseGetRowsTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowsTsArgs) ReadField4 

func (p *HbaseGetRowsTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetRowsTsArgs) String 

func (p *HbaseGetRowsTsArgs) String() string

func (*HbaseGetRowsTsArgs) Write 

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

type HbaseGetRowsTsResult 

type HbaseGetRowsTsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowsTsResult 

func NewHbaseGetRowsTsResult() *HbaseGetRowsTsResult

func (*HbaseGetRowsTsResult) GetIo 

func (p *HbaseGetRowsTsResult) GetIo() *IOError

func (*HbaseGetRowsTsResult) GetSuccess 

func (p *HbaseGetRowsTsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowsTsResult) IsSetIo 

func (p *HbaseGetRowsTsResult) IsSetIo() bool

func (*HbaseGetRowsTsResult) IsSetSuccess 

func (p *HbaseGetRowsTsResult) IsSetSuccess() bool

func (*HbaseGetRowsTsResult) Read 

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

func (*HbaseGetRowsTsResult) ReadField0 

func (p *HbaseGetRowsTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowsTsResult) ReadField1 

func (p *HbaseGetRowsTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsTsResult) String 

func (p *HbaseGetRowsTsResult) String() string

func (*HbaseGetRowsTsResult) Write 

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

type HbaseGetRowsWithColumnsArgs 

type HbaseGetRowsWithColumnsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Rows       []Text          `thrift:"rows,2" db:"rows" json:"rows"`
	Columns    []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Rows: row keys
  • Columns: List of columns to return, null for all columns
  • Attributes: Get attributes

func NewHbaseGetRowsWithColumnsArgs 

func NewHbaseGetRowsWithColumnsArgs() *HbaseGetRowsWithColumnsArgs

func (*HbaseGetRowsWithColumnsArgs) GetAttributes 

func (p *HbaseGetRowsWithColumnsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowsWithColumnsArgs) GetColumns 

func (p *HbaseGetRowsWithColumnsArgs) GetColumns() []Text

func (*HbaseGetRowsWithColumnsArgs) GetRows 

func (p *HbaseGetRowsWithColumnsArgs) GetRows() []Text

func (*HbaseGetRowsWithColumnsArgs) GetTableName 

func (p *HbaseGetRowsWithColumnsArgs) GetTableName() Text

func (*HbaseGetRowsWithColumnsArgs) Read 

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

func (*HbaseGetRowsWithColumnsArgs) ReadField1 

func (p *HbaseGetRowsWithColumnsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsArgs) ReadField2 

func (p *HbaseGetRowsWithColumnsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsArgs) ReadField3 

func (p *HbaseGetRowsWithColumnsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsArgs) ReadField4 

func (p *HbaseGetRowsWithColumnsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsArgs) String 

func (p *HbaseGetRowsWithColumnsArgs) String() string

func (*HbaseGetRowsWithColumnsArgs) Write 

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

type HbaseGetRowsWithColumnsResult 

type HbaseGetRowsWithColumnsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowsWithColumnsResult 

func NewHbaseGetRowsWithColumnsResult() *HbaseGetRowsWithColumnsResult

func (*HbaseGetRowsWithColumnsResult) GetIo 

func (p *HbaseGetRowsWithColumnsResult) GetIo() *IOError

func (*HbaseGetRowsWithColumnsResult) GetSuccess 

func (p *HbaseGetRowsWithColumnsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowsWithColumnsResult) IsSetIo 

func (p *HbaseGetRowsWithColumnsResult) IsSetIo() bool

func (*HbaseGetRowsWithColumnsResult) IsSetSuccess 

func (p *HbaseGetRowsWithColumnsResult) IsSetSuccess() bool

func (*HbaseGetRowsWithColumnsResult) Read 

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

func (*HbaseGetRowsWithColumnsResult) ReadField0 

func (p *HbaseGetRowsWithColumnsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsResult) ReadField1 

func (p *HbaseGetRowsWithColumnsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsResult) String 

func (p *HbaseGetRowsWithColumnsResult) String() string

func (*HbaseGetRowsWithColumnsResult) Write 

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

type HbaseGetRowsWithColumnsTsArgs 

type HbaseGetRowsWithColumnsTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Rows       []Text          `thrift:"rows,2" db:"rows" json:"rows"`
	Columns    []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Timestamp  int64           `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Rows: row keys
  • Columns: List of columns to return, null for all columns
  • Timestamp
  • Attributes: Get attributes

func NewHbaseGetRowsWithColumnsTsArgs 

func NewHbaseGetRowsWithColumnsTsArgs() *HbaseGetRowsWithColumnsTsArgs

func (*HbaseGetRowsWithColumnsTsArgs) GetAttributes 

func (p *HbaseGetRowsWithColumnsTsArgs) GetAttributes() map[string]Text

func (*HbaseGetRowsWithColumnsTsArgs) GetColumns 

func (p *HbaseGetRowsWithColumnsTsArgs) GetColumns() []Text

func (*HbaseGetRowsWithColumnsTsArgs) GetRows 

func (p *HbaseGetRowsWithColumnsTsArgs) GetRows() []Text

func (*HbaseGetRowsWithColumnsTsArgs) GetTableName 

func (p *HbaseGetRowsWithColumnsTsArgs) GetTableName() Text

func (*HbaseGetRowsWithColumnsTsArgs) GetTimestamp 

func (p *HbaseGetRowsWithColumnsTsArgs) GetTimestamp() int64

func (*HbaseGetRowsWithColumnsTsArgs) Read 

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

func (*HbaseGetRowsWithColumnsTsArgs) ReadField1 

func (p *HbaseGetRowsWithColumnsTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsArgs) ReadField2 

func (p *HbaseGetRowsWithColumnsTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsArgs) ReadField3 

func (p *HbaseGetRowsWithColumnsTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsArgs) ReadField4 

func (p *HbaseGetRowsWithColumnsTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsArgs) ReadField5 

func (p *HbaseGetRowsWithColumnsTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsArgs) String 

func (p *HbaseGetRowsWithColumnsTsArgs) String() string

func (*HbaseGetRowsWithColumnsTsArgs) Write 

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

type HbaseGetRowsWithColumnsTsResult 

type HbaseGetRowsWithColumnsTsResult struct {
	Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetRowsWithColumnsTsResult 

func NewHbaseGetRowsWithColumnsTsResult() *HbaseGetRowsWithColumnsTsResult

func (*HbaseGetRowsWithColumnsTsResult) GetIo 

func (p *HbaseGetRowsWithColumnsTsResult) GetIo() *IOError

func (*HbaseGetRowsWithColumnsTsResult) GetSuccess 

func (p *HbaseGetRowsWithColumnsTsResult) GetSuccess() []*TRowResult_

func (*HbaseGetRowsWithColumnsTsResult) IsSetIo 

func (p *HbaseGetRowsWithColumnsTsResult) IsSetIo() bool

func (*HbaseGetRowsWithColumnsTsResult) IsSetSuccess 

func (p *HbaseGetRowsWithColumnsTsResult) IsSetSuccess() bool

func (*HbaseGetRowsWithColumnsTsResult) Read 

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

func (*HbaseGetRowsWithColumnsTsResult) ReadField0 

func (p *HbaseGetRowsWithColumnsTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsResult) ReadField1 

func (p *HbaseGetRowsWithColumnsTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetRowsWithColumnsTsResult) String 

func (p *HbaseGetRowsWithColumnsTsResult) String() string

func (*HbaseGetRowsWithColumnsTsResult) Write 

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

type HbaseGetTableNamesArgs 

type HbaseGetTableNamesArgs struct {
}

func NewHbaseGetTableNamesArgs 

func NewHbaseGetTableNamesArgs() *HbaseGetTableNamesArgs

func (*HbaseGetTableNamesArgs) Read 

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

func (*HbaseGetTableNamesArgs) String 

func (p *HbaseGetTableNamesArgs) String() string

func (*HbaseGetTableNamesArgs) Write 

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

type HbaseGetTableNamesResult 

type HbaseGetTableNamesResult struct {
	Success []Text   `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetTableNamesResult 

func NewHbaseGetTableNamesResult() *HbaseGetTableNamesResult

func (*HbaseGetTableNamesResult) GetIo 

func (p *HbaseGetTableNamesResult) GetIo() *IOError

func (*HbaseGetTableNamesResult) GetSuccess 

func (p *HbaseGetTableNamesResult) GetSuccess() []Text

func (*HbaseGetTableNamesResult) IsSetIo 

func (p *HbaseGetTableNamesResult) IsSetIo() bool

func (*HbaseGetTableNamesResult) IsSetSuccess 

func (p *HbaseGetTableNamesResult) IsSetSuccess() bool

func (*HbaseGetTableNamesResult) Read 

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

func (*HbaseGetTableNamesResult) ReadField0 

func (p *HbaseGetTableNamesResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetTableNamesResult) ReadField1 

func (p *HbaseGetTableNamesResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetTableNamesResult) String 

func (p *HbaseGetTableNamesResult) String() string

func (*HbaseGetTableNamesResult) Write 

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

type HbaseGetTableRegionsArgs 

type HbaseGetTableRegionsArgs struct {
	TableName Text `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: table name

func NewHbaseGetTableRegionsArgs 

func NewHbaseGetTableRegionsArgs() *HbaseGetTableRegionsArgs

func (*HbaseGetTableRegionsArgs) GetTableName 

func (p *HbaseGetTableRegionsArgs) GetTableName() Text

func (*HbaseGetTableRegionsArgs) Read 

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

func (*HbaseGetTableRegionsArgs) ReadField1 

func (p *HbaseGetTableRegionsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetTableRegionsArgs) String 

func (p *HbaseGetTableRegionsArgs) String() string

func (*HbaseGetTableRegionsArgs) Write 

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

type HbaseGetTableRegionsResult 

type HbaseGetTableRegionsResult struct {
	Success []*TRegionInfo `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetTableRegionsResult 

func NewHbaseGetTableRegionsResult() *HbaseGetTableRegionsResult

func (*HbaseGetTableRegionsResult) GetIo 

func (p *HbaseGetTableRegionsResult) GetIo() *IOError

func (*HbaseGetTableRegionsResult) GetSuccess 

func (p *HbaseGetTableRegionsResult) GetSuccess() []*TRegionInfo

func (*HbaseGetTableRegionsResult) IsSetIo 

func (p *HbaseGetTableRegionsResult) IsSetIo() bool

func (*HbaseGetTableRegionsResult) IsSetSuccess 

func (p *HbaseGetTableRegionsResult) IsSetSuccess() bool

func (*HbaseGetTableRegionsResult) Read 

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

func (*HbaseGetTableRegionsResult) ReadField0 

func (p *HbaseGetTableRegionsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetTableRegionsResult) ReadField1 

func (p *HbaseGetTableRegionsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetTableRegionsResult) String 

func (p *HbaseGetTableRegionsResult) String() string

func (*HbaseGetTableRegionsResult) Write 

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

type HbaseGetVerArgs 

type HbaseGetVerArgs struct {
	TableName   Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row         Text            `thrift:"row,2" db:"row" json:"row"`
	Column      Text            `thrift:"column,3" db:"column" json:"column"`
	NumVersions int32           `thrift:"numVersions,4" db:"numVersions" json:"numVersions"`
	Attributes  map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • NumVersions: number of versions to retrieve
  • Attributes: Get attributes

func NewHbaseGetVerArgs 

func NewHbaseGetVerArgs() *HbaseGetVerArgs

func (*HbaseGetVerArgs) GetAttributes 

func (p *HbaseGetVerArgs) GetAttributes() map[string]Text

func (*HbaseGetVerArgs) GetColumn 

func (p *HbaseGetVerArgs) GetColumn() Text

func (*HbaseGetVerArgs) GetNumVersions 

func (p *HbaseGetVerArgs) GetNumVersions() int32

func (*HbaseGetVerArgs) GetRow 

func (p *HbaseGetVerArgs) GetRow() Text

func (*HbaseGetVerArgs) GetTableName 

func (p *HbaseGetVerArgs) GetTableName() Text

func (*HbaseGetVerArgs) Read 

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

func (*HbaseGetVerArgs) ReadField1 

func (p *HbaseGetVerArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetVerArgs) ReadField2 

func (p *HbaseGetVerArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetVerArgs) ReadField3 

func (p *HbaseGetVerArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetVerArgs) ReadField4 

func (p *HbaseGetVerArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetVerArgs) ReadField5 

func (p *HbaseGetVerArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseGetVerArgs) String 

func (p *HbaseGetVerArgs) String() string

func (*HbaseGetVerArgs) Write 

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

type HbaseGetVerResult 

type HbaseGetVerResult struct {
	Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetVerResult 

func NewHbaseGetVerResult() *HbaseGetVerResult

func (*HbaseGetVerResult) GetIo 

func (p *HbaseGetVerResult) GetIo() *IOError

func (*HbaseGetVerResult) GetSuccess 

func (p *HbaseGetVerResult) GetSuccess() []*TCell

func (*HbaseGetVerResult) IsSetIo 

func (p *HbaseGetVerResult) IsSetIo() bool

func (*HbaseGetVerResult) IsSetSuccess 

func (p *HbaseGetVerResult) IsSetSuccess() bool

func (*HbaseGetVerResult) Read 

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

func (*HbaseGetVerResult) ReadField0 

func (p *HbaseGetVerResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetVerResult) ReadField1 

func (p *HbaseGetVerResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetVerResult) String 

func (p *HbaseGetVerResult) String() string

func (*HbaseGetVerResult) Write 

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

type HbaseGetVerTsArgs 

type HbaseGetVerTsArgs struct {
	TableName   Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row         Text            `thrift:"row,2" db:"row" json:"row"`
	Column      Text            `thrift:"column,3" db:"column" json:"column"`
	Timestamp   int64           `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
	NumVersions int32           `thrift:"numVersions,5" db:"numVersions" json:"numVersions"`
	Attributes  map[string]Text `thrift:"attributes,6" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Column: column name
  • Timestamp: timestamp
  • NumVersions: number of versions to retrieve
  • Attributes: Get attributes

func NewHbaseGetVerTsArgs 

func NewHbaseGetVerTsArgs() *HbaseGetVerTsArgs

func (*HbaseGetVerTsArgs) GetAttributes 

func (p *HbaseGetVerTsArgs) GetAttributes() map[string]Text

func (*HbaseGetVerTsArgs) GetColumn 

func (p *HbaseGetVerTsArgs) GetColumn() Text

func (*HbaseGetVerTsArgs) GetNumVersions 

func (p *HbaseGetVerTsArgs) GetNumVersions() int32

func (*HbaseGetVerTsArgs) GetRow 

func (p *HbaseGetVerTsArgs) GetRow() Text

func (*HbaseGetVerTsArgs) GetTableName 

func (p *HbaseGetVerTsArgs) GetTableName() Text

func (*HbaseGetVerTsArgs) GetTimestamp 

func (p *HbaseGetVerTsArgs) GetTimestamp() int64

func (*HbaseGetVerTsArgs) Read 

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

func (*HbaseGetVerTsArgs) ReadField1 

func (p *HbaseGetVerTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetVerTsArgs) ReadField2 

func (p *HbaseGetVerTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseGetVerTsArgs) ReadField3 

func (p *HbaseGetVerTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseGetVerTsArgs) ReadField4 

func (p *HbaseGetVerTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseGetVerTsArgs) ReadField5 

func (p *HbaseGetVerTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseGetVerTsArgs) ReadField6 

func (p *HbaseGetVerTsArgs) ReadField6(iprot thrift.TProtocol) error

func (*HbaseGetVerTsArgs) String 

func (p *HbaseGetVerTsArgs) String() string

func (*HbaseGetVerTsArgs) Write 

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

type HbaseGetVerTsResult 

type HbaseGetVerTsResult struct {
	Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseGetVerTsResult 

func NewHbaseGetVerTsResult() *HbaseGetVerTsResult

func (*HbaseGetVerTsResult) GetIo 

func (p *HbaseGetVerTsResult) GetIo() *IOError

func (*HbaseGetVerTsResult) GetSuccess 

func (p *HbaseGetVerTsResult) GetSuccess() []*TCell

func (*HbaseGetVerTsResult) IsSetIo 

func (p *HbaseGetVerTsResult) IsSetIo() bool

func (*HbaseGetVerTsResult) IsSetSuccess 

func (p *HbaseGetVerTsResult) IsSetSuccess() bool

func (*HbaseGetVerTsResult) Read 

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

func (*HbaseGetVerTsResult) ReadField0 

func (p *HbaseGetVerTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseGetVerTsResult) ReadField1 

func (p *HbaseGetVerTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseGetVerTsResult) String 

func (p *HbaseGetVerTsResult) String() string

func (*HbaseGetVerTsResult) Write 

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

type HbaseIncrementArgs 

type HbaseIncrementArgs struct {
	Increment *TIncrement `thrift:"increment,1" db:"increment" json:"increment"`
}

Attributes:

  • Increment: The single increment to apply

func NewHbaseIncrementArgs 

func NewHbaseIncrementArgs() *HbaseIncrementArgs

func (*HbaseIncrementArgs) GetIncrement 

func (p *HbaseIncrementArgs) GetIncrement() *TIncrement

func (*HbaseIncrementArgs) IsSetIncrement 

func (p *HbaseIncrementArgs) IsSetIncrement() bool

func (*HbaseIncrementArgs) Read 

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

func (*HbaseIncrementArgs) ReadField1 

func (p *HbaseIncrementArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseIncrementArgs) String 

func (p *HbaseIncrementArgs) String() string

func (*HbaseIncrementArgs) Write 

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

type HbaseIncrementResult 

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

Attributes:

  • Io

func NewHbaseIncrementResult 

func NewHbaseIncrementResult() *HbaseIncrementResult

func (*HbaseIncrementResult) GetIo 

func (p *HbaseIncrementResult) GetIo() *IOError

func (*HbaseIncrementResult) IsSetIo 

func (p *HbaseIncrementResult) IsSetIo() bool

func (*HbaseIncrementResult) Read 

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

func (*HbaseIncrementResult) ReadField1 

func (p *HbaseIncrementResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseIncrementResult) String 

func (p *HbaseIncrementResult) String() string

func (*HbaseIncrementResult) Write 

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

type HbaseIncrementRowsArgs 

type HbaseIncrementRowsArgs struct {
	Increments []*TIncrement `thrift:"increments,1" db:"increments" json:"increments"`
}

Attributes:

  • Increments: The list of increments

func NewHbaseIncrementRowsArgs 

func NewHbaseIncrementRowsArgs() *HbaseIncrementRowsArgs

func (*HbaseIncrementRowsArgs) GetIncrements 

func (p *HbaseIncrementRowsArgs) GetIncrements() []*TIncrement

func (*HbaseIncrementRowsArgs) Read 

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

func (*HbaseIncrementRowsArgs) ReadField1 

func (p *HbaseIncrementRowsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseIncrementRowsArgs) String 

func (p *HbaseIncrementRowsArgs) String() string

func (*HbaseIncrementRowsArgs) Write 

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

type HbaseIncrementRowsResult 

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

Attributes:

  • Io

func NewHbaseIncrementRowsResult 

func NewHbaseIncrementRowsResult() *HbaseIncrementRowsResult

func (*HbaseIncrementRowsResult) GetIo 

func (p *HbaseIncrementRowsResult) GetIo() *IOError

func (*HbaseIncrementRowsResult) IsSetIo 

func (p *HbaseIncrementRowsResult) IsSetIo() bool

func (*HbaseIncrementRowsResult) Read 

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

func (*HbaseIncrementRowsResult) ReadField1 

func (p *HbaseIncrementRowsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseIncrementRowsResult) String 

func (p *HbaseIncrementRowsResult) String() string

func (*HbaseIncrementRowsResult) Write 

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

type HbaseIsTableEnabledArgs 

type HbaseIsTableEnabledArgs struct {
	TableName Bytes `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

  • TableName: name of the table to check

func NewHbaseIsTableEnabledArgs 

func NewHbaseIsTableEnabledArgs() *HbaseIsTableEnabledArgs

func (*HbaseIsTableEnabledArgs) GetTableName 

func (p *HbaseIsTableEnabledArgs) GetTableName() Bytes

func (*HbaseIsTableEnabledArgs) Read 

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

func (*HbaseIsTableEnabledArgs) ReadField1 

func (p *HbaseIsTableEnabledArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseIsTableEnabledArgs) String 

func (p *HbaseIsTableEnabledArgs) String() string

func (*HbaseIsTableEnabledArgs) Write 

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

type HbaseIsTableEnabledResult 

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

Attributes:

  • Success
  • Io

func NewHbaseIsTableEnabledResult 

func NewHbaseIsTableEnabledResult() *HbaseIsTableEnabledResult

func (*HbaseIsTableEnabledResult) GetIo 

func (p *HbaseIsTableEnabledResult) GetIo() *IOError

func (*HbaseIsTableEnabledResult) GetSuccess 

func (p *HbaseIsTableEnabledResult) GetSuccess() bool

func (*HbaseIsTableEnabledResult) IsSetIo 

func (p *HbaseIsTableEnabledResult) IsSetIo() bool

func (*HbaseIsTableEnabledResult) IsSetSuccess 

func (p *HbaseIsTableEnabledResult) IsSetSuccess() bool

func (*HbaseIsTableEnabledResult) Read 

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

func (*HbaseIsTableEnabledResult) ReadField0 

func (p *HbaseIsTableEnabledResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseIsTableEnabledResult) ReadField1 

func (p *HbaseIsTableEnabledResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseIsTableEnabledResult) String 

func (p *HbaseIsTableEnabledResult) String() string

func (*HbaseIsTableEnabledResult) Write 

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

type HbaseMajorCompactArgs 

type HbaseMajorCompactArgs struct {
	TableNameOrRegionName Bytes `thrift:"tableNameOrRegionName,1" db:"tableNameOrRegionName" json:"tableNameOrRegionName"`
}

Attributes:

  • TableNameOrRegionName

func NewHbaseMajorCompactArgs 

func NewHbaseMajorCompactArgs() *HbaseMajorCompactArgs

func (*HbaseMajorCompactArgs) GetTableNameOrRegionName 

func (p *HbaseMajorCompactArgs) GetTableNameOrRegionName() Bytes

func (*HbaseMajorCompactArgs) Read 

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

func (*HbaseMajorCompactArgs) ReadField1 

func (p *HbaseMajorCompactArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMajorCompactArgs) String 

func (p *HbaseMajorCompactArgs) String() string

func (*HbaseMajorCompactArgs) Write 

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

type HbaseMajorCompactResult 

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

Attributes:

  • Io

func NewHbaseMajorCompactResult 

func NewHbaseMajorCompactResult() *HbaseMajorCompactResult

func (*HbaseMajorCompactResult) GetIo 

func (p *HbaseMajorCompactResult) GetIo() *IOError

func (*HbaseMajorCompactResult) IsSetIo 

func (p *HbaseMajorCompactResult) IsSetIo() bool

func (*HbaseMajorCompactResult) Read 

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

func (*HbaseMajorCompactResult) ReadField1 

func (p *HbaseMajorCompactResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMajorCompactResult) String 

func (p *HbaseMajorCompactResult) String() string

func (*HbaseMajorCompactResult) Write 

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

type HbaseMutateRowArgs 

type HbaseMutateRowArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Mutations  []*Mutation     `thrift:"mutations,3" db:"mutations" json:"mutations"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Mutations: list of mutation commands
  • Attributes: Mutation attributes

func NewHbaseMutateRowArgs 

func NewHbaseMutateRowArgs() *HbaseMutateRowArgs

func (*HbaseMutateRowArgs) GetAttributes 

func (p *HbaseMutateRowArgs) GetAttributes() map[string]Text

func (*HbaseMutateRowArgs) GetMutations 

func (p *HbaseMutateRowArgs) GetMutations() []*Mutation

func (*HbaseMutateRowArgs) GetRow 

func (p *HbaseMutateRowArgs) GetRow() Text

func (*HbaseMutateRowArgs) GetTableName 

func (p *HbaseMutateRowArgs) GetTableName() Text

func (*HbaseMutateRowArgs) Read 

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

func (*HbaseMutateRowArgs) ReadField1 

func (p *HbaseMutateRowArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowArgs) ReadField2 

func (p *HbaseMutateRowArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowArgs) ReadField3 

func (p *HbaseMutateRowArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseMutateRowArgs) ReadField4 

func (p *HbaseMutateRowArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseMutateRowArgs) String 

func (p *HbaseMutateRowArgs) String() string

func (*HbaseMutateRowArgs) Write 

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

type HbaseMutateRowResult 

type HbaseMutateRowResult struct {
	Io *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Io
  • Ia

func NewHbaseMutateRowResult 

func NewHbaseMutateRowResult() *HbaseMutateRowResult

func (*HbaseMutateRowResult) GetIa 

func (p *HbaseMutateRowResult) GetIa() *IllegalArgument

func (*HbaseMutateRowResult) GetIo 

func (p *HbaseMutateRowResult) GetIo() *IOError

func (*HbaseMutateRowResult) IsSetIa 

func (p *HbaseMutateRowResult) IsSetIa() bool

func (*HbaseMutateRowResult) IsSetIo 

func (p *HbaseMutateRowResult) IsSetIo() bool

func (*HbaseMutateRowResult) Read 

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

func (*HbaseMutateRowResult) ReadField1 

func (p *HbaseMutateRowResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowResult) ReadField2 

func (p *HbaseMutateRowResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowResult) String 

func (p *HbaseMutateRowResult) String() string

func (*HbaseMutateRowResult) Write 

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

type HbaseMutateRowTsArgs 

type HbaseMutateRowTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Row        Text            `thrift:"row,2" db:"row" json:"row"`
	Mutations  []*Mutation     `thrift:"mutations,3" db:"mutations" json:"mutations"`
	Timestamp  int64           `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Row: row key
  • Mutations: list of mutation commands
  • Timestamp: timestamp
  • Attributes: Mutation attributes

func NewHbaseMutateRowTsArgs 

func NewHbaseMutateRowTsArgs() *HbaseMutateRowTsArgs

func (*HbaseMutateRowTsArgs) GetAttributes 

func (p *HbaseMutateRowTsArgs) GetAttributes() map[string]Text

func (*HbaseMutateRowTsArgs) GetMutations 

func (p *HbaseMutateRowTsArgs) GetMutations() []*Mutation

func (*HbaseMutateRowTsArgs) GetRow 

func (p *HbaseMutateRowTsArgs) GetRow() Text

func (*HbaseMutateRowTsArgs) GetTableName 

func (p *HbaseMutateRowTsArgs) GetTableName() Text

func (*HbaseMutateRowTsArgs) GetTimestamp 

func (p *HbaseMutateRowTsArgs) GetTimestamp() int64

func (*HbaseMutateRowTsArgs) Read 

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

func (*HbaseMutateRowTsArgs) ReadField1 

func (p *HbaseMutateRowTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsArgs) ReadField2 

func (p *HbaseMutateRowTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsArgs) ReadField3 

func (p *HbaseMutateRowTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsArgs) ReadField4 

func (p *HbaseMutateRowTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsArgs) ReadField5 

func (p *HbaseMutateRowTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsArgs) String 

func (p *HbaseMutateRowTsArgs) String() string

func (*HbaseMutateRowTsArgs) Write 

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

type HbaseMutateRowTsResult 

type HbaseMutateRowTsResult struct {
	Io *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Io
  • Ia

func NewHbaseMutateRowTsResult 

func NewHbaseMutateRowTsResult() *HbaseMutateRowTsResult

func (*HbaseMutateRowTsResult) GetIa 

func (p *HbaseMutateRowTsResult) GetIa() *IllegalArgument

func (*HbaseMutateRowTsResult) GetIo 

func (p *HbaseMutateRowTsResult) GetIo() *IOError

func (*HbaseMutateRowTsResult) IsSetIa 

func (p *HbaseMutateRowTsResult) IsSetIa() bool

func (*HbaseMutateRowTsResult) IsSetIo 

func (p *HbaseMutateRowTsResult) IsSetIo() bool

func (*HbaseMutateRowTsResult) Read 

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

func (*HbaseMutateRowTsResult) ReadField1 

func (p *HbaseMutateRowTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsResult) ReadField2 

func (p *HbaseMutateRowTsResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowTsResult) String 

func (p *HbaseMutateRowTsResult) String() string

func (*HbaseMutateRowTsResult) Write 

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

type HbaseMutateRowsArgs 

type HbaseMutateRowsArgs struct {
	TableName  Text             `thrift:"tableName,1" db:"tableName" json:"tableName"`
	RowBatches []*BatchMutation `thrift:"rowBatches,2" db:"rowBatches" json:"rowBatches"`
	Attributes map[string]Text  `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • RowBatches: list of row batches
  • Attributes: Mutation attributes

func NewHbaseMutateRowsArgs 

func NewHbaseMutateRowsArgs() *HbaseMutateRowsArgs

func (*HbaseMutateRowsArgs) GetAttributes 

func (p *HbaseMutateRowsArgs) GetAttributes() map[string]Text

func (*HbaseMutateRowsArgs) GetRowBatches 

func (p *HbaseMutateRowsArgs) GetRowBatches() []*BatchMutation

func (*HbaseMutateRowsArgs) GetTableName 

func (p *HbaseMutateRowsArgs) GetTableName() Text

func (*HbaseMutateRowsArgs) Read 

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

func (*HbaseMutateRowsArgs) ReadField1 

func (p *HbaseMutateRowsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowsArgs) ReadField2 

func (p *HbaseMutateRowsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowsArgs) ReadField3 

func (p *HbaseMutateRowsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseMutateRowsArgs) String 

func (p *HbaseMutateRowsArgs) String() string

func (*HbaseMutateRowsArgs) Write 

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

type HbaseMutateRowsResult 

type HbaseMutateRowsResult struct {
	Io *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Io
  • Ia

func NewHbaseMutateRowsResult 

func NewHbaseMutateRowsResult() *HbaseMutateRowsResult

func (*HbaseMutateRowsResult) GetIa 

func (p *HbaseMutateRowsResult) GetIa() *IllegalArgument

func (*HbaseMutateRowsResult) GetIo 

func (p *HbaseMutateRowsResult) GetIo() *IOError

func (*HbaseMutateRowsResult) IsSetIa 

func (p *HbaseMutateRowsResult) IsSetIa() bool

func (*HbaseMutateRowsResult) IsSetIo 

func (p *HbaseMutateRowsResult) IsSetIo() bool

func (*HbaseMutateRowsResult) Read 

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

func (*HbaseMutateRowsResult) ReadField1 

func (p *HbaseMutateRowsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowsResult) ReadField2 

func (p *HbaseMutateRowsResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowsResult) String 

func (p *HbaseMutateRowsResult) String() string

func (*HbaseMutateRowsResult) Write 

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

type HbaseMutateRowsTsArgs 

type HbaseMutateRowsTsArgs struct {
	TableName  Text             `thrift:"tableName,1" db:"tableName" json:"tableName"`
	RowBatches []*BatchMutation `thrift:"rowBatches,2" db:"rowBatches" json:"rowBatches"`
	Timestamp  int64            `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text  `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • RowBatches: list of row batches
  • Timestamp: timestamp
  • Attributes: Mutation attributes

func NewHbaseMutateRowsTsArgs 

func NewHbaseMutateRowsTsArgs() *HbaseMutateRowsTsArgs

func (*HbaseMutateRowsTsArgs) GetAttributes 

func (p *HbaseMutateRowsTsArgs) GetAttributes() map[string]Text

func (*HbaseMutateRowsTsArgs) GetRowBatches 

func (p *HbaseMutateRowsTsArgs) GetRowBatches() []*BatchMutation

func (*HbaseMutateRowsTsArgs) GetTableName 

func (p *HbaseMutateRowsTsArgs) GetTableName() Text

func (*HbaseMutateRowsTsArgs) GetTimestamp 

func (p *HbaseMutateRowsTsArgs) GetTimestamp() int64

func (*HbaseMutateRowsTsArgs) Read 

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

func (*HbaseMutateRowsTsArgs) ReadField1 

func (p *HbaseMutateRowsTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowsTsArgs) ReadField2 

func (p *HbaseMutateRowsTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowsTsArgs) ReadField3 

func (p *HbaseMutateRowsTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseMutateRowsTsArgs) ReadField4 

func (p *HbaseMutateRowsTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseMutateRowsTsArgs) String 

func (p *HbaseMutateRowsTsArgs) String() string

func (*HbaseMutateRowsTsArgs) Write 

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

type HbaseMutateRowsTsResult 

type HbaseMutateRowsTsResult struct {
	Io *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Io
  • Ia

func NewHbaseMutateRowsTsResult 

func NewHbaseMutateRowsTsResult() *HbaseMutateRowsTsResult

func (*HbaseMutateRowsTsResult) GetIa 

func (p *HbaseMutateRowsTsResult) GetIa() *IllegalArgument

func (*HbaseMutateRowsTsResult) GetIo 

func (p *HbaseMutateRowsTsResult) GetIo() *IOError

func (*HbaseMutateRowsTsResult) IsSetIa 

func (p *HbaseMutateRowsTsResult) IsSetIa() bool

func (*HbaseMutateRowsTsResult) IsSetIo 

func (p *HbaseMutateRowsTsResult) IsSetIo() bool

func (*HbaseMutateRowsTsResult) Read 

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

func (*HbaseMutateRowsTsResult) ReadField1 

func (p *HbaseMutateRowsTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseMutateRowsTsResult) ReadField2 

func (p *HbaseMutateRowsTsResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseMutateRowsTsResult) String 

func (p *HbaseMutateRowsTsResult) String() string

func (*HbaseMutateRowsTsResult) Write 

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

type HbaseProcessor 

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

func NewHbaseProcessor 

func NewHbaseProcessor(handler Hbase) *HbaseProcessor

func (*HbaseProcessor) AddToProcessorMap 

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

func (*HbaseProcessor) GetProcessorFunction 

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

func (*HbaseProcessor) Process 

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

func (*HbaseProcessor) ProcessorMap 

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

type HbaseScannerCloseArgs 

type HbaseScannerCloseArgs struct {
	ID ScannerID `thrift:"id,1" db:"id" json:"id"`
}

Attributes:

  • ID: id of a scanner returned by scannerOpen

func NewHbaseScannerCloseArgs 

func NewHbaseScannerCloseArgs() *HbaseScannerCloseArgs

func (*HbaseScannerCloseArgs) GetID 

func (p *HbaseScannerCloseArgs) GetID() ScannerID

func (*HbaseScannerCloseArgs) Read 

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

func (*HbaseScannerCloseArgs) ReadField1 

func (p *HbaseScannerCloseArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerCloseArgs) String 

func (p *HbaseScannerCloseArgs) String() string

func (*HbaseScannerCloseArgs) Write 

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

type HbaseScannerCloseResult 

type HbaseScannerCloseResult struct {
	Io *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Io
  • Ia

func NewHbaseScannerCloseResult 

func NewHbaseScannerCloseResult() *HbaseScannerCloseResult

func (*HbaseScannerCloseResult) GetIa 

func (p *HbaseScannerCloseResult) GetIa() *IllegalArgument

func (*HbaseScannerCloseResult) GetIo 

func (p *HbaseScannerCloseResult) GetIo() *IOError

func (*HbaseScannerCloseResult) IsSetIa 

func (p *HbaseScannerCloseResult) IsSetIa() bool

func (*HbaseScannerCloseResult) IsSetIo 

func (p *HbaseScannerCloseResult) IsSetIo() bool

func (*HbaseScannerCloseResult) Read 

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

func (*HbaseScannerCloseResult) ReadField1 

func (p *HbaseScannerCloseResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerCloseResult) ReadField2 

func (p *HbaseScannerCloseResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerCloseResult) String 

func (p *HbaseScannerCloseResult) String() string

func (*HbaseScannerCloseResult) Write 

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

type HbaseScannerGetArgs 

type HbaseScannerGetArgs struct {
	ID ScannerID `thrift:"id,1" db:"id" json:"id"`
}

Attributes:

  • ID: id of a scanner returned by scannerOpen

func NewHbaseScannerGetArgs 

func NewHbaseScannerGetArgs() *HbaseScannerGetArgs

func (*HbaseScannerGetArgs) GetID 

func (p *HbaseScannerGetArgs) GetID() ScannerID

func (*HbaseScannerGetArgs) Read 

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

func (*HbaseScannerGetArgs) ReadField1 

func (p *HbaseScannerGetArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerGetArgs) String 

func (p *HbaseScannerGetArgs) String() string

func (*HbaseScannerGetArgs) Write 

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

type HbaseScannerGetListArgs 

type HbaseScannerGetListArgs struct {
	ID     ScannerID `thrift:"id,1" db:"id" json:"id"`
	NbRows int32     `thrift:"nbRows,2" db:"nbRows" json:"nbRows"`
}

Attributes:

  • ID: id of a scanner returned by scannerOpen
  • NbRows: number of results to return

func NewHbaseScannerGetListArgs 

func NewHbaseScannerGetListArgs() *HbaseScannerGetListArgs

func (*HbaseScannerGetListArgs) GetID 

func (p *HbaseScannerGetListArgs) GetID() ScannerID

func (*HbaseScannerGetListArgs) GetNbRows 

func (p *HbaseScannerGetListArgs) GetNbRows() int32

func (*HbaseScannerGetListArgs) Read 

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

func (*HbaseScannerGetListArgs) ReadField1 

func (p *HbaseScannerGetListArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerGetListArgs) ReadField2 

func (p *HbaseScannerGetListArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerGetListArgs) String 

func (p *HbaseScannerGetListArgs) String() string

func (*HbaseScannerGetListArgs) Write 

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

type HbaseScannerGetListResult 

type HbaseScannerGetListResult struct {
	Success []*TRowResult_   `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Success
  • Io
  • Ia

func NewHbaseScannerGetListResult 

func NewHbaseScannerGetListResult() *HbaseScannerGetListResult

func (*HbaseScannerGetListResult) GetIa 

func (p *HbaseScannerGetListResult) GetIa() *IllegalArgument

func (*HbaseScannerGetListResult) GetIo 

func (p *HbaseScannerGetListResult) GetIo() *IOError

func (*HbaseScannerGetListResult) GetSuccess 

func (p *HbaseScannerGetListResult) GetSuccess() []*TRowResult_

func (*HbaseScannerGetListResult) IsSetIa 

func (p *HbaseScannerGetListResult) IsSetIa() bool

func (*HbaseScannerGetListResult) IsSetIo 

func (p *HbaseScannerGetListResult) IsSetIo() bool

func (*HbaseScannerGetListResult) IsSetSuccess 

func (p *HbaseScannerGetListResult) IsSetSuccess() bool

func (*HbaseScannerGetListResult) Read 

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

func (*HbaseScannerGetListResult) ReadField0 

func (p *HbaseScannerGetListResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerGetListResult) ReadField1 

func (p *HbaseScannerGetListResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerGetListResult) ReadField2 

func (p *HbaseScannerGetListResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerGetListResult) String 

func (p *HbaseScannerGetListResult) String() string

func (*HbaseScannerGetListResult) Write 

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

type HbaseScannerGetResult 

type HbaseScannerGetResult struct {
	Success []*TRowResult_   `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
	Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

  • Success
  • Io
  • Ia

func NewHbaseScannerGetResult 

func NewHbaseScannerGetResult() *HbaseScannerGetResult

func (*HbaseScannerGetResult) GetIa 

func (p *HbaseScannerGetResult) GetIa() *IllegalArgument

func (*HbaseScannerGetResult) GetIo 

func (p *HbaseScannerGetResult) GetIo() *IOError

func (*HbaseScannerGetResult) GetSuccess 

func (p *HbaseScannerGetResult) GetSuccess() []*TRowResult_

func (*HbaseScannerGetResult) IsSetIa 

func (p *HbaseScannerGetResult) IsSetIa() bool

func (*HbaseScannerGetResult) IsSetIo 

func (p *HbaseScannerGetResult) IsSetIo() bool

func (*HbaseScannerGetResult) IsSetSuccess 

func (p *HbaseScannerGetResult) IsSetSuccess() bool

func (*HbaseScannerGetResult) Read 

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

func (*HbaseScannerGetResult) ReadField0 

func (p *HbaseScannerGetResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerGetResult) ReadField1 

func (p *HbaseScannerGetResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerGetResult) ReadField2 

func (p *HbaseScannerGetResult) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerGetResult) String 

func (p *HbaseScannerGetResult) String() string

func (*HbaseScannerGetResult) Write 

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

type HbaseScannerOpenArgs 

type HbaseScannerOpenArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	StartRow   Text            `thrift:"startRow,2" db:"startRow" json:"startRow"`
	Columns    []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Attributes map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Attributes: Scan attributes

func NewHbaseScannerOpenArgs 

func NewHbaseScannerOpenArgs() *HbaseScannerOpenArgs

func (*HbaseScannerOpenArgs) GetAttributes 

func (p *HbaseScannerOpenArgs) GetAttributes() map[string]Text

func (*HbaseScannerOpenArgs) GetColumns 

func (p *HbaseScannerOpenArgs) GetColumns() []Text

func (*HbaseScannerOpenArgs) GetStartRow 

func (p *HbaseScannerOpenArgs) GetStartRow() Text

func (*HbaseScannerOpenArgs) GetTableName 

func (p *HbaseScannerOpenArgs) GetTableName() Text

func (*HbaseScannerOpenArgs) Read 

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

func (*HbaseScannerOpenArgs) ReadField1 

func (p *HbaseScannerOpenArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenArgs) ReadField2 

func (p *HbaseScannerOpenArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerOpenArgs) ReadField3 

func (p *HbaseScannerOpenArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseScannerOpenArgs) ReadField4 

func (p *HbaseScannerOpenArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseScannerOpenArgs) String 

func (p *HbaseScannerOpenArgs) String() string

func (*HbaseScannerOpenArgs) Write 

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

type HbaseScannerOpenResult 

type HbaseScannerOpenResult struct {
	Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseScannerOpenResult 

func NewHbaseScannerOpenResult() *HbaseScannerOpenResult

func (*HbaseScannerOpenResult) GetIo 

func (p *HbaseScannerOpenResult) GetIo() *IOError

func (*HbaseScannerOpenResult) GetSuccess 

func (p *HbaseScannerOpenResult) GetSuccess() ScannerID

func (*HbaseScannerOpenResult) IsSetIo 

func (p *HbaseScannerOpenResult) IsSetIo() bool

func (*HbaseScannerOpenResult) IsSetSuccess 

func (p *HbaseScannerOpenResult) IsSetSuccess() bool

func (*HbaseScannerOpenResult) Read 

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

func (*HbaseScannerOpenResult) ReadField0 

func (p *HbaseScannerOpenResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerOpenResult) ReadField1 

func (p *HbaseScannerOpenResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenResult) String 

func (p *HbaseScannerOpenResult) String() string

func (*HbaseScannerOpenResult) Write 

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

type HbaseScannerOpenTsArgs 

type HbaseScannerOpenTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	StartRow   Text            `thrift:"startRow,2" db:"startRow" json:"startRow"`
	Columns    []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Timestamp  int64           `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Timestamp: timestamp
  • Attributes: Scan attributes

func NewHbaseScannerOpenTsArgs 

func NewHbaseScannerOpenTsArgs() *HbaseScannerOpenTsArgs

func (*HbaseScannerOpenTsArgs) GetAttributes 

func (p *HbaseScannerOpenTsArgs) GetAttributes() map[string]Text

func (*HbaseScannerOpenTsArgs) GetColumns 

func (p *HbaseScannerOpenTsArgs) GetColumns() []Text

func (*HbaseScannerOpenTsArgs) GetStartRow 

func (p *HbaseScannerOpenTsArgs) GetStartRow() Text

func (*HbaseScannerOpenTsArgs) GetTableName 

func (p *HbaseScannerOpenTsArgs) GetTableName() Text

func (*HbaseScannerOpenTsArgs) GetTimestamp 

func (p *HbaseScannerOpenTsArgs) GetTimestamp() int64

func (*HbaseScannerOpenTsArgs) Read 

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

func (*HbaseScannerOpenTsArgs) ReadField1 

func (p *HbaseScannerOpenTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsArgs) ReadField2 

func (p *HbaseScannerOpenTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsArgs) ReadField3 

func (p *HbaseScannerOpenTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsArgs) ReadField4 

func (p *HbaseScannerOpenTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsArgs) ReadField5 

func (p *HbaseScannerOpenTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsArgs) String 

func (p *HbaseScannerOpenTsArgs) String() string

func (*HbaseScannerOpenTsArgs) Write 

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

type HbaseScannerOpenTsResult 

type HbaseScannerOpenTsResult struct {
	Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseScannerOpenTsResult 

func NewHbaseScannerOpenTsResult() *HbaseScannerOpenTsResult

func (*HbaseScannerOpenTsResult) GetIo 

func (p *HbaseScannerOpenTsResult) GetIo() *IOError

func (*HbaseScannerOpenTsResult) GetSuccess 

func (p *HbaseScannerOpenTsResult) GetSuccess() ScannerID

func (*HbaseScannerOpenTsResult) IsSetIo 

func (p *HbaseScannerOpenTsResult) IsSetIo() bool

func (*HbaseScannerOpenTsResult) IsSetSuccess 

func (p *HbaseScannerOpenTsResult) IsSetSuccess() bool

func (*HbaseScannerOpenTsResult) Read 

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

func (*HbaseScannerOpenTsResult) ReadField0 

func (p *HbaseScannerOpenTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsResult) ReadField1 

func (p *HbaseScannerOpenTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenTsResult) String 

func (p *HbaseScannerOpenTsResult) String() string

func (*HbaseScannerOpenTsResult) Write 

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

type HbaseScannerOpenWithPrefixArgs 

type HbaseScannerOpenWithPrefixArgs struct {
	TableName      Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	StartAndPrefix Text            `thrift:"startAndPrefix,2" db:"startAndPrefix" json:"startAndPrefix"`
	Columns        []Text          `thrift:"columns,3" db:"columns" json:"columns"`
	Attributes     map[string]Text `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • StartAndPrefix: the prefix (and thus start row) of the keys you want
  • Columns: the columns you want returned
  • Attributes: Scan attributes

func NewHbaseScannerOpenWithPrefixArgs 

func NewHbaseScannerOpenWithPrefixArgs() *HbaseScannerOpenWithPrefixArgs

func (*HbaseScannerOpenWithPrefixArgs) GetAttributes 

func (p *HbaseScannerOpenWithPrefixArgs) GetAttributes() map[string]Text

func (*HbaseScannerOpenWithPrefixArgs) GetColumns 

func (p *HbaseScannerOpenWithPrefixArgs) GetColumns() []Text

func (*HbaseScannerOpenWithPrefixArgs) GetStartAndPrefix 

func (p *HbaseScannerOpenWithPrefixArgs) GetStartAndPrefix() Text

func (*HbaseScannerOpenWithPrefixArgs) GetTableName 

func (p *HbaseScannerOpenWithPrefixArgs) GetTableName() Text

func (*HbaseScannerOpenWithPrefixArgs) Read 

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

func (*HbaseScannerOpenWithPrefixArgs) ReadField1 

func (p *HbaseScannerOpenWithPrefixArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithPrefixArgs) ReadField2 

func (p *HbaseScannerOpenWithPrefixArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithPrefixArgs) ReadField3 

func (p *HbaseScannerOpenWithPrefixArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithPrefixArgs) ReadField4 

func (p *HbaseScannerOpenWithPrefixArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithPrefixArgs) String 

func (p *HbaseScannerOpenWithPrefixArgs) String() string

func (*HbaseScannerOpenWithPrefixArgs) Write 

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

type HbaseScannerOpenWithPrefixResult 

type HbaseScannerOpenWithPrefixResult struct {
	Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseScannerOpenWithPrefixResult 

func NewHbaseScannerOpenWithPrefixResult() *HbaseScannerOpenWithPrefixResult

func (*HbaseScannerOpenWithPrefixResult) GetIo 

func (p *HbaseScannerOpenWithPrefixResult) GetIo() *IOError

func (*HbaseScannerOpenWithPrefixResult) GetSuccess 

func (p *HbaseScannerOpenWithPrefixResult) GetSuccess() ScannerID

func (*HbaseScannerOpenWithPrefixResult) IsSetIo 

func (p *HbaseScannerOpenWithPrefixResult) IsSetIo() bool

func (*HbaseScannerOpenWithPrefixResult) IsSetSuccess 

func (p *HbaseScannerOpenWithPrefixResult) IsSetSuccess() bool

func (*HbaseScannerOpenWithPrefixResult) Read 

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

func (*HbaseScannerOpenWithPrefixResult) ReadField0 

func (p *HbaseScannerOpenWithPrefixResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithPrefixResult) ReadField1 

func (p *HbaseScannerOpenWithPrefixResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithPrefixResult) String 

func (p *HbaseScannerOpenWithPrefixResult) String() string

func (*HbaseScannerOpenWithPrefixResult) Write 

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

type HbaseScannerOpenWithScanArgs 

type HbaseScannerOpenWithScanArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	Scan       *TScan          `thrift:"scan,2" db:"scan" json:"scan"`
	Attributes map[string]Text `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • Scan: Scan instance
  • Attributes: Scan attributes

func NewHbaseScannerOpenWithScanArgs 

func NewHbaseScannerOpenWithScanArgs() *HbaseScannerOpenWithScanArgs

func (*HbaseScannerOpenWithScanArgs) GetAttributes 

func (p *HbaseScannerOpenWithScanArgs) GetAttributes() map[string]Text

func (*HbaseScannerOpenWithScanArgs) GetScan 

func (p *HbaseScannerOpenWithScanArgs) GetScan() *TScan

func (*HbaseScannerOpenWithScanArgs) GetTableName 

func (p *HbaseScannerOpenWithScanArgs) GetTableName() Text

func (*HbaseScannerOpenWithScanArgs) IsSetScan 

func (p *HbaseScannerOpenWithScanArgs) IsSetScan() bool

func (*HbaseScannerOpenWithScanArgs) Read 

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

func (*HbaseScannerOpenWithScanArgs) ReadField1 

func (p *HbaseScannerOpenWithScanArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithScanArgs) ReadField2 

func (p *HbaseScannerOpenWithScanArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithScanArgs) ReadField3 

func (p *HbaseScannerOpenWithScanArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithScanArgs) String 

func (p *HbaseScannerOpenWithScanArgs) String() string

func (*HbaseScannerOpenWithScanArgs) Write 

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

type HbaseScannerOpenWithScanResult 

type HbaseScannerOpenWithScanResult struct {
	Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseScannerOpenWithScanResult 

func NewHbaseScannerOpenWithScanResult() *HbaseScannerOpenWithScanResult

func (*HbaseScannerOpenWithScanResult) GetIo 

func (p *HbaseScannerOpenWithScanResult) GetIo() *IOError

func (*HbaseScannerOpenWithScanResult) GetSuccess 

func (p *HbaseScannerOpenWithScanResult) GetSuccess() ScannerID

func (*HbaseScannerOpenWithScanResult) IsSetIo 

func (p *HbaseScannerOpenWithScanResult) IsSetIo() bool

func (*HbaseScannerOpenWithScanResult) IsSetSuccess 

func (p *HbaseScannerOpenWithScanResult) IsSetSuccess() bool

func (*HbaseScannerOpenWithScanResult) Read 

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

func (*HbaseScannerOpenWithScanResult) ReadField0 

func (p *HbaseScannerOpenWithScanResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithScanResult) ReadField1 

func (p *HbaseScannerOpenWithScanResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithScanResult) String 

func (p *HbaseScannerOpenWithScanResult) String() string

func (*HbaseScannerOpenWithScanResult) Write 

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

type HbaseScannerOpenWithStopArgs 

type HbaseScannerOpenWithStopArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	StartRow   Text            `thrift:"startRow,2" db:"startRow" json:"startRow"`
	StopRow    Text            `thrift:"stopRow,3" db:"stopRow" json:"stopRow"`
	Columns    []Text          `thrift:"columns,4" db:"columns" json:"columns"`
	Attributes map[string]Text `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • StopRow: row to stop scanning on. This row is *not* included in the

scanner's results

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Attributes: Scan attributes

func NewHbaseScannerOpenWithStopArgs 

func NewHbaseScannerOpenWithStopArgs() *HbaseScannerOpenWithStopArgs

func (*HbaseScannerOpenWithStopArgs) GetAttributes 

func (p *HbaseScannerOpenWithStopArgs) GetAttributes() map[string]Text

func (*HbaseScannerOpenWithStopArgs) GetColumns 

func (p *HbaseScannerOpenWithStopArgs) GetColumns() []Text

func (*HbaseScannerOpenWithStopArgs) GetStartRow 

func (p *HbaseScannerOpenWithStopArgs) GetStartRow() Text

func (*HbaseScannerOpenWithStopArgs) GetStopRow 

func (p *HbaseScannerOpenWithStopArgs) GetStopRow() Text

func (*HbaseScannerOpenWithStopArgs) GetTableName 

func (p *HbaseScannerOpenWithStopArgs) GetTableName() Text

func (*HbaseScannerOpenWithStopArgs) Read 

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

func (*HbaseScannerOpenWithStopArgs) ReadField1 

func (p *HbaseScannerOpenWithStopArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopArgs) ReadField2 

func (p *HbaseScannerOpenWithStopArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopArgs) ReadField3 

func (p *HbaseScannerOpenWithStopArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopArgs) ReadField4 

func (p *HbaseScannerOpenWithStopArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopArgs) ReadField5 

func (p *HbaseScannerOpenWithStopArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopArgs) String 

func (p *HbaseScannerOpenWithStopArgs) String() string

func (*HbaseScannerOpenWithStopArgs) Write 

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

type HbaseScannerOpenWithStopResult 

type HbaseScannerOpenWithStopResult struct {
	Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseScannerOpenWithStopResult 

func NewHbaseScannerOpenWithStopResult() *HbaseScannerOpenWithStopResult

func (*HbaseScannerOpenWithStopResult) GetIo 

func (p *HbaseScannerOpenWithStopResult) GetIo() *IOError

func (*HbaseScannerOpenWithStopResult) GetSuccess 

func (p *HbaseScannerOpenWithStopResult) GetSuccess() ScannerID

func (*HbaseScannerOpenWithStopResult) IsSetIo 

func (p *HbaseScannerOpenWithStopResult) IsSetIo() bool

func (*HbaseScannerOpenWithStopResult) IsSetSuccess 

func (p *HbaseScannerOpenWithStopResult) IsSetSuccess() bool

func (*HbaseScannerOpenWithStopResult) Read 

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

func (*HbaseScannerOpenWithStopResult) ReadField0 

func (p *HbaseScannerOpenWithStopResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopResult) ReadField1 

func (p *HbaseScannerOpenWithStopResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopResult) String 

func (p *HbaseScannerOpenWithStopResult) String() string

func (*HbaseScannerOpenWithStopResult) Write 

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

type HbaseScannerOpenWithStopTsArgs 

type HbaseScannerOpenWithStopTsArgs struct {
	TableName  Text            `thrift:"tableName,1" db:"tableName" json:"tableName"`
	StartRow   Text            `thrift:"startRow,2" db:"startRow" json:"startRow"`
	StopRow    Text            `thrift:"stopRow,3" db:"stopRow" json:"stopRow"`
	Columns    []Text          `thrift:"columns,4" db:"columns" json:"columns"`
	Timestamp  int64           `thrift:"timestamp,5" db:"timestamp" json:"timestamp"`
	Attributes map[string]Text `thrift:"attributes,6" db:"attributes" json:"attributes"`
}

Attributes:

  • TableName: name of table
  • StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

  • StopRow: row to stop scanning on. This row is *not* included in the

scanner's results

  • Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

  • Timestamp: timestamp
  • Attributes: Scan attributes

func NewHbaseScannerOpenWithStopTsArgs 

func NewHbaseScannerOpenWithStopTsArgs() *HbaseScannerOpenWithStopTsArgs

func (*HbaseScannerOpenWithStopTsArgs) GetAttributes 

func (p *HbaseScannerOpenWithStopTsArgs) GetAttributes() map[string]Text

func (*HbaseScannerOpenWithStopTsArgs) GetColumns 

func (p *HbaseScannerOpenWithStopTsArgs) GetColumns() []Text

func (*HbaseScannerOpenWithStopTsArgs) GetStartRow 

func (p *HbaseScannerOpenWithStopTsArgs) GetStartRow() Text

func (*HbaseScannerOpenWithStopTsArgs) GetStopRow 

func (p *HbaseScannerOpenWithStopTsArgs) GetStopRow() Text

func (*HbaseScannerOpenWithStopTsArgs) GetTableName 

func (p *HbaseScannerOpenWithStopTsArgs) GetTableName() Text

func (*HbaseScannerOpenWithStopTsArgs) GetTimestamp 

func (p *HbaseScannerOpenWithStopTsArgs) GetTimestamp() int64

func (*HbaseScannerOpenWithStopTsArgs) Read 

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

func (*HbaseScannerOpenWithStopTsArgs) ReadField1 

func (p *HbaseScannerOpenWithStopTsArgs) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsArgs) ReadField2 

func (p *HbaseScannerOpenWithStopTsArgs) ReadField2(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsArgs) ReadField3 

func (p *HbaseScannerOpenWithStopTsArgs) ReadField3(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsArgs) ReadField4 

func (p *HbaseScannerOpenWithStopTsArgs) ReadField4(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsArgs) ReadField5 

func (p *HbaseScannerOpenWithStopTsArgs) ReadField5(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsArgs) ReadField6 

func (p *HbaseScannerOpenWithStopTsArgs) ReadField6(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsArgs) String 

func (p *HbaseScannerOpenWithStopTsArgs) String() string

func (*HbaseScannerOpenWithStopTsArgs) Write 

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

type HbaseScannerOpenWithStopTsResult 

type HbaseScannerOpenWithStopTsResult struct {
	Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
	Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

  • Success
  • Io

func NewHbaseScannerOpenWithStopTsResult 

func NewHbaseScannerOpenWithStopTsResult() *HbaseScannerOpenWithStopTsResult

func (*HbaseScannerOpenWithStopTsResult) GetIo 

func (p *HbaseScannerOpenWithStopTsResult) GetIo() *IOError

func (*HbaseScannerOpenWithStopTsResult) GetSuccess 

func (p *HbaseScannerOpenWithStopTsResult) GetSuccess() ScannerID

func (*HbaseScannerOpenWithStopTsResult) IsSetIo 

func (p *HbaseScannerOpenWithStopTsResult) IsSetIo() bool

func (*HbaseScannerOpenWithStopTsResult) IsSetSuccess 

func (p *HbaseScannerOpenWithStopTsResult) IsSetSuccess() bool

func (*HbaseScannerOpenWithStopTsResult) Read 

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

func (*HbaseScannerOpenWithStopTsResult) ReadField0 

func (p *HbaseScannerOpenWithStopTsResult) ReadField0(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsResult) ReadField1 

func (p *HbaseScannerOpenWithStopTsResult) ReadField1(iprot thrift.TProtocol) error

func (*HbaseScannerOpenWithStopTsResult) String 

func (p *HbaseScannerOpenWithStopTsResult) String() string

func (*HbaseScannerOpenWithStopTsResult) Write 

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

type IOError 

type IOError struct {
	Message string `thrift:"message,1" db:"message" json:"message"`
}

An IOError exception signals that an error occurred communicating to the Hbase master or an Hbase region server. Also used to return more general Hbase error conditions.

Attributes:

  • Message
var HbaseAppendResult_Io_DEFAULT *IOError
var HbaseAtomicIncrementResult_Io_DEFAULT *IOError
var HbaseCheckAndPutResult_Io_DEFAULT *IOError
var HbaseCompactResult_Io_DEFAULT *IOError
var HbaseCreateTableResult_Io_DEFAULT *IOError
var HbaseDeleteAllResult_Io_DEFAULT *IOError
var HbaseDeleteAllRowResult_Io_DEFAULT *IOError
var HbaseDeleteAllRowTsResult_Io_DEFAULT *IOError
var HbaseDeleteAllTsResult_Io_DEFAULT *IOError
var HbaseDeleteTableResult_Io_DEFAULT *IOError
var HbaseDisableTableResult_Io_DEFAULT *IOError
var HbaseEnableTableResult_Io_DEFAULT *IOError
var HbaseGetColumnDescriptorsResult_Io_DEFAULT *IOError
var HbaseGetRegionInfoResult_Io_DEFAULT *IOError
var HbaseGetResult_Io_DEFAULT *IOError
var HbaseGetRowOrBeforeResult_Io_DEFAULT *IOError
var HbaseGetRowResult_Io_DEFAULT *IOError
var HbaseGetRowTsResult_Io_DEFAULT *IOError
var HbaseGetRowWithColumnsResult_Io_DEFAULT *IOError
var HbaseGetRowWithColumnsTsResult_Io_DEFAULT *IOError
var HbaseGetRowsResult_Io_DEFAULT *IOError
var HbaseGetRowsTsResult_Io_DEFAULT *IOError
var HbaseGetRowsWithColumnsResult_Io_DEFAULT *IOError
var HbaseGetRowsWithColumnsTsResult_Io_DEFAULT *IOError
var HbaseGetTableNamesResult_Io_DEFAULT *IOError
var HbaseGetTableRegionsResult_Io_DEFAULT *IOError
var HbaseGetVerResult_Io_DEFAULT *IOError
var HbaseGetVerTsResult_Io_DEFAULT *IOError
var HbaseIncrementResult_Io_DEFAULT *IOError
var HbaseIncrementRowsResult_Io_DEFAULT *IOError
var HbaseIsTableEnabledResult_Io_DEFAULT *IOError
var HbaseMajorCompactResult_Io_DEFAULT *IOError
var HbaseMutateRowResult_Io_DEFAULT *IOError
var HbaseMutateRowTsResult_Io_DEFAULT *IOError
var HbaseMutateRowsResult_Io_DEFAULT *IOError
var HbaseMutateRowsTsResult_Io_DEFAULT *IOError
var HbaseScannerCloseResult_Io_DEFAULT *IOError
var HbaseScannerGetListResult_Io_DEFAULT *IOError
var HbaseScannerGetResult_Io_DEFAULT *IOError
var HbaseScannerOpenResult_Io_DEFAULT *IOError
var HbaseScannerOpenTsResult_Io_DEFAULT *IOError
var HbaseScannerOpenWithPrefixResult_Io_DEFAULT *IOError
var HbaseScannerOpenWithScanResult_Io_DEFAULT *IOError
var HbaseScannerOpenWithStopResult_Io_DEFAULT *IOError
var HbaseScannerOpenWithStopTsResult_Io_DEFAULT *IOError

func NewIOError 

func NewIOError() *IOError

func (*IOError) Error 

func (p *IOError) Error() string

func (*IOError) GetMessage 

func (p *IOError) GetMessage() string

func (*IOError) Read 

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

func (*IOError) ReadField1 

func (p *IOError) ReadField1(iprot thrift.TProtocol) error

func (*IOError) String 

func (p *IOError) String() string

func (*IOError) Write 

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

type IllegalArgument 

type IllegalArgument struct {
	Message string `thrift:"message,1" db:"message" json:"message"`
}

An IllegalArgument exception indicates an illegal or invalid argument was passed into a procedure.

Attributes:

  • Message
var HbaseAtomicIncrementResult_Ia_DEFAULT *IllegalArgument
var HbaseCheckAndPutResult_Ia_DEFAULT *IllegalArgument
var HbaseCreateTableResult_Ia_DEFAULT *IllegalArgument
var HbaseMutateRowResult_Ia_DEFAULT *IllegalArgument
var HbaseMutateRowTsResult_Ia_DEFAULT *IllegalArgument
var HbaseMutateRowsResult_Ia_DEFAULT *IllegalArgument
var HbaseMutateRowsTsResult_Ia_DEFAULT *IllegalArgument
var HbaseScannerCloseResult_Ia_DEFAULT *IllegalArgument
var HbaseScannerGetListResult_Ia_DEFAULT *IllegalArgument
var HbaseScannerGetResult_Ia_DEFAULT *IllegalArgument

func NewIllegalArgument 

func NewIllegalArgument() *IllegalArgument

func (*IllegalArgument) Error 

func (p *IllegalArgument) Error() string

func (*IllegalArgument) GetMessage 

func (p *IllegalArgument) GetMessage() string

func (*IllegalArgument) Read 

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

func (*IllegalArgument) ReadField1 

func (p *IllegalArgument) ReadField1(iprot thrift.TProtocol) error

func (*IllegalArgument) String 

func (p *IllegalArgument) String() string

func (*IllegalArgument) Write 

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

type Mutation 

type Mutation struct {
	IsDelete   bool `thrift:"isDelete,1" db:"isDelete" json:"isDelete"`
	Column     Text `thrift:"column,2" db:"column" json:"column"`
	Value      Text `thrift:"value,3" db:"value" json:"value"`
	WriteToWAL bool `thrift:"writeToWAL,4" db:"writeToWAL" json:"writeToWAL"`
}

A Mutation object is used to either update or delete a column-value.

Attributes:

  • IsDelete
  • Column
  • Value
  • WriteToWAL
var HbaseCheckAndPutArgs_Mput_DEFAULT *Mutation

func NewMutation 

func NewMutation() *Mutation

func (*Mutation) GetColumn 

func (p *Mutation) GetColumn() Text

func (*Mutation) GetIsDelete 

func (p *Mutation) GetIsDelete() bool

func (*Mutation) GetValue 

func (p *Mutation) GetValue() Text

func (*Mutation) GetWriteToWAL 

func (p *Mutation) GetWriteToWAL() bool

func (*Mutation) Read 

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

func (*Mutation) ReadField1 

func (p *Mutation) ReadField1(iprot thrift.TProtocol) error

func (*Mutation) ReadField2 

func (p *Mutation) ReadField2(iprot thrift.TProtocol) error

func (*Mutation) ReadField3 

func (p *Mutation) ReadField3(iprot thrift.TProtocol) error

func (*Mutation) ReadField4 

func (p *Mutation) ReadField4(iprot thrift.TProtocol) error

func (*Mutation) String 

func (p *Mutation) String() string

func (*Mutation) Write 

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

type ScannerID 

type ScannerID int32
var HbaseScannerOpenResult_Success_DEFAULT ScannerID
var HbaseScannerOpenTsResult_Success_DEFAULT ScannerID
var HbaseScannerOpenWithPrefixResult_Success_DEFAULT ScannerID
var HbaseScannerOpenWithScanResult_Success_DEFAULT ScannerID
var HbaseScannerOpenWithStopResult_Success_DEFAULT ScannerID
var HbaseScannerOpenWithStopTsResult_Success_DEFAULT ScannerID

func ScannerIDPtr 

func ScannerIDPtr(v ScannerID) *ScannerID

type TAppend 

type TAppend struct {
	Table   Text   `thrift:"table,1" db:"table" json:"table"`
	Row     Text   `thrift:"row,2" db:"row" json:"row"`
	Columns []Text `thrift:"columns,3" db:"columns" json:"columns"`
	Values  []Text `thrift:"values,4" db:"values" json:"values"`
}

An Append object is used to specify the parameters for performing the append operation.

Attributes:

  • Table
  • Row
  • Columns
  • Values
var HbaseAppendArgs_Append_DEFAULT *TAppend

func NewTAppend 

func NewTAppend() *TAppend

func (*TAppend) GetColumns 

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

func (*TAppend) GetRow 

func (p *TAppend) GetRow() Text

func (*TAppend) GetTable 

func (p *TAppend) GetTable() Text

func (*TAppend) GetValues 

func (p *TAppend) GetValues() []Text

func (*TAppend) Read 

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

func (*TAppend) ReadField1 

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

func (*TAppend) ReadField2 

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

func (*TAppend) ReadField3 

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

func (*TAppend) ReadField4 

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

func (*TAppend) String 

func (p *TAppend) String() string

func (*TAppend) Write 

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

type TCell 

type TCell struct {
	Value     Bytes `thrift:"value,1" db:"value" json:"value"`
	Timestamp int64 `thrift:"timestamp,2" db:"timestamp" json:"timestamp"`
}

TCell - Used to transport a cell value (byte[]) and the timestamp it was stored with together as a result for get and getRow methods. This promotes the timestamp of a cell to a first-class value, making it easy to take note of temporal data. Cell is used all the way from HStore up to HTable.

Attributes:

  • Value
  • Timestamp
var TColumn_Cell_DEFAULT *TCell

func NewTCell 

func NewTCell() *TCell

func (*TCell) GetTimestamp 

func (p *TCell) GetTimestamp() int64

func (*TCell) GetValue 

func (p *TCell) GetValue() Bytes

func (*TCell) Read 

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

func (*TCell) ReadField1 

func (p *TCell) ReadField1(iprot thrift.TProtocol) error

func (*TCell) ReadField2 

func (p *TCell) ReadField2(iprot thrift.TProtocol) error

func (*TCell) String 

func (p *TCell) String() string

func (*TCell) Write 

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

type TColumn 

type TColumn struct {
	ColumnName Text   `thrift:"columnName,1" db:"columnName" json:"columnName"`
	Cell       *TCell `thrift:"cell,2" db:"cell" json:"cell"`
}

Holds column name and the cell.

Attributes:

  • ColumnName
  • Cell

func NewTColumn 

func NewTColumn() *TColumn

func (*TColumn) GetCell 

func (p *TColumn) GetCell() *TCell

func (*TColumn) GetColumnName 

func (p *TColumn) GetColumnName() Text

func (*TColumn) IsSetCell 

func (p *TColumn) IsSetCell() bool

func (*TColumn) Read 

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

func (*TColumn) ReadField1 

func (p *TColumn) ReadField1(iprot thrift.TProtocol) error

func (*TColumn) ReadField2 

func (p *TColumn) ReadField2(iprot thrift.TProtocol) error

func (*TColumn) String 

func (p *TColumn) String() string

func (*TColumn) Write 

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

type TIncrement 

type TIncrement struct {
	Table   Text  `thrift:"table,1" db:"table" json:"table"`
	Row     Text  `thrift:"row,2" db:"row" json:"row"`
	Column  Text  `thrift:"column,3" db:"column" json:"column"`
	Ammount int64 `thrift:"ammount,4" db:"ammount" json:"ammount"`
}

For increments that are not incrementColumnValue equivalents.

Attributes:

  • Table
  • Row
  • Column
  • Ammount
var HbaseIncrementArgs_Increment_DEFAULT *TIncrement

func NewTIncrement 

func NewTIncrement() *TIncrement

func (*TIncrement) GetAmmount 

func (p *TIncrement) GetAmmount() int64

func (*TIncrement) GetColumn 

func (p *TIncrement) GetColumn() Text

func (*TIncrement) GetRow 

func (p *TIncrement) GetRow() Text

func (*TIncrement) GetTable 

func (p *TIncrement) GetTable() Text

func (*TIncrement) Read 

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

func (*TIncrement) ReadField1 

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

func (*TIncrement) ReadField2 

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

func (*TIncrement) ReadField3 

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

func (*TIncrement) ReadField4 

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

func (*TIncrement) String 

func (p *TIncrement) String() string

func (*TIncrement) Write 

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

type TRegionInfo 

type TRegionInfo struct {
	StartKey   Text  `thrift:"startKey,1" db:"startKey" json:"startKey"`
	EndKey     Text  `thrift:"endKey,2" db:"endKey" json:"endKey"`
	ID         int64 `thrift:"id,3" db:"id" json:"id"`
	Name       Text  `thrift:"name,4" db:"name" json:"name"`
	Version    int8  `thrift:"version,5" db:"version" json:"version"`
	ServerName Text  `thrift:"serverName,6" db:"serverName" json:"serverName"`
	Port       int32 `thrift:"port,7" db:"port" json:"port"`
}

A TRegionInfo contains information about an HTable region.

Attributes:

  • StartKey
  • EndKey
  • ID
  • Name
  • Version
  • ServerName
  • Port
var HbaseGetRegionInfoResult_Success_DEFAULT *TRegionInfo

func NewTRegionInfo 

func NewTRegionInfo() *TRegionInfo

func (*TRegionInfo) GetEndKey 

func (p *TRegionInfo) GetEndKey() Text

func (*TRegionInfo) GetID 

func (p *TRegionInfo) GetID() int64

func (*TRegionInfo) GetName 

func (p *TRegionInfo) GetName() Text

func (*TRegionInfo) GetPort 

func (p *TRegionInfo) GetPort() int32

func (*TRegionInfo) GetServerName 

func (p *TRegionInfo) GetServerName() Text

func (*TRegionInfo) GetStartKey 

func (p *TRegionInfo) GetStartKey() Text

func (*TRegionInfo) GetVersion 

func (p *TRegionInfo) GetVersion() int8

func (*TRegionInfo) Read 

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

func (*TRegionInfo) ReadField1 

func (p *TRegionInfo) ReadField1(iprot thrift.TProtocol) error

func (*TRegionInfo) ReadField2 

func (p *TRegionInfo) ReadField2(iprot thrift.TProtocol) error

func (*TRegionInfo) ReadField3 

func (p *TRegionInfo) ReadField3(iprot thrift.TProtocol) error

func (*TRegionInfo) ReadField4 

func (p *TRegionInfo) ReadField4(iprot thrift.TProtocol) error

func (*TRegionInfo) ReadField5 

func (p *TRegionInfo) ReadField5(iprot thrift.TProtocol) error

func (*TRegionInfo) ReadField6 

func (p *TRegionInfo) ReadField6(iprot thrift.TProtocol) error

func (*TRegionInfo) ReadField7 

func (p *TRegionInfo) ReadField7(iprot thrift.TProtocol) error

func (*TRegionInfo) String 

func (p *TRegionInfo) String() string

func (*TRegionInfo) Write 

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

type TRowResult_ 

type TRowResult_ struct {
	Row           Text              `thrift:"row,1" db:"row" json:"row"`
	Columns       map[string]*TCell `thrift:"columns,2" db:"columns" json:"columns,omitempty"`
	SortedColumns []*TColumn        `thrift:"sortedColumns,3" db:"sortedColumns" json:"sortedColumns,omitempty"`
}

Holds row name and then a map of columns to cells.

Attributes:

  • Row
  • Columns
  • SortedColumns

func NewTRowResult_ 

func NewTRowResult_() *TRowResult_

func (*TRowResult_) GetColumns 

func (p *TRowResult_) GetColumns() map[string]*TCell

func (*TRowResult_) GetRow 

func (p *TRowResult_) GetRow() Text

func (*TRowResult_) GetSortedColumns 

func (p *TRowResult_) GetSortedColumns() []*TColumn

func (*TRowResult_) IsSetColumns 

func (p *TRowResult_) IsSetColumns() bool

func (*TRowResult_) IsSetSortedColumns 

func (p *TRowResult_) IsSetSortedColumns() bool

func (*TRowResult_) Read 

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

func (*TRowResult_) ReadField1 

func (p *TRowResult_) ReadField1(iprot thrift.TProtocol) error

func (*TRowResult_) ReadField2 

func (p *TRowResult_) ReadField2(iprot thrift.TProtocol) error

func (*TRowResult_) ReadField3 

func (p *TRowResult_) ReadField3(iprot thrift.TProtocol) error

func (*TRowResult_) String 

func (p *TRowResult_) String() string

func (*TRowResult_) Write 

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

type TScan 

type TScan struct {
	StartRow     Text   `thrift:"startRow,1" db:"startRow" json:"startRow,omitempty"`
	StopRow      Text   `thrift:"stopRow,2" db:"stopRow" json:"stopRow,omitempty"`
	Timestamp    *int64 `thrift:"timestamp,3" db:"timestamp" json:"timestamp,omitempty"`
	Columns      []Text `thrift:"columns,4" db:"columns" json:"columns,omitempty"`
	Caching      *int32 `thrift:"caching,5" db:"caching" json:"caching,omitempty"`
	FilterString Text   `thrift:"filterString,6" db:"filterString" json:"filterString,omitempty"`
	BatchSize    *int32 `thrift:"batchSize,7" db:"batchSize" json:"batchSize,omitempty"`
	SortColumns  *bool  `thrift:"sortColumns,8" db:"sortColumns" json:"sortColumns,omitempty"`
	Reversed     *bool  `thrift:"reversed,9" db:"reversed" json:"reversed,omitempty"`
}

A Scan object is used to specify scanner parameters when opening a scanner.

Attributes:

  • StartRow
  • StopRow
  • Timestamp
  • Columns
  • Caching
  • FilterString
  • BatchSize
  • SortColumns
  • Reversed
var HbaseScannerOpenWithScanArgs_Scan_DEFAULT *TScan

func NewTScan 

func NewTScan() *TScan

func (*TScan) GetBatchSize 

func (p *TScan) GetBatchSize() int32

func (*TScan) GetCaching 

func (p *TScan) GetCaching() int32

func (*TScan) GetColumns 

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

func (*TScan) GetFilterString 

func (p *TScan) GetFilterString() Text

func (*TScan) GetReversed 

func (p *TScan) GetReversed() bool

func (*TScan) GetSortColumns 

func (p *TScan) GetSortColumns() bool

func (*TScan) GetStartRow 

func (p *TScan) GetStartRow() Text

func (*TScan) GetStopRow 

func (p *TScan) GetStopRow() Text

func (*TScan) GetTimestamp 

func (p *TScan) GetTimestamp() int64

func (*TScan) IsSetBatchSize 

func (p *TScan) IsSetBatchSize() bool

func (*TScan) IsSetCaching 

func (p *TScan) IsSetCaching() bool

func (*TScan) IsSetColumns 

func (p *TScan) IsSetColumns() bool

func (*TScan) IsSetFilterString 

func (p *TScan) IsSetFilterString() bool

func (*TScan) IsSetReversed 

func (p *TScan) IsSetReversed() bool

func (*TScan) IsSetSortColumns 

func (p *TScan) IsSetSortColumns() bool

func (*TScan) IsSetStartRow 

func (p *TScan) IsSetStartRow() bool

func (*TScan) IsSetStopRow 

func (p *TScan) IsSetStopRow() bool

func (*TScan) IsSetTimestamp 

func (p *TScan) IsSetTimestamp() bool

func (*TScan) Read 

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

func (*TScan) ReadField1 

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

func (*TScan) ReadField2 

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

func (*TScan) ReadField3 

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

func (*TScan) ReadField4 

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

func (*TScan) ReadField5 

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

func (*TScan) ReadField6 

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

func (*TScan) ReadField7 

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

func (*TScan) ReadField8 

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

func (*TScan) ReadField9 

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

func (*TScan) String 

func (p *TScan) String() string

func (*TScan) Write 

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

type Text 

type Text []byte
var TScan_FilterString_DEFAULT Text
var TScan_StartRow_DEFAULT Text
var TScan_StopRow_DEFAULT Text

func TextPtr 

func TextPtr(v Text) *Text

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.