Commitebc2eb0

James Lee

committed

improve RddDatasetConversion

1 parentced25b4 commitebc2eb0Copy full SHA for ebc2eb0

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@ public static void main(String[] args) throws Exception {`
`28`	`28`	`.filter(line -> !line.split(COMMA_DELIMITER, -1)[2].equals("country"))`
`29`	`29`	`.map(line -> {`
`30`	`30`	`String[]splits =line.split(COMMA_DELIMITER, -1);`
`31`		`-returnnewResponse(splits[2],convertStringToFloat(splits[6]),splits[9],convertStringToFloat(splits[14]));`
	`31`	`+returnnewResponse(splits[2],toInt(splits[6]),splits[9],toInt(splits[14]));`
`32`	`32`	`});`
`33`	`33`	`Dataset<Response>responseDataset =session.createDataset(responseRDD.rdd(),Encoders.bean(Response.class));`
`34`	`34`
`@@ -46,7 +46,7 @@ public static void main(String[] args) throws Exception {`
`46`	`46`
`47`	`47`	`}`
`48`	`48`
`49`		`-privatestaticIntegerconvertStringToFloat(Stringsplit) {`
	`49`	`+privatestaticIntegertoInt(Stringsplit) {`
`50`	`50`	`returnsplit.isEmpty() ?null :Math.round(Float.valueOf(split));`
`51`	`51`	`}`
`52`	`52`

Comments

(0)