Package | Description |
---|---|
org.apache.flink.connector.jdbc.dialect | |
org.apache.flink.table.types.inference |
Modifier and Type | Method and Description |
---|---|
void |
AbstractDialect.validate(RowType rowType) |
void |
JdbcDialect.validate(RowType rowType)
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 exception 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–2023 The Apache Software Foundation. All rights reserved.