oracle.pgx.api.spark2.internal

Class Spark2Adapter

java.lang.Object

oracle.pgx.api.spark2.internal.Spark2Adapter

public final class Spark2Adapter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Spark2Adapter()

Method Summary

Modifier and Type	Method and Description
JavaSparkContext	createSparkContextFromSQLContext(SQLContext context)
SQLContext	createSqlContextFromSparkContext(JavaSparkContext context)
java.lang.Integer	defaultParallelism(JavaSparkContext context)
java.lang.String	extractSparkVersion(JavaSparkContext context)
<T> <any>	parallelize(JavaSparkContext context, java.util.List<T> list, int numSlices)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Spark2Adapter

public Spark2Adapter()

Method Detail

createSparkContextFromSQLContext

public JavaSparkContext createSparkContextFromSQLContext(SQLContext context)

createSqlContextFromSparkContext

public SQLContext createSqlContextFromSparkContext(JavaSparkContext context)

defaultParallelism

public java.lang.Integer defaultParallelism(JavaSparkContext context)

extractSparkVersion

public java.lang.String extractSparkVersion(JavaSparkContext context)

parallelize

public <T> <any> parallelize(JavaSparkContext context,
                             java.util.List<T> list,
                             int numSlices)