тест перезаписи свечи зажигания

Question

Я новичок в pyspark и хотел бы поиграть с Insert Overwrite.

Я создал таблицу test_overwrite со многими записями. Затем я создал пустую таблицу test_overwrite_3 из test_overwrite и поместил в нее некоторые данные. (Я убедился, что структура та же.)

вставить перезапись test_overwrite_3 select * from test_overwrite limit 3

Я ожидаю, что после выполнения код над моей test_overwrite_3 таблицей с некоторыми фиктивными данными будет удален, и в ней должно быть 3 записи из моей test_overwrite таблицы.

Вместо этого я получил сообщение об ошибке, подобное этому :

* Ошибка в операторе SQL: ParseException: нет жизнеспособной альтернативы на входе 'вставить перезапись test_overwrite_3' (строка 1, позиция 17) == SQL == вставить перезапись test_overwrite_3 --- -------------- ^^^ select * from test_overwrite *

Может кто-нибудь помочь, что пошло не так? Спасибо!

Answer 1

no viable alternative at input 'insert overwrite test_overwrite_3

ошибка разбора, а не ошибка типа. смотри это

Я вижу, что в вашем выражении отсутствует ключевое слово таблицы.

Пример:

sql(
      """
        |INSERT OVERWRITE TABLE table_with_partition
        |partition (p1='a',p2='b',p3='c',p4='c',p5='4')
        |SELECT 'blarr' FROM tmp_table
      """.stripMargin)