void sendStateUpdateToNode(LlapNodeId nodeId, String sourceName, VertexState state) {
    taskCommunicator.sendStateUpdate(nodeId,
        SourceStateUpdatedRequestProto.newBuilder().setQueryIdentifier(currentQueryIdentifier)
            .setSrcName(sourceName).setState(Converters.fromVertexState(state)).build());
  }
Constructs FragmentRuntimeInfo for scheduling within LLAP daemons.
Also caches state based on state updates.
@param vertexName
@param fragmentNumber
@param priority
@return
llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java