org.apache.flink.connector.jdbc.internal.options

Class JdbcInsertOptions

java.lang.Object

org.apache.flink.connector.jdbc.internal.options.JdbcInsertOptions

All Implemented Interfaces:

Serializable

public class JdbcInsertOptions
extends Object

JDBC sink insert options.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcTypedQueryOptions.JdbcUpdateQueryOptionsBuilder<T extends JdbcTypedQueryOptions.JdbcUpdateQueryOptionsBuilder<T>>

Constructor Summary

Constructors

Constructor and Description
JdbcInsertOptions(String query, int[] typesArray)

Method Summary

Modifier and Type	Method and Description
static JdbcInsertOptions	from(String query, int firstFieldType, int... nextFieldTypes)
int[]	getFieldTypes()
String	getQuery()

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcInsertOptions

public JdbcInsertOptions(String query,
                         int[] typesArray)

Method Detail

getQuery

public String getQuery()

from

public static JdbcInsertOptions from(String query,
                                     int firstFieldType,
                                     int... nextFieldTypes)

getFieldTypes

public int[] getFieldTypes()