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

Class WriteToPostgresSchemaTransformProvider.PostgresWriteSchemaTransform

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.WriteToPostgresSchemaTransformProvider.PostgresWriteSchemaTransform

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

WriteToPostgresSchemaTransformProvider

public static class WriteToPostgresSchemaTransformProvider.PostgresWriteSchemaTransform
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
PostgresWriteSchemaTransform(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

PostgresWriteSchemaTransform

public PostgresWriteSchemaTransform(JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration config)