| Package | Description |
|---|---|
| com.cerner.bunsen.spark |
| Modifier and Type | Method and Description |
|---|---|
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> |
Bundles.fromJson(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> jsonBundles,
String column)
Returns an RDD of bundles loaded from the given dataset that has JSON-encoded
bundles in the given column.
|
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> |
Bundles.fromJson(org.apache.spark.sql.Dataset<String> jsonBundles)
Returns an RDD of bundles loaded from the given dataset of JSON-encoded
bundles.
|
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> |
Bundles.fromXml(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> xmlBundles,
String column)
Returns an RDD of bundles loaded from the given dataset that has XML-encoded
bundles in the given column.
|
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> |
Bundles.fromXml(org.apache.spark.sql.Dataset<String> xmlBundles)
Returns an RDD of bundles loaded from the given dataset of XML-encoded
bundles.
|
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> |
Bundles.loadFromDirectory(org.apache.spark.sql.SparkSession spark,
String path,
int minPartitions)
Returns an RDD of bundles loaded from the given path.
|
| Modifier and Type | Method and Description |
|---|---|
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> |
Bundles.extractEntry(org.apache.spark.sql.SparkSession spark,
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> bundles,
Class resourceClass)
Extracts the given resource type from the RDD of bundles and returns
it as a Dataset of that type.
|
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> |
Bundles.extractEntry(org.apache.spark.sql.SparkSession spark,
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> bundles,
Class resourceClass,
List<Class> containedClasses)
Extracts the given resource type from the RDD of bundles and returns
it as a Dataset of that type, including any declared resources contained
to the parent resource.
|
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> |
Bundles.extractEntry(org.apache.spark.sql.SparkSession spark,
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> bundles,
String resourceTypeUrl)
Extracts the given resource type from the RDD of bundles and returns
it as a Dataset of that type.
|
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> |
Bundles.extractEntry(org.apache.spark.sql.SparkSession spark,
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> bundles,
String resourceTypeUrl,
List<String> containedClassesUrls)
Extracts the given resource type from the RDD of bundles and returns
it as a Dataset of that type, including any declared resources contained
to the parent resource.
|
void |
Bundles.saveAsDatabase(org.apache.spark.sql.SparkSession spark,
org.apache.spark.api.java.JavaRDD<Bundles.BundleContainer> bundles,
String database,
String... resourceNames)
Saves an RDD of bundles as a database, where each table
has the resource name.
|
Copyright © 2020. All rights reserved.