Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private void saveKeywords(String key, final List<String> keywords, final String columnName) {
- this.hbaseTemplate.execute(TABLE_NAME, new TableCallback() {
- @Override
- public Object doWithTable(HTable hTable) throws Exception {
- try {
- Put put = new Put(toBytes(key));
- put.add(toBytes(COLUMN_FAMILY), toBytes(columnName), toBytes(join(keywords.iterator(), ",")));
- hTable.put(put);
- }
- } catch (Exception e) {
- LOGGER.error("Error occurred while saving " + columnName + " keywords", e);
- }
- return null;
- }
- });
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement