Package | Description |
---|---|
org.apache.flink.connector.jdbc.dialect | |
org.apache.flink.table.types.inference |
Modifier and Type | Method and Description |
---|---|
default void |
JdbcDialect.validate(TableSchema schema)
Check if this dialect instance support a specific data type in table schema.
|
Modifier and Type | Method and Description |
---|---|
static ValidationException |
TypeInferenceUtil.createInvalidCallException(CallContext callContext,
ValidationException cause)
Returns an exception for an invalid call to a function.
|
static ValidationException |
TypeInferenceUtil.createInvalidInputException(TypeInference typeInference,
CallContext callContext,
ValidationException cause)
Returns an exception for invalid input arguments.
|
default ValidationException |
CallContext.newValidationError(String message,
Object... args)
Creates a validation error for exiting the type inference process with a meaningful
exception.
|
Modifier and Type | Method and Description |
---|---|
static ValidationException |
TypeInferenceUtil.createInvalidCallException(CallContext callContext,
ValidationException cause)
Returns an exception for an invalid call to a function.
|
static ValidationException |
TypeInferenceUtil.createInvalidInputException(TypeInference typeInference,
CallContext callContext,
ValidationException cause)
Returns an exception for invalid input arguments.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.