scala . Tuple2 < java . io . InputStream , java . lang . String > function ( org . apache . hadoop . arg1 . Path arg0 , org . apache . hadoop . arg1 . FileSystem arg1 ) { throw new RuntimeException ( ) ; }
opens an event log file and returns an input stream to the event data . concode_field_sep EventLoggingListener$ MODULE$ concode_field_sep java.lang.String IN_PROGRESS concode_elem_sep java.lang.String HEADER_END_MARKER concode_elem_sep int MAX_HEADER_LINE_LENGTH concode_elem_sep org.apache.hadoop.fs.permission.FsPermission LOG_FILE_PERMISSIONS concode_elem_sep java.lang.String DEFAULT_LOG_DIR concode_elem_sep java.lang.String getLogPath concode_elem_sep java.io.OutputStream initEventLog concode_elem_sep scala.collection.mutable.HashMap<java.lang.String,org.apache.spark.io.CompressionCodec> codecMap