From class
org.mule.module.hbase.HbaseCloudConnector
|
void
|
addColumnFamily(String tableName, String columnFamilyName, Integer maxVersions, Boolean inMemory, Integer scope)
Adds a column family to a table given a table and column name.
|
|
boolean
|
checkAndDeleteValue(String tableName, String rowKey, String checkColumnFamilyName, String checkColumnQualifier, Object checkValue, String deleteColumnFamilyName, String deleteColumnQualifier, Long deleteTimestamp, boolean deleteAllVersions, RowLock lock)
Atomically checks if a value at a (table, row,family,qualifier) matches
the given one.
|
|
boolean
|
checkAndPutValue(String tableName, String rowKey, String checkColumnFamilyName, String checkColumnQualifier, Object checkValue, String putColumnFamilyName, String putColumnQualifier, Long putTimestamp, Object value, boolean writeToWAL, RowLock lock)
Atomically checks if a value at a (table, row,family,qualifier) matches
the given one.
|
|
void
|
createTable(String tableName)
Creates a new table given its name.
|
|
void
|
deleteColumnFamily(String tableName, String columnFamilyName)
Delete a column family
|
|
void
|
deleteTable(String tableName)
Disables and deletes an existent table.
|
|
void
|
deleteValues(String tableName, String rowKey, String columnFamilyName, String columnQualifier, Long timestamp, boolean deleteAllVersions, RowLock lock)
Deletes the values at a given row
|
|
void
|
disableTable(String tableName)
Disables an existent table
|
|
void
|
enableTable(String tableName)
Enables an existent table.
|
|
boolean
|
existsColumnFamily(String tableName, String columnFamilyName)
Answers if column family exists.
|
|
boolean
|
existsTable(String tableName)
Answers if a given table exists, regardless it is enabled or not
|
|
HBaseService
|
getFacade()
|
|
Map<String, String>
|
getProperties()
|
|
Result
|
getValues(String tableName, String rowKey, String columnFamilyName, String columnQualifier, Integer maxVersions, Long timestamp)
Answers the values at the given row - (table, row) combination
|
|
long
|
incrementValue(String tableName, String rowKey, String columnFamilyName, String columnQualifier, long amount, boolean writeToWAL)
Atomically increments the value of at a (table, row, familyName,
familyQualifier) combination.
|
|
void
|
initialiseConnector()
|
|
boolean
|
isAliveServer()
Answers if the HBase server is reachable
|
|
boolean
|
isEnabledTable(String tableName)
Answers if the given existent table is enabled.
|
|
void
|
modifyColumnFamily(String tableName, String columnFamilyName, Integer maxVersions, Integer blocksize, CompressionType compressionType, CompressionType compactionCompressionType, Boolean inMemory, Integer timeToLive, Boolean blockCacheEnabled, BloomFilterType bloomFilterType, Integer replicationScope, Map<String, String> values)
Changes one or more properties of a column family in a table.
|
|
void
|
putValue(String tableName, String rowKey, String columnFamilyName, String columnQualifier, Long timestamp, Object value, boolean writeToWAL, RowLock lock)
Saves a value at the specified (table, row, familyName, familyQualifier,
timestamp) combination
|
|
Iterable<Result>
|
scanTable(String tableName, String columnFamilyName, String columnQualifier, Long timestamp, Long maxTimestamp, Integer caching, boolean cacheBlocks, int maxVersions, String startRowKey, String stopRowKey, int fetchSize)
Scans across all rows in a table, returning a scanner over it
|
|
void
|
setFacade(HBaseService facade)
|
|
void
|
setProperties(Map<String, String> properties)
|
|
