Package | Description |
---|---|
org.apache.flink.runtime.rpc.akka.exceptions | |
org.apache.flink.runtime.util | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.util |
Modifier and Type | Class and Description |
---|---|
class |
AkkaRpcInvalidStateException
Exception which indicates an invalid state.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
HadoopUtils.isMinHadoopVersion(int major,
int minor)
Checks if the Hadoop dependency is at least of 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 | 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 |
WrappingRuntimeException
A runtime exception that is explicitly used to wrap non-runtime exceptions.
|
Modifier and Type | Method and Description |
---|---|
T |
OptionalFailure.getUnchecked() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.