Packages

package jdbc

Main package for JDBC APIs. Import all.

import com.spotify.scio.jdbc._
Source
package.scala
Linear Supertypes
AllSyntax, SCollectionSyntax, ScioContextSyntax, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. jdbc
  2. AllSyntax
  3. SCollectionSyntax
  4. ScioContextSyntax
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Package Members

  1. package sharded
  2. package syntax

Type Members

  1. trait CloudSqlOptions extends PipelineOptions
  2. class CloudSqlOptionsRegistrar extends PipelineOptionsRegistrar
    Annotations
    @AutoService()
  3. final case class JdbcConnectionOptions(username: String, password: Option[String], connectionUrl: String, driverClass: Class[_ <: Driver]) extends Product with Serializable

    Options for a JDBC connection.

    Options for a JDBC connection.

    username

    database login username

    password

    database login password if exists

    connectionUrl

    connection url, i.e "jdbc:mysql://[host]:[port]/db?"

    driverClass

    subclass of java.sql.Driver

  4. abstract class JdbcDoFn[A, B] extends DoFn[A, B]

    A DoFn that performs synchronous lookup using JDBC connection.

  5. sealed trait JdbcIO[T] extends ScioIO[T]
  6. final case class JdbcSelect[T](opts: JdbcConnectionOptions, query: String)(implicit evidence$1: Coder[T]) extends JdbcIO[T] with Product with Serializable
  7. final case class JdbcWrite[T](opts: JdbcConnectionOptions, statement: String) extends JdbcIO[T] with Product with Serializable

Value Members

  1. implicit def jdbcSCollectionOps[T](sc: SCollection[T]): JdbcSCollectionOps[T]
    Definition Classes
    SCollectionSyntax
  2. implicit def jdbcScioContextOps(sc: ScioContext): JdbcScioContextOps
    Definition Classes
    ScioContextSyntax
  3. object JdbcIO

Inherited from AllSyntax

Inherited from SCollectionSyntax

Inherited from ScioContextSyntax

Inherited from AnyRef

Inherited from Any

Ungrouped