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

Class SingleStoreSchemaTransformReadConfiguration

java.lang.Object

org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformReadConfiguration

@DefaultSchema(org.apache.beam.sdk.schemas.AutoValueSchema.class)
public abstract class SingleStoreSchemaTransformReadConfiguration
extends java.lang.Object

Configuration for reading from SingleStoreDB.

This class is meant to be used with SingleStoreSchemaTransformReadProvider.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SingleStoreSchemaTransformReadConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
SingleStoreSchemaTransformReadConfiguration()

Method Summary

Modifier and Type	Method	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()
org.apache.beam.sdk.values.Row	toBeamRow()	Serializes configuration to a Row.

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleStoreSchemaTransformReadConfiguration

public SingleStoreSchemaTransformReadConfiguration()

Method Detail

builder

public static SingleStoreSchemaTransformReadConfiguration.Builder builder()

Instantiates a SingleStoreSchemaTransformReadConfiguration.Builder.

toBeamRow

public org.apache.beam.sdk.values.Row toBeamRow()

Serializes configuration to a Row.

getDataSourceConfiguration

@Nullable
public abstract SingleStoreIO.DataSourceConfiguration getDataSourceConfiguration()

getQuery

@Nullable
public abstract java.lang.String getQuery()

getTable

@Nullable
public abstract java.lang.String getTable()

getOutputParallelization

@Nullable
public abstract java.lang.Boolean getOutputParallelization()

getWithPartitions

@Nullable
public abstract java.lang.Boolean getWithPartitions()