import pysparkfrom pyspark.sql.session import SparkSession #session 연결# Session 생성spark = SparkSession.builder.appName('Basics').getOrCreate()df = spark.read.options(delimiter='|').csv('20240424 전력가스 대용량 (반기별)/전력가스 DB_202001~202006.csv',header=True)#df = spark.read.option("header",'True').options(delimiter='|').csv('20240424 전력가스 대용량 (반기별)/전력가스 DB_202001~202006.csv')df.show()df.select("BASE_YM")..
