vector

This package contains a series of helpers to create and manage JDBC connections to Vector, to define the equivalence of SparkSQL and Vector data types, to create tables when they do not exist (respecting input DataFrame's schema), to obtain column metadata for Vector tables, and high level methods to initiate loading to Vector tables.

Linear Supertypes

AnyRef, Any

Type Members

case class ColumnMetadata(name: String, typeName: String, nullable: Boolean, precision: Int, scale: Int, valueRanges: Option[ValueRanges] = None) extends Serializable with Product

Wrap column metadata returned by JDBC and provide functions to support converting into a StructField.
abstract class ResultSetIterator[T] extends Iterator[T]

Iterator over an ResultSet
case class VectorConnectionProperties(host: String, instance: String, database: String, user: Option[String] = None, password: Option[String] = None) extends Serializable with Product

Container for Vector connection properties.
case class VectorException(errorCode: Int, message: String, cause: Throwable = null) extends RuntimeException with Product with Serializable

Exception interacting with Vector.
class VectorJDBC extends Logging

Encapsulate functions for accessing Vector using JDBC
trait VectorOps extends AnyRef

Add vector operations to RecordRDD.

Value Members

object ErrorCodes

Error codes to return in exceptions from Vector ops
object PredicatePushdown extends Logging

Object that brings together a set of functions that are used for implementing "Predicate Pushdown": A Vector query such as "SELECT * from external_table where col = 10" should not result in the provider sending the whole table to Vector, but only those tuples that pass the "col = 10" predicate.
object ResultSetIterator
object TableSchemaGenerator
object VectorDataType
object VectorJDBC extends Logging
object VectorNet

Helper functions for communicating with Vector.
Helper functions for communicating with Vector.

Note
These functions follow the Vector network communication protocol.
object VectorOps extends VectorOps

package vector

Type Members

case class ColumnMetadata(name: String, typeName: String, nullable: Boolean, precision: Int, scale: Int, valueRanges: Option[ValueRanges] = None) extends Serializable with Product

abstract class ResultSetIterator[T] extends Iterator[T]

case class VectorConnectionProperties(host: String, instance: String, database: String, user: Option[String] = None, password: Option[String] = None) extends Serializable with Product

case class VectorException(errorCode: Int, message: String, cause: Throwable = null) extends RuntimeException with Product with Serializable

class VectorJDBC extends Logging

trait VectorOps extends AnyRef

Value Members

object ErrorCodes

object PredicatePushdown extends Logging

object ResultSetIterator

object TableSchemaGenerator

object VectorDataType

object VectorJDBC extends Logging

object VectorNet

object VectorOps extends VectorOps

Inherited from AnyRef

Inherited from Any

Ungrouped