Skip to content

Instantly share code, notes, and snippets.

@alg-jmx
alg-jmx / ExampleUsage.java
Created March 16, 2023 10:12 — forked from dmmiller612/ExampleUsage.java
Spark DL4J Dataframe/Dataset usage
import org.apache.spark.ml.feature.*;
class ExampleUsage {
public void example(){
List<Row> dubs = Lists.newArrayList(
RowFactory.create(1000.0, 1000.0, 1.0),
RowFactory.create(90.0, 90.0, 0.0)
);
DataFrame df = sqlContext.createDataFrame(dubs, createStruct());