Вы можете использовать HBase API в задании Hadoop.
Вот некоторые фрагменты кода для использования HBase API в задании.
Импорт
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
Это внутри функции @Override
в моем коде
private HTable hTable = null;
Configuration hConfig = HBaseConfiguration.create();
hConfig.set(Constants.HBASE_CONFIGURATION_ZOOKEEPER_QUORUM, zkQuorum);
hConfig.set(Constants.HBASE_CONFIGURATION_ZOOKEEPER_CLIENTPORT, zkclientPort);
hTable = new HTable(hConfig, hbCube);
...
hTable.put(subPuts);
Очевидно, что не полные фрагменты, но с правильным imports
и предоставлением правильных значений ваша работа (у меня был только картограф) может получить доступ к HBase API.
Надеюсь, это поможет.