[S2GRAPH-237] Refactor unused variable on AnnoyIndexBuildSink class

• Type: Bug
• Status: To Do
• Priority: Minor
• Resolution: Unresolved
• Assignee: Hwansung Yu
• Reporter: Hwansung Yu
• Created: 29/Aug/18 01:03
• Updated: 03/Sep/18 09:35

Description

val df = repartition(preprocess(inputDF), inputDF.sparkSession.sparkContext.defaultParallelism)

if (inputDF.isStreaming) throw new IllegalStateException("AnnoyIndexBuildSink can not be run as streaming.")
else {
      ALSModelProcess.buildAnnoyIndex(conf, inputDF)
}

In "write" method of AnnoyIndexBuildSink class, variable "df" is never used.
So, repartition does not working .
I think that second parameter of buildAnnoyIndex shoule be "df", not "inputDF".