2013-12-26 1 views
1

HBASE-3996 Поддержка нескольких таблиц и сканеров в качестве входных данных для картографа в карте/сокращении задания. Функция карты всегда выглядит следующим образом:Как получить имя таблицы HBase из объекта Result в качестве параметра mapreduce?

public void map(ImmutableBytesWritable row, Result value, Context context) 

В функции карты, как я могу определить, какую таблицу значения (результат) происходит от?

ответ

0

Вы можете извлечь TableSplit из контекста, это должно работать для вас (не проверено):

public void map(ImmutableBytesWritable row, Result value, Context context) { 
    TableSplit currentSplit = (TableSplit)context.getInputSplit(); 
    byte[] tableName = split.getTableName(); 
    .... 
} 
Смежные вопросы