Packages

package query

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class PartitioningConfig(partitionColumn: String, lowerBound: Long, upperBound: Long, numPartitions: Long) extends Product with Serializable
  2. class QueryBatch extends Batch with Logging
  3. case class QueryInputPartition(schema: StructType, filters: Array[Filter], locations: Array[String], aggregations: Option[Aggregation], bound: Option[QueryPartitionBound], limit: Option[Int]) extends InputPartition with Product with Serializable
  4. class QueryPartition extends Partition
  5. case class QueryPartitionBound(lowerBoundInclusive: Long, upperBoundExclusive: Long, whereClause: String) extends Product with Serializable
  6. class QueryPartitionReader extends PartitionReader[InternalRow] with Logging
  7. class QueryPartitionReaderFactory extends PartitionReaderFactory
  8. class QueryRDD[T] extends RDD[T] with Logging
  9. case class QueryReadConfig(bucket: String, scope: Option[String], collection: Option[String], idFieldName: String, userFilter: Option[String], scanConsistency: String, timeout: Option[String], pushDownAggregate: Boolean, connectionIdentifier: Option[String], partition: Option[PartitioningConfig]) extends Product with Serializable
  10. class QueryScan extends Scan
  11. class QueryScanBuilder extends ScanBuilder with SupportsPushDownFilters with SupportsPushDownRequiredColumns with SupportsPushDownAggregates with SupportsPushDownLimit
  12. class QueryTable extends SupportsRead
  13. class QueryTableProvider extends TableProvider with Logging with DataSourceRegister with CreatableRelationProvider
  14. case class QueryWriteConfig(bucket: String, scope: Option[String], collection: Option[String], idFieldName: String, timeout: Option[String], connectionIdentifier: Option[String]) extends Product with Serializable
  15. class RelationPartitionWriter extends ForeachPartitionFunction[String] with Logging

Value Members

  1. object QueryAggregations extends Logging

    Helper object to deal with aggregations in N1QL/SQL++.

  2. object QueryFilters extends Logging
  3. object QueryOptions

    Helper object to provide type-safe keys and values for Spark SQL query options.

  4. object RelationPartitionWriter extends Serializable