Package

org.apache.spark.sql.streaming

jdbc

Permalink

package jdbc

Visibility
  1. Public
  2. All

Type Members

  1. case class JDBCSource(sqlContext: SQLContext, parameters: Map[String, String], spec: SourceSpec) extends Source with Logging with Product with Serializable

    Permalink
  2. class JDBCStreamBuilder extends AnyRef

    Permalink
  3. class JdbcStreamProvider extends StreamSourceProvider with DataSourceRegister

    Permalink
  4. case class LSN(json: String) extends Offset with Product with Serializable

    Permalink
  5. case class SnappyStoreSink(snappySession: SnappySession, parameters: Map[String, String], sink: SnappyStreamSink) extends Sink with Product with Serializable

    Permalink
  6. class SnappyStoreSinkProvider extends StreamSinkProvider with DataSourceRegister

    Permalink
  7. trait SnappyStreamSink extends AnyRef

    Permalink
  8. trait SourceSpec extends AnyRef

    Permalink
  9. class SqlServerSpec extends SourceSpec

    Permalink

Value Members

  1. object StreamConf

    Permalink

Ungrouped