org.apache.beam.it.gcp.datastream

Class PostgresqlSource

java.lang.Object

org.apache.beam.it.gcp.datastream.JDBCSource

org.apache.beam.it.gcp.datastream.PostgresqlSource

public class PostgresqlSource
extends JDBCSource

Client for PostgreSQL resource used by Datastream.

Subclass of JDBCSource.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PostgresqlSource.Builder

Method Summary

Modifier and Type	Method and Description
static PostgresqlSource.Builder	builder(java.lang.String hostname, java.lang.String username, java.lang.String password, int port, java.util.Map<java.lang.String,java.util.List<java.lang.String>> allowedTables, java.lang.String database, java.lang.String replicationSlot, java.lang.String publication)
com.google.protobuf.MessageOrBuilder	config()
java.lang.String	database()
org.apache.beam.it.gcp.datastream.JDBCSource.SourceType	type()

Methods inherited from class org.apache.beam.it.gcp.datastream.JDBCSource

allowedTables, hostname, password, port, username

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

builder

public static PostgresqlSource.Builder builder(java.lang.String hostname,
                                               java.lang.String username,
                                               java.lang.String password,
                                               int port,
                                               java.util.Map<java.lang.String,java.util.List<java.lang.String>> allowedTables,
                                               java.lang.String database,
                                               java.lang.String replicationSlot,
                                               java.lang.String publication)

type

public org.apache.beam.it.gcp.datastream.JDBCSource.SourceType type()

Specified by:

type in class JDBCSource

config

public com.google.protobuf.MessageOrBuilder config()

Specified by:

config in class JDBCSource

database

public java.lang.String database()