고 싶 복제 아래 코드를 사용하여 pyspark 데이터 프레임 기능을 대신에 SQL 쿼리가 있습니다.
spark.sql("select date from walmart_stock order by high desc limit 1").show()
0
는 코드는 다음과 같습니다면 당신은에서 시작된 CSV 파일입니다. 당신을 인식해야 SQL functions. 참고는 우리가 사용하는 inferSchema 옵션하기 위해서 직접 구문 분석으로 숫자 복식과를 얻을 올바른 순서(그것은 작동하지 않을 것으로 예상 기본 문자열을 타입)으로 구성되어 있습니다. 또 다른 방법은 것을 주 열을 읽은 후 제공합니다.
spark.read
.option("header", "true")
.option("inferSchema", "true")
.csv("walmart_stock.csv")
.orderBy(f.col("High"), desc=True)
.limit(1)
.select("Date")
.show()
산
+----------+
| Date|
+----------+
|2015-11-13|
+----------+
내가 만든 테이블 walmart_stock 작업을 하 고 있습니다. 그래서 당신의 코드가 내 대답이다. 감사합니다.
BEing MECHon