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

Class ReadFromMySqlSchemaTransformProvider.MySqlReadSchemaTransform

java.lang.Object

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

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

org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProvider.JdbcReadSchemaTransform

org.apache.beam.sdk.io.jdbc.providers.ReadFromMySqlSchemaTransformProvider.MySqlReadSchemaTransform

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

ReadFromMySqlSchemaTransformProvider

public static class ReadFromMySqlSchemaTransformProvider.MySqlReadSchemaTransform
extends JdbcReadSchemaTransformProvider.JdbcReadSchemaTransform

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
MySqlReadSchemaTransform(JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration config)

Method Summary

Methods inherited from class org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProvider.JdbcReadSchemaTransform

dataSourceConfiguration, expand, getConfigurationRow

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

MySqlReadSchemaTransform

public MySqlReadSchemaTransform(JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration config)