oracle.pgx.api.spark1.internal

Class Spark1Adapter

java.lang.Object

oracle.pgx.api.spark1.internal.Spark1Adapter

public final class Spark1Adapter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Spark1Adapter()

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

Spark1Adapter

public Spark1Adapter()

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)