Invalid \ x Escape при загрузке Spark Dataframe

Question

Я загружаю фрейм данных искры, разделенный "\x0". Когда я запускаю это:

logs = sqlContext.read.format("csv").option("delimiter", "\x0").load("path")

Я получаю следующую ошибку:

ValueError: invalid \x escape

Как я могу это исправить?

Answer 1

Поскольку \ является escape-символом в python , его необходимо определить как литерал. Вы можете просто поставить r перед строкой, чтобы превратить ее в необработанную строку:

logs = sqlContext.read.format("csv").option("delimiter", r"\x0").load("path")