public ReplicationJob createJobForDropTable(long auditLogId,long auditLogEntryCreateTime,Table table) throws StateUpdateException {
  ReplicationOperation replicationOperation=ReplicationOperation.DROP_TABLE;
  Map<String,String> extras=new HashMap<>();
  extras.put(PersistedJobInfo.AUDIT_LOG_ID_EXTRAS_KEY,Long.toString(auditLogId));
  extras.put(PersistedJobInfo.AUDIT_LOG_ENTRY_CREATE_TIME_KEY,Long.toString(auditLogEntryCreateTime));
  HiveObjectSpec tableSpec=new HiveObjectSpec(table);
  PersistedJobInfo persistedJobInfo=jobInfoStore.resilientCreate(replicationOperation,ReplicationStatus.PENDING,ReplicationUtils.getLocation(table),srcCluster.getName(),tableSpec,Collections.emptyList(),ReplicationUtils.getTldt(table),Optional.empty(),Optional.empty(),extras);
  return new ReplicationJob(conf,new DropTableTask(srcCluster,destCluster,tableSpec,ReplicationUtils.getTldt(table)),onStateChangeHandler,persistedJobInfo);
}

public ReplicationJob createJobForDropTable ( long auditLogId , long auditLogEntryCreateTime , Table table ) throws StateUpdateException { ReplicationOperation replicationOperation = ReplicationOperation . DROP_TABLE ; Map < String , String > extras = new HashMap < > ( ) ; extras . put ( PersistedJobInfo . AUDIT_LOG_ID_EXTRAS_KEY , Long . toString ( auditLogId ) ) ; extras . put ( PersistedJobInfo . AUDIT_LOG_ENTRY_CREATE_TIME_KEY , Long . toString ( auditLogEntryCreateTime ) ) ; HiveObjectSpec tableSpec = new HiveObjectSpec ( table ) ; PersistedJobInfo persistedJobInfo = jobInfoStore . resilientCreate ( replicationOperation , ReplicationStatus . PENDING , ReplicationUtils . getLocation ( table ) , srcCluster . getName ( ) , tableSpec , Collections . emptyList ( ) , ReplicationUtils . getTldt ( table ) , Optional . empty ( ) , Optional . empty ( ) , extras ) ; return new ReplicationJob ( conf , new DropTableTask ( srcCluster , destCluster , tableSpec , ReplicationUtils . getTldt ( table ) ) , onStateChangeHandler , persistedJobInfo ) ; }
create a replication job to drop a table .
