org.wso2.carbon.analytics.datasource.hbase.util

Class HBaseUtils

java.lang.Object

org.wso2.carbon.analytics.datasource.hbase.util.HBaseUtils

public class HBaseUtils
extends Object

Class containing various utility methods required by classes from the HBase Analytics Datasource implementation

Constructor Summary

Constructors

Constructor and Description
HBaseUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static org.wso2.carbon.analytics.datasource.commons.Record	constructRecord(org.apache.hadoop.hbase.client.Result currentResult, int tenantId, String tableName, Set<String> colSet)
static org.apache.hadoop.fs.Path	createPath(String source)
static long	decodeLong(byte[] arr)
static byte[]	encodeLong(long value)
static String	generateGenericTableName(int tenantId, String tableName)
static String	generateTableName(int tenantId, String tableName, HBaseAnalyticsDSConstants.TableType type)
static String	generateTablePrefix(int tenantId, HBaseAnalyticsDSConstants.TableType type)
static String	inferTableName(String genericTableName)
static int	inferTenantId(String genericTableName)
static HBaseAnalyticsConfigurationEntry	lookupConfiguration()
static String	normalizeTableName(String tableName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HBaseUtils

public HBaseUtils()

Method Detail

normalizeTableName

public static String normalizeTableName(String tableName)

generateTablePrefix

public static String generateTablePrefix(int tenantId,
                         HBaseAnalyticsDSConstants.TableType type)

generateTableName

public static String generateTableName(int tenantId,
                       String tableName,
                       HBaseAnalyticsDSConstants.TableType type)

generateGenericTableName

public static String generateGenericTableName(int tenantId,
                              String tableName)

inferTenantId

public static int inferTenantId(String genericTableName)

inferTableName

public static String inferTableName(String genericTableName)

createPath

public static org.apache.hadoop.fs.Path createPath(String source)

encodeLong

public static byte[] encodeLong(long value)

decodeLong

public static long decodeLong(byte[] arr)

constructRecord

public static org.wso2.carbon.analytics.datasource.commons.Record constructRecord(org.apache.hadoop.hbase.client.Result currentResult,
                                                                  int tenantId,
                                                                  String tableName,
                                                                  Set<String> colSet)
                                                                           throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

lookupConfiguration

public static HBaseAnalyticsConfigurationEntry lookupConfiguration()
                                                            throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException