question: public ReplicationJob createJobForCopyPartition ( long auditLogId , long auditLogEntryCreateTime , HiveObjectSpec spec ) throws StateUpdateException { 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 ) ) ; List < String > partitionNames = new ArrayList < > ( ) ; partitionNames . add ( spec . getPartitionName ( ) ) ; ReplicationOperation replicationOperation = ReplicationOperation . COPY_PARTITION ; PersistedJobInfo persistedJobInfo = jobInfoStore . resilientCreate ( replicationOperation , ReplicationStatus . PENDING , Optional . empty ( ) , srcCluster . getName ( ) , spec , partitionNames , Optional . empty ( ) , Optional . empty ( ) , Optional . empty ( ) , extras ) ; ReplicationTask replicationTask = new CopyPartitionTask ( conf , destinationObjectFactory , objectConflictHandler , srcCluster , destCluster , spec , Optional . < Path > empty ( ) , Optional . < Path > empty ( ) , directoryCopier , true ) ; return new ReplicationJob ( conf , replicationTask , onStateChangeHandler , persistedJobInfo ) ; }
target:  Create a replication job to copy a partition.