Package org.apache.beam.sdk.io.singlestore

Class SingleStoreIO.DataSourceConfiguration

java.lang.Object

org.apache.beam.sdk.io.singlestore.SingleStoreIO.DataSourceConfiguration

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

SingleStoreIO

@DefaultSchema(org.apache.beam.sdk.schemas.AutoValueSchema.class)
public abstract static class SingleStoreIO.DataSourceConfiguration
extends java.lang.Object
implements java.io.Serializable

A POJO describing a SingleStoreDB DataSource by providing all properties needed to create it.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DataSourceConfiguration()

Method Summary

Modifier and Type	Method	Description
static SingleStoreIO.DataSourceConfiguration	create(java.lang.String endpoint)
javax.sql.DataSource	getDataSource()
static void	populateDisplayData(@Nullable SingleStoreIO.DataSourceConfiguration dataSourceConfiguration, org.apache.beam.sdk.transforms.display.DisplayData.Builder builder)
SingleStoreIO.DataSourceConfiguration	withConnectionProperties(java.lang.String connectionProperties)	Sets the connection properties passed to driver.connect(...).
SingleStoreIO.DataSourceConfiguration	withDatabase(java.lang.String database)
SingleStoreIO.DataSourceConfiguration	withPassword(java.lang.String password)
SingleStoreIO.DataSourceConfiguration	withUsername(java.lang.String username)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataSourceConfiguration

public DataSourceConfiguration()

Method Detail

create

public static SingleStoreIO.DataSourceConfiguration create(java.lang.String endpoint)

withUsername

public SingleStoreIO.DataSourceConfiguration withUsername(java.lang.String username)

withPassword

public SingleStoreIO.DataSourceConfiguration withPassword(java.lang.String password)

withDatabase

public SingleStoreIO.DataSourceConfiguration withDatabase(java.lang.String database)

withConnectionProperties

public SingleStoreIO.DataSourceConfiguration withConnectionProperties(java.lang.String connectionProperties)

Sets the connection properties passed to driver.connect(...). Format of the string must be [propertyName=property;]*

NOTE - The "user" and "password" properties can be add via withUsername(String), withPassword(String), so they do not need to be included here.

Full list of supported properties can be found here ...

populateDisplayData

public static void populateDisplayData(@Nullable SingleStoreIO.DataSourceConfiguration dataSourceConfiguration,
                                       org.apache.beam.sdk.transforms.display.DisplayData.Builder builder)

getDataSource

public javax.sql.DataSource getDataSource()