@DefaultSchema(value=AutoValueSchema.class) public abstract class SingleStoreSchemaTransformReadConfiguration extends java.lang.Object
This class is meant to be used with SingleStoreSchemaTransformReadProvider
.
Modifier and Type | Class and Description |
---|---|
static class |
SingleStoreSchemaTransformReadConfiguration.Builder |
Constructor and Description |
---|
SingleStoreSchemaTransformReadConfiguration() |
Modifier and Type | Method and Description |
---|---|
static SingleStoreSchemaTransformReadConfiguration.Builder |
builder()
Instantiates a
SingleStoreSchemaTransformReadConfiguration.Builder . |
abstract SingleStoreIO.DataSourceConfiguration |
getDataSourceConfiguration() |
abstract java.lang.Boolean |
getOutputParallelization() |
abstract java.lang.String |
getQuery() |
abstract java.lang.String |
getTable() |
abstract java.lang.Boolean |
getWithPartitions() |
Row |
toBeamRow()
Serializes configuration to a
Row . |
public SingleStoreSchemaTransformReadConfiguration()
public static SingleStoreSchemaTransformReadConfiguration.Builder builder()
SingleStoreSchemaTransformReadConfiguration.Builder
.@Nullable public abstract SingleStoreIO.DataSourceConfiguration getDataSourceConfiguration()
@Nullable public abstract java.lang.String getQuery()
@Nullable public abstract java.lang.String getTable()
@Nullable public abstract java.lang.Boolean getOutputParallelization()
@Nullable public abstract java.lang.Boolean getWithPartitions()