Wenn ich Spark zum Parsen von Protokolldateien verwende, stelle ich fest, dass das erste Zeichen des Dateinamens @ is_, das Ergebnis ist leer. Hier ist mein Testcode:

SparkSession spark = SparkSession
  .builder()
  .appName("TestLog")
  .master("local")
  .getOrCreate();
JavaRDD<String> input = spark.read().text("D:\\_event_2.log").javaRDD();
System.out.println("size : " + input.count());

Wenn ich den Dateinamen in @ ändeevent_2.log, der Code wird es korrekt ausführen. Ich fand, dass dastext -Funktion ist definiert als:

@scala.annotation.varargs
def text(paths: String*): Dataset[String] = {
  format("text").load(paths : _*).as[String](sparkSession.implicits.newStringEncoder)
}

Ich denke, es könnte an @ lieg_ Sein Scalaplaceholder. Wie kann ich dieses Problem vermeiden?