Package io.confluent.flink.plugin

Class StatementWarning

java.lang.Object

io.confluent.flink.plugin.StatementWarning

public class StatementWarning
extends Object

Represents a non-fatal issue encountered during statement processing.

Warnings indicate potential problems that don't prevent statement execution but may require user attention. The severity level indicates how critical the warning is.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StatementWarning.Severity	Warning severity levels.

Constructor Summary

Constructors

Constructor	Description
StatementWarning(StatementWarning.Severity severity, OffsetDateTime createdAt, String reason, String message)	Creates a new statement warning.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
OffsetDateTime	getCreatedAt()	Returns the timestamp when the warning was created.
String	getMessage()	Returns a human-readable description of the warning.
String	getReason()	Returns a machine-readable summary of the warning.
StatementWarning.Severity	getSeverity()	Returns the severity of the warning.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

StatementWarning

public StatementWarning(StatementWarning.Severity severity,
 OffsetDateTime createdAt,
 String reason,
 String message)

Creates a new statement warning.

Parameters:

severity - the severity level

createdAt - the timestamp when the warning was created (RFC3339 format, UTC)

reason - a machine-readable short, upper case summary delimited by underscore

message - a human-readable description of the warning

Method Details

getSeverity

public StatementWarning.Severity getSeverity()

Returns the severity of the warning.

Returns:

the severity level

getCreatedAt

public OffsetDateTime getCreatedAt()

Returns the timestamp when the warning was created.

Returns:

the creation timestamp in RFC3339 format (UTC)

getReason

public String getReason()

Returns a machine-readable summary of the warning.

Returns:

the reason code (upper case, underscore-delimited)

getMessage

public String getMessage()

Returns a human-readable description of the warning.

Returns:

the warning message

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object