Commitcaf78df

James Lee

committed

improve UkMarketSpaces

1 parente0f69f2 commitcaf78dfCopy full SHA for caf78df

File tree

-3

lines changed

-3

lines changed

Lines changed: 6 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -21,13 +21,16 @@ public static void main(String[] args) throws Exception {`
`21`	`21`	`Dataset<Row>postCode =session.read().option("header","true").csv("in/uk-postcode.csv")`
`22`	`22`	`.withColumn("PostCode",concat_ws("",col("PostCode"),lit(" ")));`
`23`	`23`
`24`		`-postCode.show();`
	`24`	`+System.out.println("=== Print 20 records of market space table ===");`
`25`	`25`	`marketSpace.show();`
`26`	`26`
`27`		`-Dataset<Row>joined =marketSpace.join(postCode,marketSpace.col("Postcode").startsWith(postCode.col("Postcode")));`
	`27`	`+System.out.println("=== Print 20 records of postcode table ===");`
	`28`	`+postCode.show();`
`28`	`29`
`29`		`-joined.show();`
	`30`	`+Dataset<Row>joined =marketSpace.join(postCode,`
	`31`	`+marketSpace.col("Postcode").startsWith(postCode.col("Postcode")),"left_outer");`
`30`	`32`
	`33`	`+System.out.println("=== Group by Region ===");`
`31`	`34`	`joined.groupBy("Region").count().show(200);`
`32`	`35`	`}`
`33`	`36`	`}`

Comments

(0)