class HBaseNotificationStore implements NotificationStore {

    @Override
    public Notification getNotification(String notificationId) {
        try {
            String tableName = notificationMapper.getTableName();
            LOG.debug("getting notification with notificationId {} from table {}", notificationId, tableName);
            Get get = new Get(notificationId.getBytes(StandardCharsets.UTF_8));
            Result result = tables.get(tableName).get().get(get);
            return result.isEmpty() ? null : notificationMapper.entity(result);
        } catch (IOException ex) {
            throw new NotificationStoreException("Error getting notification id: " + notificationId, ex);
        }
    }

}