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

Class ReadFromPostgresSchemaTransformProvider.PostgresReadSchemaTransform

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.ReadFromPostgresSchemaTransformProvider.PostgresReadSchemaTransform

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

ReadFromPostgresSchemaTransformProvider

public static class ReadFromPostgresSchemaTransformProvider.PostgresReadSchemaTransform
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
PostgresReadSchemaTransform(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

PostgresReadSchemaTransform

public PostgresReadSchemaTransform(JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration config)