Packages

class DefaultSource extends RelationProvider with SchemaRelationProvider with CreatableRelationProvider with StreamSinkProvider with StreamSourceProvider with DataSourceRegister

The default couchbase source for Spark SQL.

Linear Supertypes
DataSourceRegister, StreamSourceProvider, StreamSinkProvider, CreatableRelationProvider, SchemaRelationProvider, RelationProvider, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DefaultSource
  2. DataSourceRegister
  3. StreamSourceProvider
  4. StreamSinkProvider
  5. CreatableRelationProvider
  6. SchemaRelationProvider
  7. RelationProvider
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DefaultSource()

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. def createRelation(sqlContext: SQLContext, mode: SaveMode, parameters: Map[String, String], data: DataFrame): BaseRelation

    Creates a N1QLRelation based on the input data and saves it to couchbase.

    Creates a N1QLRelation based on the input data and saves it to couchbase.

    sqlContext

    the parent sql context.

    mode

    the save mode.

    parameters

    custom parameters that are applied.

    data

    the input data frame to store.

    Definition Classes
    DefaultSource → CreatableRelationProvider
  7. def createRelation(sqlContext: SQLContext, parameters: Map[String, String], schema: StructType): BaseRelation

    Creates a new N1QLRelation with a custom schema provided.

    Creates a new N1QLRelation with a custom schema provided.

    sqlContext

    the parent sql context.

    parameters

    custom parameters that are applied.

    schema

    the custom schema provided by the caller.

    Definition Classes
    DefaultSource → SchemaRelationProvider
  8. def createRelation(sqlContext: SQLContext, parameters: Map[String, String]): BaseRelation

    Creates a new N1QLRelation with automatic schema inference.

    Creates a new N1QLRelation with automatic schema inference.

    sqlContext

    the parent sql context.

    parameters

    custom parameters that are applied.

    Definition Classes
    DefaultSource → RelationProvider
  9. def createSink(sqlContext: SQLContext, parameters: Map[String, String], partitionColumns: Seq[String], outputMode: OutputMode): Sink
    Definition Classes
    DefaultSource → StreamSinkProvider
  10. def createSource(sqlContext: SQLContext, metadataPath: String, schema: Option[StructType], providerName: String, parameters: Map[String, String]): Source
    Definition Classes
    DefaultSource → StreamSourceProvider
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. def shortName(): String
    Definition Classes
    DefaultSource → DataSourceRegister
  21. def sourceSchema(sqlContext: SQLContext, schema: Option[StructType], providerName: String, parameters: Map[String, String]): (String, StructType)
    Definition Classes
    DefaultSource → StreamSourceProvider
  22. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from DataSourceRegister

Inherited from StreamSourceProvider

Inherited from StreamSinkProvider

Inherited from CreatableRelationProvider

Inherited from SchemaRelationProvider

Inherited from RelationProvider

Inherited from AnyRef

Inherited from Any

Ungrouped