public class RiakTSJavaRDD<T>
extends org.apache.spark.api.java.JavaRDD<T>
| Constructor and Description |
|---|
RiakTSJavaRDD(com.basho.riak.spark.rdd.RiakTSRDD<T> rdd,
Class<T> clazz) |
RiakTSJavaRDD(com.basho.riak.spark.rdd.RiakTSRDD<T> rdd,
scala.reflect.ClassTag<T> classTag) |
| Modifier and Type | Method and Description |
|---|---|
scala.reflect.ClassTag<T> |
classTag() |
com.basho.riak.spark.rdd.RiakTSRDD<T> |
rdd() |
RiakTSJavaRDD<T> |
sql(String queryString) |
cache, coalesce, coalesce, distinct, distinct, filter, fromRDD, intersection, persist, randomSplit, randomSplit, repartition, sample, sample, setName, sortBy, subtract, subtract, subtract, toRDD, toString, union, unpersist, unpersist, wrapRDDaggregate, cartesian, checkpoint, collect, collectAsync, collectPartitions, context, count, countApprox, countApprox, countApproxDistinct, countAsync, countByValue, countByValueApprox, countByValueApprox, first, flatMap, flatMapToDouble, flatMapToPair, fold, foreach, foreachAsync, foreachPartition, foreachPartitionAsync, getCheckpointFile, getNumPartitions, getStorageLevel, glom, groupBy, groupBy, id, isCheckpointed, isEmpty, iterator, keyBy, map, mapPartitions, mapPartitions, mapPartitionsToDouble, mapPartitionsToDouble, mapPartitionsToPair, mapPartitionsToPair, mapPartitionsWithIndex, mapPartitionsWithIndex$default$2, mapToDouble, mapToPair, max, min, name, partitioner, partitions, pipe, pipe, pipe, reduce, saveAsObjectFile, saveAsTextFile, saveAsTextFile, splits, take, takeAsync, takeOrdered, takeOrdered, takeSample, takeSample, toArray, toDebugString, toLocalIterator, top, top, treeAggregate, treeAggregate, treeReduce, treeReduce, zip, zipPartitions, zipWithIndex, zipWithUniqueIdpublic com.basho.riak.spark.rdd.RiakTSRDD<T> rdd()
public scala.reflect.ClassTag<T> classTag()
public RiakTSJavaRDD<T> sql(String queryString)
Copyright © 2016. All rights reserved.