A B C D E F G H I J L M N O P R S U W 
All Classes All Packages

A

absolute(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
acceptsURL(String) - Static method in class org.apache.flink.table.jdbc.DriverUri
 
acceptsURL(String) - Method in class org.apache.flink.table.jdbc.FlinkDriver
 
addBatch(String) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
afterLast() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
allProceduresAreCallable() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
allTablesAreSelectable() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
ArrayFieldGetter - Interface in org.apache.flink.table.jdbc.utils
Creates an accessor for getting elements in an array data structure at the given position.
autoCommitFailureClosesAllResultSets() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 

B

BaseDatabaseMetaData - Class in org.apache.flink.table.jdbc
Base DatabaseMetaData for flink driver with not supported features.
BaseDatabaseMetaData() - Constructor for class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
BaseResultSet - Class in org.apache.flink.table.jdbc
Base result set for jdbc driver with not supported features.
BaseResultSet() - Constructor for class org.apache.flink.table.jdbc.BaseResultSet
 
BaseStatement - Class in org.apache.flink.table.jdbc
Base statement in flink driver.
BaseStatement() - Constructor for class org.apache.flink.table.jdbc.BaseStatement
 
beforeFirst() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 

C

cancel() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
cancelRowUpdates() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
checkArgument(boolean, Object) - Static method in class org.apache.flink.table.jdbc.utils.DriverUtils
Checks the given boolean condition, and throws an IllegalArgumentException if the condition is not met (evaluates to false).
checkNotNull(T, String) - Static method in class org.apache.flink.table.jdbc.utils.DriverUtils
Ensures that the given object reference is not null.
clearBatch() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
clearWarnings() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
clearWarnings() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
close() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
close() - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
close() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
close() - Method in class org.apache.flink.table.jdbc.utils.CollectionResultIterator
 
close() - Method in class org.apache.flink.table.jdbc.utils.StatementResultIterator
 
CloseableResultIterator<T> - Interface in org.apache.flink.table.jdbc.utils
Closeable result iterator for jdbc driver.
closeOnCompletion() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
CollectionResultIterator - Class in org.apache.flink.table.jdbc.utils
Result iterator from given iterator.
CollectionResultIterator(Iterator<RowData>) - Constructor for class org.apache.flink.table.jdbc.utils.CollectionResultIterator
 
ColumnInfo - Class in org.apache.flink.table.jdbc
Column info for ResultSetMetaData, it is converted from LogicalType.
columnTypeName() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
connect(String, Properties) - Method in class org.apache.flink.table.jdbc.FlinkDriver
 
create(String, Properties) - Static method in class org.apache.flink.table.jdbc.DriverUri
 
createCatalogsResultSet(Statement, StatementResult) - Static method in class org.apache.flink.table.jdbc.utils.DatabaseMetaDataUtils
Create result set for catalogs.
createFieldGetter(LogicalType) - Static method in interface org.apache.flink.table.jdbc.utils.ArrayFieldGetter
 
createSchemasResultSet(Statement, List<String>, Map<String, List<String>>) - Static method in class org.apache.flink.table.jdbc.utils.DatabaseMetaDataUtils
Create result set for schemas.
createStatement() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 

D

DatabaseMetaDataUtils - Class in org.apache.flink.table.jdbc.utils
Utils to create catalog/schema results for FlinkDatabaseMetaData.
DatabaseMetaDataUtils() - Constructor for class org.apache.flink.table.jdbc.utils.DatabaseMetaDataUtils
 
dataDefinitionCausesTransactionCommit() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
dataDefinitionIgnoredInTransactions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
deleteRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
deletesAreDetected(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
doesMaxRowSizeIncludeBlobs() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
DriverUri - Class in org.apache.flink.table.jdbc
Parse catalog, table and connection properties from uri for FlinkDriver.
DriverUtils - Class in org.apache.flink.table.jdbc.utils
Utils methods are copied from flink-core for flink jdbc driver to avoid excessive dependency.
DriverUtils() - Constructor for class org.apache.flink.table.jdbc.utils.DriverUtils
 

E

execute(String) - Method in class org.apache.flink.table.jdbc.FlinkStatement
Execute a sql statement.
execute(String, int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
execute(String, int[]) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
execute(String, String[]) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
executeBatch() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
executeQuery(String) - Method in class org.apache.flink.table.jdbc.FlinkStatement
Execute a SELECT query.
executeUpdate(String) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
executeUpdate(String, int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
executeUpdate(String, int[]) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
executeUpdate(String, String[]) - Method in class org.apache.flink.table.jdbc.BaseStatement
 

F

findColumn(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
first() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
FlinkConnection - Class in org.apache.flink.table.jdbc
Connection to flink sql gateway for jdbc driver.
FlinkConnection(DriverUri) - Constructor for class org.apache.flink.table.jdbc.FlinkConnection
 
FlinkDatabaseMetaData - Class in org.apache.flink.table.jdbc
Implementation of DatabaseMetaData for flink jdbc driver.
FlinkDatabaseMetaData(String, FlinkConnection, Statement) - Constructor for class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
FlinkDataSource - Class in org.apache.flink.table.jdbc
Basic flink data source which create FlinkConnection.
FlinkDataSource(String, Properties) - Constructor for class org.apache.flink.table.jdbc.FlinkDataSource
 
FlinkDriver - Class in org.apache.flink.table.jdbc
Jdbc Driver for flink sql gateway.
FlinkDriver() - Constructor for class org.apache.flink.table.jdbc.FlinkDriver
 
FlinkResultSet - Class in org.apache.flink.table.jdbc
ResultSet for flink jdbc driver.
FlinkResultSet(Statement, StatementResult) - Constructor for class org.apache.flink.table.jdbc.FlinkResultSet
 
FlinkResultSet(Statement, CloseableResultIterator<RowData>, ResolvedSchema) - Constructor for class org.apache.flink.table.jdbc.FlinkResultSet
 
FlinkResultSetMetaData - Class in org.apache.flink.table.jdbc
Implementation of ResultSetMetaData for flink jdbc driver.
FlinkResultSetMetaData(List<String>, List<DataType>) - Constructor for class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
FlinkStatement - Class in org.apache.flink.table.jdbc
Statement for flink jdbc driver.
FlinkStatement(FlinkConnection) - Constructor for class org.apache.flink.table.jdbc.FlinkStatement
 
fromLogicalType(String, LogicalType) - Static method in class org.apache.flink.table.jdbc.ColumnInfo
Build column info from given logical type.
fromProperties(Properties) - Static method in class org.apache.flink.table.jdbc.utils.DriverUtils
Generate map from given properties.

G

generatedKeyAlwaysReturned() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getAddress() - Method in class org.apache.flink.table.jdbc.DriverUri
 
getArray(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getArray(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getAsciiStream(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getAsciiStream(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getAttributes(String, String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getAutoCommit() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getBestRowIdentifier(String, String, String, int, boolean) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getBigDecimal(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBigDecimal(int, int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBigDecimal(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBigDecimal(String, int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBinaryStream(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getBinaryStream(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getBlob(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getBlob(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getBoolean(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBoolean(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getByte(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getByte(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBytes(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getBytes(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getCatalog() - Method in class org.apache.flink.table.jdbc.DriverUri
 
getCatalog() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getCatalogName(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getCatalogs() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getCatalogSeparator() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getCatalogTerm() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getCharacterStream(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getCharacterStream(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getClientInfo() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getClientInfo(String) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getClientInfoProperties() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getClob(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getClob(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getColumnClassName(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getColumnCount() - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getColumnDisplaySize() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
getColumnDisplaySize(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getColumnLabel(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getColumnName() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
getColumnName(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getColumnPrivileges(String, String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getColumns(String, String, String, String) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getColumnType() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
getColumnType(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getColumnTypeName(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getConcurrency() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getConnection() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getConnection() - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
getConnection() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
getConnection(String, String) - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
getCrossReference(String, String, String, String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getCursorName() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getDatabase() - Method in class org.apache.flink.table.jdbc.DriverUri
 
getDatabaseMajorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDatabaseMinorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDatabaseProductName() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDatabaseProductVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDate(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getDate(int, Calendar) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getDate(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getDate(String, Calendar) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getDefaultTransactionIsolation() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getDouble(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getDouble(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getDriverMajorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDriverMinorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDriverName() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getDriverVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getExportedKeys(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getExtraNameCharacters() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getFetchDirection() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getFetchDirection() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getFetchSize() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getFetchSize() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getFloat(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getFloat(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getFunctionColumns(String, String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getFunctions(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getGeneratedKeys() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getHoldability() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getIdentifierQuoteString() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getImportedKeys(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getIndexInfo(String, String, String, boolean, boolean) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getInt(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getInt(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getJDBCMajorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getJDBCMinorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getLoginTimeout() - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
getLogWriter() - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
getLong(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getLong(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getMajorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDriver
Major version of flink.
getMaxBinaryLiteralLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxCatalogNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxCharLiteralLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxColumnNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxColumnsInGroupBy() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxColumnsInIndex() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxColumnsInOrderBy() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxColumnsInSelect() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxColumnsInTable() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxConnections() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxCursorNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxFieldSize() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getMaxIndexLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxProcedureNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxRows() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getMaxRowSize() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxSchemaNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxStatementLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxStatements() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxTableNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxTablesInSelect() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMaxUserNameLength() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getMetaData() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getMetaData() - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getMinorVersion() - Method in class org.apache.flink.table.jdbc.FlinkDriver
Minor version of flink.
getMoreResults() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
getMoreResults(int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getNCharacterStream(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getNCharacterStream(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getNClob(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getNClob(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getNString(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getNString(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getNumericFunctions() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getObject(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getObject(int, Class<T>) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getObject(int, Map<String, Class<?>>) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getObject(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getObject(String, Class<T>) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getObject(String, Map<String, Class<?>>) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getObjectOrNull(ArrayData, int) - Method in interface org.apache.flink.table.jdbc.utils.ArrayFieldGetter
 
getParentLogger() - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
getParentLogger() - Method in class org.apache.flink.table.jdbc.FlinkDriver
 
getPrecision() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
getPrecision(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getPrimaryKeys(String, String, String) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getProcedureColumns(String, String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getProcedures(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getProcedureTerm() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getProperties() - Method in class org.apache.flink.table.jdbc.DriverUri
 
getPropertyInfo(String, Properties) - Method in class org.apache.flink.table.jdbc.FlinkDriver
 
getPseudoColumns(String, String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getQueryTimeout() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getRef(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getRef(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getResultSet() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
getResultSetConcurrency() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getResultSetHoldability() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getResultSetHoldability() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getResultSetType() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
getRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getRowId(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getRowId(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getRowIdLifetime() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getScale() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
getScale(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getSchema() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getSchemaName(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getSchemas() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getSchemas(String, String) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getSchemaTerm() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getSearchStringEscape() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getShort(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getShort(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getSQLKeywords() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getSQLStateType() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getSQLXML(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getSQLXML(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getStatement() - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getString(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getString(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getStringFunctions() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getSuperTables(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getSuperTypes(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getSystemFunctions() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getTableName(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
getTablePrivileges(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getTables(String, String, String, String[]) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getTableTypes() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getTime(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTime(int, Calendar) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTime(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTime(String, Calendar) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTimeDateFunctions() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getTimestamp(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTimestamp(int, Calendar) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTimestamp(String) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTimestamp(String, Calendar) - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
getTransactionIsolation() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getType() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getTypeInfo() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getUDTs(String, String, String, int[]) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getUnicodeStream(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getUnicodeStream(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getUpdateCount() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
getURL() - Method in class org.apache.flink.table.jdbc.DriverUri
 
getURL() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
getURL(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getURL(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getUserName() - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getVersionColumns(String, String, String) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
getWarnings() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
getWarnings() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
getWarnings() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 

H

hasNext() - Method in class org.apache.flink.table.jdbc.utils.CollectionResultIterator
 
hasNext() - Method in class org.apache.flink.table.jdbc.utils.StatementResultIterator
 

I

insertRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
insertsAreDetected(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
isAfterLast() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
isAutoIncrement(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isBeforeFirst() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
isCaseSensitive(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isCatalogAtStart() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
Catalog name appears at the start of full name.
isClosed() - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
isClosed() - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
isClosed() - Method in class org.apache.flink.table.jdbc.FlinkStatement
 
isCloseOnCompletion() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
isCurrency(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isDefinitelyWritable(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isFirst() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
isLast() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
isNullable() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
isNullable(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isNullOrWhitespaceOnly(String) - Static method in class org.apache.flink.table.jdbc.utils.DriverUtils
Checks if the string is null, empty, or contains only whitespace characters.
isPoolable() - Method in class org.apache.flink.table.jdbc.BaseStatement
 
isReadOnly() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
isReadOnly(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isSearchable(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isSigned() - Method in class org.apache.flink.table.jdbc.ColumnInfo
 
isSigned(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isWrapperFor(Class<?>) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
isWrapperFor(Class<?>) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
isWrapperFor(Class<?>) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
isWrapperFor(Class<?>) - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
isWrapperFor(Class<?>) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
isWritable(int) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 

J

jdbcCompliant() - Method in class org.apache.flink.table.jdbc.FlinkDriver
 

L

last() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
locatorsUpdateCopy() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 

M

moveToCurrentRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
moveToInsertRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 

N

next() - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
next() - Method in class org.apache.flink.table.jdbc.utils.CollectionResultIterator
 
next() - Method in class org.apache.flink.table.jdbc.utils.StatementResultIterator
 
nullPlusNonNullIsNull() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
Null value plus non-null in flink will be null result.
nullsAreSortedAtEnd() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
nullsAreSortedAtStart() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
nullsAreSortedHigh() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
nullsAreSortedLow() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
In flink null value will be used as low value for sort.

O

org.apache.flink.table.jdbc - package org.apache.flink.table.jdbc
 
org.apache.flink.table.jdbc.utils - package org.apache.flink.table.jdbc.utils
 
othersDeletesAreVisible(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
othersInsertsAreVisible(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
othersUpdatesAreVisible(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
ownDeletesAreVisible(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
ownInsertsAreVisible(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
ownUpdatesAreVisible(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 

P

previous() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 

R

refreshRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
relative(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
rowDeleted() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
rowInserted() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
rowUpdated() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 

S

setAutoCommit(boolean) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
setCatalog(String) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
setClientInfo(String, String) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
setClientInfo(Properties) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
setCursorName(String) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setEscapeProcessing(boolean) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setFetchDirection(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
setFetchDirection(int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setFetchSize(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
setFetchSize(int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setLoginTimeout(int) - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
setLogWriter(PrintWriter) - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
setMaxFieldSize(int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setMaxRows(int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setPoolable(boolean) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setQueryTimeout(int) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
setSchema(String) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
setTransactionIsolation(int) - Method in class org.apache.flink.table.jdbc.FlinkConnection
 
StatementResultIterator - Class in org.apache.flink.table.jdbc.utils
Closeable result iterator for statement result.
StatementResultIterator(StatementResult) - Constructor for class org.apache.flink.table.jdbc.utils.StatementResultIterator
 
storesLowerCaseIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
storesLowerCaseQuotedIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
storesMixedCaseIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
Flink sql is mixed case as sensitive.
storesMixedCaseQuotedIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
Flink sql is mixed case as sensitive.
storesUpperCaseIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
storesUpperCaseQuotedIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsAlterTableWithAddColumn() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsAlterTableWithDropColumn() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsANSI92EntryLevelSQL() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsANSI92FullSQL() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsANSI92IntermediateSQL() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsBatchUpdates() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCatalogsInDataManipulation() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCatalogsInIndexDefinitions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCatalogsInPrivilegeDefinitions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCatalogsInProcedureCalls() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCatalogsInTableDefinitions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsColumnAliasing() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsConvert() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsConvert(int, int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCoreSQLGrammar() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsCorrelatedSubqueries() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsDataDefinitionAndDataManipulationTransactions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsDataManipulationTransactionsOnly() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsDifferentTableCorrelationNames() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsExpressionsInOrderBy() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsExtendedSQLGrammar() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsFullOuterJoins() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsGetGeneratedKeys() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsGroupBy() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsGroupByBeyondSelect() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsGroupByUnrelated() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsIntegrityEnhancementFacility() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsLikeEscapeClause() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsLimitedOuterJoins() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsMinimumSQLGrammar() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsMixedCaseIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
Flink sql is mixed case as sensitive.
supportsMixedCaseQuotedIdentifiers() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
Flink sql is mixed case as sensitive.
supportsMultipleOpenResults() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsMultipleResultSets() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsMultipleTransactions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsNamedParameters() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsNonNullableColumns() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsOpenCursorsAcrossCommit() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsOpenCursorsAcrossRollback() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsOpenStatementsAcrossCommit() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsOpenStatementsAcrossRollback() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsOrderByUnrelated() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsOuterJoins() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsPositionedDelete() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsPositionedUpdate() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsResultSetConcurrency(int, int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsResultSetHoldability(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsResultSetType(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSavepoints() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSchemasInDataManipulation() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSchemasInIndexDefinitions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSchemasInPrivilegeDefinitions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSchemasInProcedureCalls() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSchemasInTableDefinitions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSelectForUpdate() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsStatementPooling() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsStoredFunctionsUsingCallSyntax() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsStoredProcedures() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSubqueriesInComparisons() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSubqueriesInExists() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSubqueriesInIns() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsSubqueriesInQuantifieds() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsTableCorrelationNames() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsTransactionIsolationLevel(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsTransactions() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsUnion() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
supportsUnionAll() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 

U

unwrap(Class<T>) - Method in class org.apache.flink.table.jdbc.BaseDatabaseMetaData
 
unwrap(Class<T>) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
unwrap(Class<T>) - Method in class org.apache.flink.table.jdbc.BaseStatement
 
unwrap(Class<T>) - Method in class org.apache.flink.table.jdbc.FlinkDataSource
 
unwrap(Class<T>) - Method in class org.apache.flink.table.jdbc.FlinkResultSetMetaData
 
updateArray(int, Array) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateArray(String, Array) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateAsciiStream(int, InputStream) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateAsciiStream(int, InputStream, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateAsciiStream(int, InputStream, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateAsciiStream(String, InputStream) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateAsciiStream(String, InputStream, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateAsciiStream(String, InputStream, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBigDecimal(int, BigDecimal) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBigDecimal(String, BigDecimal) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBinaryStream(int, InputStream) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBinaryStream(int, InputStream, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBinaryStream(int, InputStream, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBinaryStream(String, InputStream) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBinaryStream(String, InputStream, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBinaryStream(String, InputStream, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBlob(int, InputStream) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBlob(int, InputStream, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBlob(int, Blob) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBlob(String, InputStream) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBlob(String, InputStream, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBlob(String, Blob) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBoolean(int, boolean) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBoolean(String, boolean) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateByte(int, byte) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateByte(String, byte) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBytes(int, byte[]) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateBytes(String, byte[]) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateCharacterStream(int, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateCharacterStream(int, Reader, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateCharacterStream(int, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateCharacterStream(String, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateCharacterStream(String, Reader, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateCharacterStream(String, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateClob(int, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateClob(int, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateClob(int, Clob) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateClob(String, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateClob(String, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateClob(String, Clob) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateDate(int, Date) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateDate(String, Date) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateDouble(int, double) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateDouble(String, double) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateFloat(int, float) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateFloat(String, float) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateInt(int, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateInt(String, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateLong(int, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateLong(String, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNCharacterStream(int, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNCharacterStream(int, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNCharacterStream(String, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNCharacterStream(String, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNClob(int, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNClob(int, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNClob(int, NClob) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNClob(String, Reader) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNClob(String, Reader, long) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNClob(String, NClob) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNString(int, String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNString(String, String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNull(int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateNull(String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateObject(int, Object) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateObject(int, Object, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateObject(String, Object) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateObject(String, Object, int) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateRef(int, Ref) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateRef(String, Ref) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateRow() - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateRowId(int, RowId) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateRowId(String, RowId) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updatesAreDetected(int) - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
updateShort(int, short) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateShort(String, short) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateSQLXML(int, SQLXML) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateSQLXML(String, SQLXML) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateString(int, String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateString(String, String) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateTime(int, Time) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateTime(String, Time) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateTimestamp(int, Timestamp) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
updateTimestamp(String, Timestamp) - Method in class org.apache.flink.table.jdbc.BaseResultSet
 
usesLocalFilePerTable() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 
usesLocalFiles() - Method in class org.apache.flink.table.jdbc.FlinkDatabaseMetaData
 

W

wasNull() - Method in class org.apache.flink.table.jdbc.FlinkResultSet
 
A B C D E F G H I J L M N O P R S U W 
All Classes All Packages