private void maybeRegisterForVertexUpdates(String sourceName) {
    if (!notificationRegisteredVertices.contains(sourceName)) {
      notificationRegisteredVertices.add(sourceName);
      taskCommunicatorContext.registerForVertexStateUpdates(sourceName, EnumSet.of(
          VertexState.RUNNING, VertexState.SUCCEEDED));
    }
  }
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