Рабочий Spark SQL:
"SELECT current_timestamp() - INTERVAL 10 DAYS as diff from sample_table"
Пробный Spark SQL:
"SELECT current_timestamp() - INTERVAL col1 DAYS as diff from sample_table"
Ошибка:
"\ nсоответствующий ввод 'ДНЕЙ', ожидающих \ n\ n == SQL == \ nВЫБРАТЬ current_timestamp () - ДЕНЬ ИНТЕРВАЛА col1 как разность из sample_table \ n ------------------------------------------ ^^^ \ n "Traceback (последний вызов был последним): файл" /usr/lib/spark/python/lib/pyspark.zip/pyspark/sql/session.py ", строка 767, в sql возвращает DataFrame (self._jsparkSession.sql (sqlQuery), self._wrapped) файл" /usr/lib/spark/python/lib/py4j-0.10.7-src.zip/py4j/java_gateway.py ", строка 1257, в вызов ответ, self.gateway_client, self.target_id, self.name) Файл" /usr/lib/spark/python/lib/pyspark.zip/pyspark/sql/utils.py ", строка 73, в deco, вызвать ParseException (s.split (':', 1) [1], stackTrace) pyspark.sql.utils.ParseException:" \ nmismatched входные данные 'DAYS' ожидая \ n \ n== SQL == \ nSELECT current_timestamp () - ИНТЕРВАЛ col1 ДНЕЙ в виде различий из sample_table \ n ------------------------------------------ ^^^ \ n "