Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add jsc stop
  • Loading branch information
yinxusen committed Nov 27, 2015
commit dd1d2c12d5d7e65332c955bd63127a8b59f74502
Original file line number Diff line number Diff line change
Expand Up @@ -63,5 +63,6 @@ public static void main(String[] args) {
System.out.println(binarized_value);
}
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,7 @@ public static void main(String[] args) {
// Transform original data into its bucket index.
DataFrame bucketedData = bucketizer.transform(dataFrame);
// $example off$
jsc.stop();
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ public static void main(String[] args) {
DataFrame dctDf = dct.transform(df);
dctDf.select("featuresDCT").show(3);
// $example off$
jsc.stop();
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -69,5 +69,6 @@ public static void main(String[] args) {
// Batch transform the vectors to create new column:
transformer.transform(dataFrame).show();
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -66,5 +66,6 @@ public static void main(String[] args) {
System.out.println();
}
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -47,5 +47,6 @@ public static void main(String[] args) {
DataFrame lInfNormData =
normalizer.transform(dataFrame, normalizer.p().w(Double.POSITIVE_INFINITY));
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@ public static void main(String[] args) {
.setOutputCol("categoryVec");
DataFrame encoded = encoder.transform(indexed);
// $example off$
jsc.stop();
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ public static void main(String[] args) {
DataFrame result = pca.transform(df).select("pcaFeatures");
result.show();
// $example off$
jsc.stop();
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -66,5 +66,6 @@ public static void main(String[] args) {
System.out.println(r.get(0));
}
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,7 @@ public static void main(String[] args) {
DataFrame output = formula.fit(dataset).transform(dataset);
output.select("features", "label").show();
// $example off$
jsc.stop();
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -48,5 +48,6 @@ public static void main(String[] args) {
// Normalize each feature to have unit standard deviation.
DataFrame scaledData = scalerModel.transform(dataFrame);
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -60,5 +60,6 @@ public static void main(String[] args) {
DataFrame dataset = jsql.createDataFrame(rdd, schema);
remover.transform(dataset).show();
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -61,5 +61,6 @@ public static void main(String[] args) {
DataFrame indexed = indexer.fit(df).transform(df);
indexed.show();
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -70,5 +70,6 @@ public static void main(String[] args) {
.setOutputCol("words")
.setPattern("\\W"); // alternatively .setPattern("\\w+").setGaps(false);
// example off
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,7 @@ public static void main(String[] args) {
DataFrame output = assembler.transform(dataset);
System.out.println(output.select("features", "clicked").first());
// $example off$
jsc.stop();
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -54,5 +54,6 @@ public static void main(String[] args) {
// Create new column "indexed" with categorical values transformed to indices
DataFrame indexedData = indexerModel.transform(data);
// $example off$
jsc.stop();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,7 @@ public static void main(String[] args) {

System.out.println(output.select("userFeatures", "features").first());
// $example off$
jsc.stop();
}
}