@ Override public void configure ( Configuration parameters ) { super . configure ( parameters ) ; String delimString = parameters . getString ( RECORD_DELIMITER , null ) ; if ( delimString != null ) { String charsetName = parameters . getString ( RECORD_DELIMITER_ENCODING , null ) ; if ( charsetName == null ) { setDelimiter ( delimString ) ; } else { try { setDelimiter ( delimString , charsetName ) ; } catch ( UnsupportedCharsetException e ) { throw new IllegalArgumentException ( "The charset with the name '" + charsetName + "' is not supported on this TaskManager instance." , e ) ; } } } // set the number of samples String samplesString = parameters . getString ( NUM_STATISTICS_SAMPLES , null ) ; if ( samplesString != null ) { try { setNumLineSamples ( Integer . parseInt ( samplesString ) ) ; } catch ( NumberFormatException e ) { if ( LOG . isWarnEnabled ( ) ) { LOG . warn ( "Invalid value for number of samples to take: " + samplesString + ". Skipping sampling." ) ; } setNumLineSamples ( 0 ) ; } } }
Configures this input format by reading the path to the file from the configuration andge the string that defines the record delimiter .