jdbc

Documentation

Index

• func ReadPipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline
• func WritePipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline
• type JdbcTestRow

Functions

func ReadPipeline

func ReadPipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline

ReadPipeline creates a pipeline for JDBC IO Read transform.

func WritePipeline

func WritePipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline

WritePipeline creates a pipeline for JDBC IO Write transform.

Types

type JdbcTestRow

type JdbcTestRow struct {
	Role_id int32 `beam:"role_id"`
}

JdbcTestRow is the sample schema for read and write transform test.