org.apache.beam.sdk.io.jdbc

Class JdbcUtil

java.lang.Object

org.apache.beam.sdk.io.jdbc.JdbcUtil

public class JdbcUtil
extends java.lang.Object

Provides utility functions for working with JdbcIO.

Constructor Summary

Constructors

Constructor and Description
JdbcUtil()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	generateStatement(java.lang.String tableName, java.util.List<Schema.Field> fields) Generates an insert statement based on .
static org.apache.beam.sdk.io.jdbc.JdbcIO.PreparedStatementSetCaller	getPreparedStatementSetCaller(Schema.FieldType fieldType) PreparedStatementSetCaller for Schema Field Logical types.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcUtil

public JdbcUtil()

Method Detail

generateStatement

public static java.lang.String generateStatement(java.lang.String tableName,
                                                 java.util.List<Schema.Field> fields)

Generates an insert statement based on . *

getPreparedStatementSetCaller

public static org.apache.beam.sdk.io.jdbc.JdbcIO.PreparedStatementSetCaller getPreparedStatementSetCaller(Schema.FieldType fieldType)

PreparedStatementSetCaller for Schema Field Logical types. *