@Override
  public void onCommitCompaction(CommitCompactionEvent commitCompactionEvent, Connection dbConn, SQLGenerator sqlGenerator)
      throws MetaException {

    CommitCompactionMessage msg = MessageBuilder.getInstance().buildCommitCompactionMessage(commitCompactionEvent);

    NotificationEvent event = new NotificationEvent(0, now(), EventType.COMMIT_COMPACTION.toString(),
        msgEncoder.getSerializer().serialize(msg));
    event.setDbName(commitCompactionEvent.getDbname());
    event.setTableName(commitCompactionEvent.getTableName());
    event.setCatName(getDefaultCatalog(conf));
    try {
      addNotificationLog(event, commitCompactionEvent, dbConn, sqlGenerator);
    } catch (SQLException e) {
      throw new MetaException("Unable to execute direct SQL " + StringUtils.stringifyException(e));
    }
  }
@param allocWriteIdEvent Alloc write id event
@throws MetaException
hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/DbNotificationListener.java