code: @Deprecated
  	@SuppressWarnings("deprecation")
  	public DataStream<String> readFileStream(String filePath, long intervalMillis, FileMonitoringFunction.WatchType watchType) {
  		DataStream<Tuple3<String, Long, Long>> source = addSource(new FileMonitoringFunction(
  				filePath, intervalMillis, watchType), "Read File Stream source");
  
  		return source.flatMap(new FileReadFunction());
  	}
docs: Creates a data stream that contains the contents of file created while system watches the given path. The file
  will be read with the system's default character set.
  
  @param filePath
  The path of the file, as a URI (e.g., "file:///some/local/file" or "hdfs://host:port/file/path/")
  @param intervalMillis
  The interval of file watching in milliseconds
  @param watchType
  The watch type of file stream. When watchType is {@link org.apache.flink.streaming.api.functions.source.FileMonitoringFunction.WatchType#ONLY_NEW_FILES}, the system processes
  only
  new files. {@link org.apache.flink.streaming.api.functions.source.FileMonitoringFunction.WatchType#REPROCESS_WITH_APPENDED} means that the system re-processes all contents of
  appended file. {@link org.apache.flink.streaming.api.functions.source.FileMonitoringFunction.WatchType#PROCESS_ONLY_APPENDED} means that the system processes only appended
  contents
  of files.
  @return The DataStream containing the given directory.
  
  @deprecated Use {@link #readFile(FileInputFormat, String, FileProcessingMode, long)} instead.