Package | Description |
---|---|
org.apache.flink.connector.jdbc.xa |
Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
|
org.apache.flink.runtime.rpc.akka.exceptions | |
org.apache.flink.runtime.util | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.table.functions.hive | |
org.apache.flink.table.runtime.operators.multipleinput.output | |
org.apache.flink.util |
Modifier and Type | Class and Description |
---|---|
static class |
XaFacade.EmptyXaTransactionException
|
static class |
XaFacade.TransientXaException
Indicates a transient or unknown failure from the resource manager (see
XA_RBTRANSIENT , XAER_RMFAIL ). |
Modifier and Type | Class and Description |
---|---|
class |
AkkaRpcInvalidStateException
Exception which indicates an invalid state.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
HadoopUtils.isMaxHadoopVersion(int major,
int minor)
Checks if the Hadoop dependency is at most the given version.
|
static boolean |
HadoopUtils.isMinHadoopVersion(int major,
int minor)
Checks if the Hadoop dependency is at least the given version.
|
Modifier and Type | Class and Description |
---|---|
class |
UnsupportedTimeCharacteristicException
An exception that indicates that a time characteristic was used that is not supported in the
current operation.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MailboxExecutor.tryYield()
This methods attempts to run the command at the head of the mailbox.
|
void |
MailboxExecutor.yield()
This methods starts running the command at the head of the mailbox and is intended to be used
by the mailbox thread to yield from a currently ongoing action to another command.
|
Modifier and Type | Class and Description |
---|---|
class |
ExceptionInChainedOperatorException
A special exception that signifies that the cause exception came from a chained operator.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkHiveUDFException
Hive UDF related exceptions in Flink.
|
Modifier and Type | Class and Description |
---|---|
class |
ExceptionInMultipleInputOperatorException
A special exception that signifies that the cause exception came from a
MultipleInputStreamOperatorBase . |
Modifier and Type | Class and Description |
---|---|
class |
WrappingRuntimeException
A runtime exception that is explicitly used to wrap non-runtime exceptions.
|
Modifier and Type | Method and Description |
---|---|
T |
OptionalFailure.getUnchecked() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.