Algorithm for spliting a data-job into sub-jobs

writeDataJob(dataJobId, DataJobMetadata, DataJobWriteRequest) {

	Map<ProducerKey, Collection> producerKeyMap = new HashMap()
	
	FOR writeRequest in DataJobWriteRequest
		dataNode = inventoryPersistence.getCmHandleDataNodeByLongestMatchAlternateId(writeOperation.path())
		
		ProducerKey prodKey = new ProducerKey( dataNode.dmiServiceName, dataProducerIdentifier)
		
		SubJobWriteRequest sjwr = createSubJobWriteRequest(DataJobMetadata, dataNode, dataJobId) // method to create the request
		if (producerKeyMap.contains(prodKey) {
			// update the Map's collection with the new request
		} else {
			producerKeyMap.put(prodKey, sjwr)
		}
	END FOR
	
	FOR value in producerKeyMap
		dmiUrl = DmiServiceUrlBuilder.createUrlForSubJob() // new method
		dmiRestClient.postOperation( value ) // send each collection of subjobs to the right DMI plugin
	END FOR
}