jdbc

package
Version: v2.39.0-RC1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 13, 2022 License: Apache-2.0, BSD-3-Clause, MIT Imports: 4 Imported by: 0

Documentation

Overview

Package jdbc contains integration tests for cross-language JDBC IO transforms.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadFromPostgres added in v2.38.0

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

ReadFromPostgres creates a pipeline for JDBC IO Read transform.

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.

func WriteToPostgres added in v2.38.0

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

WriteToPostgres 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.

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL