Package org.apache.beam.sdk.io.jdbc.providers

Class WriteToMySqlSchemaTransformProvider.MySqlWriteSchemaTransform

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollectionRowTuple,PCollectionRowTuple>

org.apache.beam.sdk.schemas.transforms.SchemaTransform

org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransform

org.apache.beam.sdk.io.jdbc.providers.WriteToMySqlSchemaTransformProvider.MySqlWriteSchemaTransform

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

WriteToMySqlSchemaTransformProvider

public static class WriteToMySqlSchemaTransformProvider.MySqlWriteSchemaTransform
extends JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransform

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
MySqlWriteSchemaTransform(JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration config)

Method Summary

Methods inherited from class org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransform

dataSourceConfiguration, expand, getConfigurationRow, writeStatement

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Constructor Details

MySqlWriteSchemaTransform

public MySqlWriteSchemaTransform(JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration config)