public Map < String , Long > getOffsetsLag ( Map < String , String > offsetMap ) throws IOException { return fileContextProvider . getOffsetsLag ( offsetMap ) ; }
Determines the offset lag for each active file being read .