org.apache.beam.it.gcp.datastream

Class MySQLSource

java.lang.Object

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

org.apache.beam.it.gcp.datastream.MySQLSource

public class MySQLSource
extends JDBCSource

Client for MySQL resource used by Datastream.

Subclass of JDBCSource.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MySQLSource.Builder

Method Summary

Modifier and Type	Method and Description
static MySQLSource.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)
com.google.cloud.datastream.v1.MysqlSourceConfig	config()
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

type

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

Specified by:

type in class JDBCSource

config

public com.google.cloud.datastream.v1.MysqlSourceConfig config()

Specified by:

config in class JDBCSource

builder

public static MySQLSource.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)