Skip to content

Commit 8933c66

Browse files
committed
updated dir name
1 parent 683a13b commit 8933c66

File tree

3 files changed

+3
-7
lines changed

3 files changed

+3
-7
lines changed

spark/core/src/main/java/zingg/spark/core/preprocess/SparkPreprocMap.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
import zingg.common.core.preprocess.IPreprocType;
1414
import zingg.common.core.preprocess.IPreprocTypes;
1515
import zingg.common.core.preprocess.IPreprocessor;
16-
import zingg.spark.core.preprocess.caseNormalize.SparkCaseNormalizer;
16+
import zingg.spark.core.preprocess.casenormalize.SparkCaseNormalizer;
1717
import zingg.spark.core.preprocess.stopwords.SparkStopWordsRemover;
1818

1919
public class SparkPreprocMap implements IPreprocMap<SparkSession,Dataset<Row>,Row,Column,DataType> {

spark/core/src/main/java/zingg/spark/core/preprocess/caseNormalize/SparkCaseNormalizer.java spark/core/src/main/java/zingg/spark/core/preprocess/casenormalize/SparkCaseNormalizer.java

+1-5
Original file line numberDiff line numberDiff line change
@@ -1,19 +1,15 @@
1-
package zingg.spark.core.preprocess.caseNormalize;
1+
package zingg.spark.core.preprocess.casenormalize;
22

33
import org.apache.spark.sql.Column;
44
import org.apache.spark.sql.Dataset;
55
import org.apache.spark.sql.Row;
66
import org.apache.spark.sql.SparkSession;
77
import org.apache.spark.sql.types.DataType;
8-
import scala.collection.JavaConverters;
9-
import scala.collection.Seq;
108
import zingg.common.client.FieldDefinition;
119
import zingg.common.client.ZFrame;
1210
import zingg.common.core.context.IContext;
1311
import zingg.common.core.preprocess.casenormalize.CaseNormalizer;
14-
import zingg.spark.client.SparkFrame;
1512

16-
import java.util.ArrayList;
1713
import java.util.List;
1814

1915
import static org.apache.spark.sql.functions.lower;

spark/core/src/test/java/zingg/spark/core/preprocess/caseNormalize/TestSparkCaseNormalizer.java spark/core/src/test/java/zingg/spark/core/preprocess/casenormalize/TestSparkCaseNormalizer.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package zingg.spark.core.preprocess.caseNormalize;
1+
package zingg.spark.core.preprocess.casenormalize;
22

33
import org.apache.spark.sql.Column;
44
import org.apache.spark.sql.Dataset;

0 commit comments

Comments
 (0)