// Process the received profiling data
final Iterator<InternalProfilingData> dataIterator = profilingDataContainer.getIterator();
while (dataIterator.hasNext()) {
final InternalProfilingData internalProfilingData = dataIterator.next();
if (internalProfilingData instanceof InternalExecutionVertexThreadProfilingData) {
dispatchThreadData(timestamp, (InternalExecutionVertexThreadProfilingData) internalProfilingData);
} else if (internalProfilingData instanceof InternalInstanceProfilingData) {
dispatchInstanceData(timestamp, (InternalInstanceProfilingData) internalProfilingData);
} else if (internalProfilingData instanceof InternalInputGateProfilingData) {
dispatchInputGateData(timestamp, (InternalInputGateProfilingData) internalProfilingData);
} else if (internalProfilingData instanceof InternalOutputGateProfilingData) {
dispatchOutputGateData(timestamp, (InternalOutputGateProfilingData) internalProfilingData);
} else {
LOG.error("Received unknown profiling data: " + internalProfilingData.getClass().getName());
}
}
}