public class AppToFlowTable extends BaseTable<AppToFlowTable>
|--------------------------------------| | Row | Column Family | | key | mapping | |--------------------------------------| | appId | flow_name!cluster1: | | | foo@daily_hive_report | | | | | | flow_run_id!cluster1: | | | 1452828720457 | | | | | | user_id!cluster1: | | | admin | | | | | | flow_name!cluster2: | | | bar@ad_hoc_query | | | | | | flow_run_id!cluster2: | | | 1452828498752 | | | | | | user_id!cluster2: | | | joe | | | | |--------------------------------------|It is possible (although unlikely) in a multi-cluster environment that there may be more than one applications for a given app id. Different clusters are recorded as different sets of columns.
Modifier and Type | Field and Description |
---|---|
static String |
TABLE_NAME_CONF_NAME
config param name that specifies the app_flow table name.
|
Constructor and Description |
---|
AppToFlowTable() |
Modifier and Type | Method and Description |
---|---|
void |
createTable(org.apache.hadoop.hbase.client.Admin admin,
org.apache.hadoop.conf.Configuration hbaseConf)
Used to create the table in HBase.
|
getResult, getResultScanner, getTableMutator, getTableName, getTableName, getTableName
public static final String TABLE_NAME_CONF_NAME
public void createTable(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.conf.Configuration hbaseConf) throws IOException
BaseTable
createTable
in class BaseTable<AppToFlowTable>
admin
- Used for doing HBase table operations.hbaseConf
- Hbase configuration.IOException
- if any exception occurs while creating the table.Copyright © 2017 Apache Software Foundation. All Rights Reserved.