public class JdbcUtil
extends java.lang.Object
JdbcIO
.Constructor and Description |
---|
JdbcUtil() |
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.
|
public static java.lang.String generateStatement(java.lang.String tableName, java.util.List<Schema.Field> fields)
public static org.apache.beam.sdk.io.jdbc.JdbcIO.PreparedStatementSetCaller getPreparedStatementSetCaller(Schema.FieldType fieldType)