Package | Description |
---|---|
edu.snu.coral.compiler.frontend.spark.core.java | |
edu.snu.coral.compiler.frontend.spark.source | |
edu.snu.coral.compiler.frontend.spark.sql |
Modifier and Type | Method and Description |
---|---|
static <T> JavaRDD<T> |
JavaRDD.of(org.apache.spark.SparkContext sparkContext,
Dataset<T> dataset)
Static method to create a JavaRDD object from a Dataset.
|
Constructor and Description |
---|
SparkBoundedSourceVertex(Dataset<T> dataset)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static <U> Dataset<U> |
Dataset.from(org.apache.spark.sql.Dataset<U> dataset)
Using the immutable property of datasets, we can downcast spark datasets to our class using this function.
|
Dataset<String> |
DataFrameReader.textFile(String path) |
Copyright © 2018. All rights reserved.