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

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.

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

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