void registerJob ( final ExecutionGraph eg ) { final Iterator < ExecutionGroupVertex > it = new ExecutionGroupVertexIterator ( eg , true , - 1 ) ; while ( it . hasNext ( ) ) { final ExecutionGroupVertex groupVertex = it . next ( ) ; final InputSplit [ ] inputSplits = groupVertex . getInputSplits ( ) ; if ( inputSplits == null ) { continue ; } if ( inputSplits . length == 0 ) { continue ; } for ( int i = 0 ; i < groupVertex . getCurrentNumberOfGroupMembers ( ) ; ++ i ) { final ExecutionVertex vertex = groupVertex . getGroupMember ( i ) ; if ( this . splitMap . put ( vertex . getID ( ) , new ArrayList < InputSplit > ( ) ) != null ) { LOG . error ( "InputSplitTracker must keep track of two vertices with ID " + vertex . getID ( ) ) ; } } } }
Registers a new job with the input split tracker .