The above code is resulting in issues as it has a column name as keyword
предел. Если я удалю столбец «предел» из списка выбора, сценарий
работает нормально.
Таблица А имеет следующее содержание
\ **** Таблица A ******* \\\\
There are two tables A , B Table A as follows
ID Day Name Description limit
1 2016-09-01 Sam Retail 100
2 2016-01-28 Chris Retail 200
3 2016-02-06 ChrisTY Retail 50
4 2016-02-26 Christa Retail 10
3 2016-12-06 ChrisTu Retail 200
4 2016-12-31 Christi Retail 500
Table B has following contents
\\\**** Table B *****\\\\\\\
Table B
ID SkEY
1 1.1
2 1.2
3 1.3
Приведенный выше код вызывает проблемы, так как в качестве ключевого слова используется имя столбца
предел. Если я удалю столбец «предел» из списка выбора, сценарий
работает нормально.
\\\**** Tried Code *****\\\\\\\
from pyspark.sql import sparksession
from pyspark.sql import functions as F
from pyspark.sql.functions import lit
from pyspark import HiveContext
hiveContext= HiveContext(sc)
ABC2 = spark.sql(
"select * From A where day ='{0}'".format(i[0])
)
Join = ABC2.join(
Tab2,
(
ABC2.ID == Tab2.ID
)
)\
.select(
Tab2.skey,
ABC2.Day,
ABC2.Name,
ABC2.limit,)
withColumn('newcol1, lit('')),
withColumn('newcol2, lit('A'))
ABC2 .show()
АВС = spark.sql (
msgstr "выберите отличный день от А, где день = '2016-01-01'"
)
\\\**** Expected Result *****\\\\\\\
How can we amend the code so that the limit is also selected