Skip to content

Commit ce367cf

Browse files
author
James Lee
committed
stop sessions in the end
1 parent 1f99c37 commit ce367cf

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/main/java/com/sparkTutorial/sparkSql/StackOverFlowSurvey.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,5 +61,8 @@ public static void main(String[] args) throws Exception {
6161
System.out.println("=== Group by salary bucket ===");
6262
Dataset<Row> responseWithSalaryBucket = castedResponse.withColumn(SALARY_MIDPOINT_BUCKET, col(SALARY_MIDPOINT).divide(20000).cast("integer").multiply(20000));
6363
responseWithSalaryBucket.groupBy(SALARY_MIDPOINT_BUCKET).count().orderBy(col(SALARY_MIDPOINT_BUCKET)).show();
64+
65+
66+
session.stop();
6467
}
6568
}

0 commit comments

Comments
 (0)