| Package | Description |
|---|---|
| com.basho.riak.spark.japi | |
| com.basho.riak.spark.japi.rdd |
| Modifier and Type | Method and Description |
|---|---|
<T> RiakTSJavaRDD<T> |
SparkContextJavaFunctions.riakTSTable(String bucketName,
Class<T> targetClass) |
<T> RiakTSJavaRDD<T> |
SparkContextJavaFunctions.riakTSTable(String bucketName,
org.apache.spark.sql.types.StructType schema,
Class<T> targetClass) |
| Modifier and Type | Method and Description |
|---|---|
RiakTSJavaRDD<T> |
RiakTSJavaRDD.sql(String queryString) |
Copyright © 2016. All rights reserved.