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

Class SingleStoreSchemaTransformWriteConfiguration

java.lang.Object

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

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

Configuration for writing to SingleStoreDB.

This class is meant to be used with SingleStoreSchemaTransformWriteProvider.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SingleStoreSchemaTransformWriteConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
SingleStoreSchemaTransformWriteConfiguration()

Method Summary

Modifier and Type	Method	Description
static SingleStoreSchemaTransformWriteConfiguration.Builder	builder()	Instantiates a SingleStoreSchemaTransformWriteConfiguration.Builder.
abstract java.lang.Integer	getBatchSize()
abstract SingleStoreIO.DataSourceConfiguration	getDataSourceConfiguration()
abstract java.lang.String	getTable()
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

SingleStoreSchemaTransformWriteConfiguration

public SingleStoreSchemaTransformWriteConfiguration()

Method Detail

builder

public static SingleStoreSchemaTransformWriteConfiguration.Builder builder()

Instantiates a SingleStoreSchemaTransformWriteConfiguration.Builder.

toBeamRow

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

Serializes configuration to a Row.

getDataSourceConfiguration

@Nullable
public abstract SingleStoreIO.DataSourceConfiguration getDataSourceConfiguration()

getTable

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

getBatchSize

@Nullable
public abstract java.lang.Integer getBatchSize()