oracle.pgx.api.spark2.internal

Class Spark2RddAdapter<T>

java.lang.Object

oracle.pgx.api.spark2.internal.Spark2RddAdapter<T>

public final class Spark2RddAdapter<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Spark2RddAdapter(<any> actualRdd)

Method Summary

Modifier and Type	Method and Description
<any>	cache()
long	count()
Spark2RddAdapter<T>	filter(oracle.pgx.common.util.function.SerializableFunction<T,java.lang.Boolean> p)
<RddType> RddType	get()
int	getNumPartitions()
<any>	getRdd()
<R> Spark2RddAdapter<R>	map(oracle.pgx.common.util.function.SerializableFunction<T,R> f)
<R> Spark2RddAdapter<R>	mapPartitionsWithIndex(oracle.pgx.common.util.function.SerializableBiFunction<java.lang.Integer,java.util.Iterator<T>,java.util.Iterator<R>> f, boolean preservesPartitioning)
T	reduce(oracle.pgx.common.util.function.SerializableBiFunction<T,T,T> f)

Methods inherited from class java.lang.Object

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

Constructor Detail

Spark2RddAdapter

public Spark2RddAdapter(<any> actualRdd)

Method Detail

cache

public <any> cache()

count

public long count()

filter

public Spark2RddAdapter<T> filter(oracle.pgx.common.util.function.SerializableFunction<T,java.lang.Boolean> p)

get

public <RddType> RddType get()

getNumPartitions

public int getNumPartitions()

getRdd

public <any> getRdd()

map

public <R> Spark2RddAdapter<R> map(oracle.pgx.common.util.function.SerializableFunction<T,R> f)

mapPartitionsWithIndex

public <R> Spark2RddAdapter<R> mapPartitionsWithIndex(oracle.pgx.common.util.function.SerializableBiFunction<java.lang.Integer,java.util.Iterator<T>,java.util.Iterator<R>> f,
                                                      boolean preservesPartitioning)

reduce

public T reduce(oracle.pgx.common.util.function.SerializableBiFunction<T,T,T> f)