VP
SUBMIT_ARGS = "--packages org.apache.spark:spark-sql-kafka-0-10_2.12:3.1.1 --driver-class-path " \
"libs/postgresql-42.2.19.jar --jars libs/postgresql-42.2.19.jar pyspark-shell "
os.environ["PYSPARK_SUBMIT_ARGS"] = SUBMIT_ARGS
Size: a a a
VP
PM
B
B
PM
B
PM
VS
PM
VS
АЖ
PM
S
AZ
AB
ИШ
ИШ
S
VS
ИШ