| 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.