public class SchemaEvolveException
extends org.apache.flink.util.FlinkRuntimeException
| 限定符和类型 | 字段和说明 |
|---|---|
protected SchemaChangeEvent |
applyingEvent |
protected Throwable |
cause |
protected String |
exceptionMessage |
| 构造器和说明 |
|---|
SchemaEvolveException(SchemaChangeEvent applyingEvent,
String exceptionMessage) |
SchemaEvolveException(SchemaChangeEvent applyingEvent,
String exceptionMessage,
Throwable cause) |
| 限定符和类型 | 方法和说明 |
|---|---|
SchemaChangeEvent |
getApplyingEvent() |
Throwable |
getCause() |
String |
getExceptionMessage() |
String |
toString() |
protected final SchemaChangeEvent applyingEvent
protected final String exceptionMessage
public SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage)
public SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage, @Nullable Throwable cause)
Copyright © 2025 The Apache Software Foundation. All rights reserved.