1. A method, comprising: receiving data from a network element; determining a candidate data processing task for the received data based upon a first similarity metric between the received data and data currently associated with the candidate data processing task; and sending the received data to the candidate data processing task.