Index (Flink : Core API 1.20.1-cp3 API)

A B C D E F G H I K L M N O P Q R S T U V Z
All Classes All Packages

A

accept(S, T, U) - Method in interface org.apache.flink.util.function.TriConsumer: Performs this operation on the given arguments.
accept(S, T, U) - Method in interface org.apache.flink.util.function.TriConsumerWithException: Performs this operation on the given arguments.
accept(S, T, U, V) - Method in interface org.apache.flink.util.function.QuadConsumer: Performs this operation on the given arguments.
accept(T) - Method in interface org.apache.flink.util.function.ThrowingConsumer: Performs this operation on the given argument.
accept(T, U) - Method in interface org.apache.flink.util.function.BiConsumerWithException: Performs this operation on the given arguments.
add(IN) - Method in interface org.apache.flink.api.common.state.AppendingState: Updates the operator state accessible by AppendingState.get() by adding the given value to the list of values.
add(IN, ACC) - Method in interface org.apache.flink.api.common.functions.AggregateFunction: Adds the given input value to the given accumulator, returning the new accumulator value.
add(MemorySize) - Method in class org.apache.flink.configuration.MemorySize
addAll(List<T>) - Method in interface org.apache.flink.api.common.state.ListState: Updates the operator state accessible by AppendingState.get() by adding the given values to existing list of values.
AggregateFunction<IN,ACC,OUT> - Interface in org.apache.flink.api.common.functions: The AggregateFunction is a flexible aggregation function, characterized by the following features: The aggregates may use different types for input values, intermediate aggregates, and result type, to support a wide range of aggregation types.
aggregatingState(String, TypeDescriptor<ACC>, AggregateFunction<IN, ACC, OUT>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the AggregatingStateDeclaration of aggregating state.
AggregatingState<IN,OUT> - Interface in org.apache.flink.api.common.state: State interface for aggregating state, based on an AggregateFunction.
AggregatingState<IN,OUT> - Interface in org.apache.flink.api.common.state.v2: State interface for aggregating state, based on an AggregateFunction.
aggregatingStateBuilder(String, TypeDescriptor<ACC>, AggregateFunction<IN, ACC, OUT>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the builder of AggregatingStateDeclaration.
AggregatingStateDeclaration<IN,ACC,OUT> - Interface in org.apache.flink.api.common.state: This represents a declaration of the aggregating state.
AggregatingStateDeclarationBuilder(String, TypeDescriptor<ACC>, AggregateFunction<IN, ACC, OUT>) - Constructor for class org.apache.flink.api.common.state.StateDeclarations.AggregatingStateDeclarationBuilder
AppendingState<IN,OUT> - Interface in org.apache.flink.api.common.state: Base interface for partitioned state that supports adding elements and inspecting the current state.
AppendingState<IN,OUT> - Interface in org.apache.flink.api.common.state.v2: Base interface for partitioned state that supports adding elements and inspecting the current state.
apply(long) - Method in interface org.apache.flink.util.function.LongFunctionWithException: Applies this function to the given argument.
apply(S, T, U) - Method in interface org.apache.flink.util.function.TriFunction: Applies this function to the given arguments.
apply(S, T, U) - Method in interface org.apache.flink.util.function.TriFunctionWithException: Applies this function to the given arguments.
apply(S, T, U, V) - Method in interface org.apache.flink.util.function.QuadFunction: Applies this function to the given arguments.
apply(T) - Method in interface org.apache.flink.util.function.FunctionWithException: Calls this function.
apply(T, U) - Method in interface org.apache.flink.util.function.BiFunctionWithException: Apply the given values t and u to obtain the resulting value.
asyncAdd(IN) - Method in interface org.apache.flink.api.common.state.v2.AppendingState: Updates the operator state accessible by AppendingState.asyncGet() by adding the given value to the list of values.
asyncAddAll(List<T>) - Method in interface org.apache.flink.api.common.state.v2.ListState: Updates the operator state accessible by AppendingState.asyncGet() by adding the given values to existing list of values.
asyncClear() - Method in interface org.apache.flink.api.common.state.v2.State: Removes the value mapped under the current key asynchronously.
asyncContains(UK) - Method in interface org.apache.flink.api.common.state.v2.MapState: Returns whether there exists the given mapping asynchronously.
asyncEntries() - Method in interface org.apache.flink.api.common.state.v2.MapState: Returns the current iterator for all the mappings of this state asynchronously.
asyncGet() - Method in interface org.apache.flink.api.common.state.v2.AppendingState: Returns the current value for the state.
asyncGet(UK) - Method in interface org.apache.flink.api.common.state.v2.MapState: Returns the current value associated with the given key asynchronously.
asyncIsEmpty() - Method in interface org.apache.flink.api.common.state.v2.MapState: Returns whether this state contains no key-value mappings asynchronously.
asyncKeys() - Method in interface org.apache.flink.api.common.state.v2.MapState: Returns the current iterator for all the keys of this state asynchronously.
asyncPut(UK, UV) - Method in interface org.apache.flink.api.common.state.v2.MapState: Update the current value associated with the given key asynchronously.
asyncPutAll(Map<UK, UV>) - Method in interface org.apache.flink.api.common.state.v2.MapState: Update all of the mappings from the given map into the state asynchronously.
asyncRemove(UK) - Method in interface org.apache.flink.api.common.state.v2.MapState: Delete the mapping of the given key from the state asynchronously.
asyncUpdate(List<T>) - Method in interface org.apache.flink.api.common.state.v2.ListState: Updates the operator state accessible by AppendingState.asyncGet() by updating existing values to the given list of values.
asyncUpdate(T) - Method in interface org.apache.flink.api.common.state.v2.ValueState: Updates the operator state accessible by ValueState.asyncValue() to the given value.
asyncValue() - Method in interface org.apache.flink.api.common.state.v2.ValueState: Returns the current value for the state asynchronously.
asyncValues() - Method in interface org.apache.flink.api.common.state.v2.MapState: Returns the current iterator for all the values of this state asynchronously.
AUTOMATIC - org.apache.flink.api.common.RuntimeExecutionMode: Flink will set the execution mode to RuntimeExecutionMode.BATCH if all sources are bounded, or RuntimeExecutionMode.STREAMING if there is at least one source which is unbounded.

B

BATCH - org.apache.flink.api.common.RuntimeExecutionMode: The Pipeline will be executed with Batch Semantics.
BiConsumerWithException<T,U,E extends Throwable> - Interface in org.apache.flink.util.function: A checked extension of the BiConsumer interface.
BiFunctionWithException<T,U,R,E extends Throwable> - Interface in org.apache.flink.util.function: BiFunction interface which can throw exceptions.
BOOLEAN - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
BroadcastState<K,V> - Interface in org.apache.flink.api.common.state: A type of state that can be created to store the state of a BroadcastStream.
BroadcastStateDeclaration<K,V> - Interface in org.apache.flink.api.common.state: This represents a declaration of the broadcast state.
build() - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Build the SlotSharingGroup.
build() - Method in class org.apache.flink.api.common.state.StateDeclarations.ListStateDeclarationBuilder
buildBroadcast() - Method in class org.apache.flink.api.common.state.StateDeclarations.MapStateDeclarationBuilder
BYTE - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
BYTES - org.apache.flink.configuration.MemorySize.MemoryUnit

C

CHAR - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
checked(Supplier<R>) - Static method in interface org.apache.flink.util.function.CheckedSupplier
CheckedSupplier<R> - Interface in org.apache.flink.util.function: Similar to Supplier but can throw Exception.
clear() - Method in interface org.apache.flink.api.common.state.State: Removes the value mapped under the current key.
compareTo(MemorySize) - Method in class org.apache.flink.configuration.MemorySize
contains(K) - Method in interface org.apache.flink.api.common.state.ReadOnlyBroadcastState: Returns whether there exists the given mapping.
contains(UK) - Method in interface org.apache.flink.api.common.state.MapState: Returns whether there exists the given mapping.
createAccumulator() - Method in interface org.apache.flink.api.common.functions.AggregateFunction: Creates a new accumulator, starting a new aggregate.

D

divide(long) - Method in class org.apache.flink.configuration.MemorySize
DOUBLE - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors

E

entries() - Method in interface org.apache.flink.api.common.state.BroadcastState: Returns all the mappings in the state.
entries() - Method in interface org.apache.flink.api.common.state.MapState: Returns all the mappings in the state.
equals(Object) - Method in class org.apache.flink.api.common.SlotSharingGroup
equals(Object) - Method in class org.apache.flink.configuration.MemorySize

F

FLOAT - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
Function - Interface in org.apache.flink.api.common.functions: The base interface for all user-defined functions.
FunctionWithException<T,R,E extends Throwable> - Interface in org.apache.flink.util.function: A functional interface for a Function that may throw exceptions.

G

get() - Method in interface org.apache.flink.api.common.state.AppendingState: Returns the current value for the state.
get() - Method in interface org.apache.flink.util.function.SupplierWithException: Gets the result of this supplier.
get(K) - Method in interface org.apache.flink.api.common.state.ReadOnlyBroadcastState: Returns the current value associated with the given key.
get(UK) - Method in interface org.apache.flink.api.common.state.MapState: Returns the current value associated with the given key.
getAggregateFunction() - Method in interface org.apache.flink.api.common.state.AggregatingStateDeclaration: Get the aggregate function of this state.
getAllUnits() - Static method in enum org.apache.flink.configuration.MemorySize.MemoryUnit
getBytes() - Method in class org.apache.flink.configuration.MemorySize: Gets the memory size in bytes.
getCpuCores() - Method in class org.apache.flink.api.common.SlotSharingGroup
getExternalResources() - Method in class org.apache.flink.api.common.SlotSharingGroup
getGibiBytes() - Method in class org.apache.flink.configuration.MemorySize: Gets the memory size in Gibibytes (= 1024 Mebibytes).
getInstance(String, Object...) - Static method in class org.apache.flink.api.common.typeinfo.utils.TypeUtils
getKey(IN) - Method in interface org.apache.flink.api.java.functions.KeySelector: User-defined function that deterministically extracts the key from an object.
getKeyTypeDescriptor() - Method in interface org.apache.flink.api.common.state.BroadcastStateDeclaration: Get type descriptor of this broadcast state's key.
getKeyTypeDescriptor() - Method in interface org.apache.flink.api.common.state.MapStateDeclaration: Get type descriptor of this map state's key.
getKibiBytes() - Method in class org.apache.flink.configuration.MemorySize: Gets the memory size in Kibibytes (= 1024 bytes).
getManagedMemory() - Method in class org.apache.flink.api.common.SlotSharingGroup
getMebiBytes() - Method in class org.apache.flink.configuration.MemorySize: Gets the memory size in Mebibytes (= 1024 Kibibytes).
getMultiplier() - Method in enum org.apache.flink.configuration.MemorySize.MemoryUnit
getName() - Method in class org.apache.flink.api.common.SlotSharingGroup
getName() - Method in interface org.apache.flink.api.common.state.StateDeclaration: Get the name of this state.
getRedistributionMode() - Method in interface org.apache.flink.api.common.state.StateDeclaration: Get the StateDeclaration.RedistributionMode of this state.
getRedistributionStrategy() - Method in interface org.apache.flink.api.common.state.ListStateDeclaration: Get the ListStateDeclaration.RedistributionStrategy of this list state.
getReduceFunction() - Method in interface org.apache.flink.api.common.state.ReducingStateDeclaration: Get ReduceFunction associated with this reducing state.
getResult(ACC) - Method in interface org.apache.flink.api.common.functions.AggregateFunction: Gets the result of the aggregation from the accumulator.
getTaskHeapMemory() - Method in class org.apache.flink.api.common.SlotSharingGroup
getTaskOffHeapMemory() - Method in class org.apache.flink.api.common.SlotSharingGroup
getTebiBytes() - Method in class org.apache.flink.configuration.MemorySize: Gets the memory size in Tebibytes (= 1024 Gibibytes).
getTypeClass() - Method in interface org.apache.flink.api.common.typeinfo.TypeDescriptor: Gets the class of the type represented by this type descriptor.
getTypeDescriptor() - Method in interface org.apache.flink.api.common.state.AggregatingStateDeclaration: Get type descriptor of this state.
getTypeDescriptor() - Method in interface org.apache.flink.api.common.state.ListStateDeclaration: Get type descriptor of this list state's element.
getTypeDescriptor() - Method in interface org.apache.flink.api.common.state.ReducingStateDeclaration: Get type descriptor of this reducing state.
getTypeDescriptor() - Method in interface org.apache.flink.api.common.state.ValueStateDeclaration: Get type descriptor of this value state.
getUnits() - Method in enum org.apache.flink.configuration.MemorySize.MemoryUnit
getValueTypeDescriptor() - Method in interface org.apache.flink.api.common.state.BroadcastStateDeclaration: Get type descriptor of this broadcast state's value.
getValueTypeDescriptor() - Method in interface org.apache.flink.api.common.state.MapStateDeclaration: Get type descriptor of this map state's value.
GIGA_BYTES - org.apache.flink.configuration.MemorySize.MemoryUnit

H

hashCode() - Method in class org.apache.flink.api.common.SlotSharingGroup
hashCode() - Method in class org.apache.flink.configuration.MemorySize
hasUnit(String) - Static method in enum org.apache.flink.configuration.MemorySize.MemoryUnit

I

IDENTICAL - org.apache.flink.api.common.state.StateDeclaration.RedistributionMode: States are guranteed to be identical in different partitions, thus redistribution is not a problem.
IllegalRedistributionModeException - Exception in org.apache.flink.api.common.state: A special IllegalStateException indicating a mismatch in StateDeclaration.
IllegalRedistributionModeException(StateDeclaration.RedistributionMode) - Constructor for exception org.apache.flink.api.common.state.IllegalRedistributionModeException
immutableEntries() - Method in interface org.apache.flink.api.common.state.ReadOnlyBroadcastState: Returns an immutable Iterable over the entries in the state.
INT - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
isEmpty() - Method in interface org.apache.flink.api.common.state.MapState: Returns true if this state contains no key-value mappings, otherwise false.
isEmpty() - Method in interface org.apache.flink.api.common.state.v2.StateIterator: Return if this iterator is empty synchronously.
iterator() - Method in interface org.apache.flink.api.common.state.BroadcastState: Iterates over all the mappings in the state.
iterator() - Method in interface org.apache.flink.api.common.state.MapState: Iterates over all the mappings in the state.

K

keys() - Method in interface org.apache.flink.api.common.state.MapState: Returns all the keys in the state.
KeySelector<IN,KEY> - Interface in org.apache.flink.api.java.functions: The KeySelector allows to use deterministic objects for operations such as reduce, reduceGroup, join, coGroup, etc.
KILO_BYTES - org.apache.flink.configuration.MemorySize.MemoryUnit

L

list(TypeDescriptor<T>) - Static method in class org.apache.flink.api.common.typeinfo.TypeDescriptors
listState(String, TypeDescriptor<T>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the ListStateDeclaration of list state with StateDeclaration.RedistributionMode.NONE.
ListState<T> - Interface in org.apache.flink.api.common.state: State interface for partitioned list state in Operations.
ListState<T> - Interface in org.apache.flink.api.common.state.v2: State interface for partitioned list state in Operations.
listStateBuilder(String, TypeDescriptor<T>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the builder of ListStateDeclaration.
ListStateDeclaration<T> - Interface in org.apache.flink.api.common.state: This represents a declaration of the list state.
ListStateDeclaration.RedistributionStrategy - Enum in org.apache.flink.api.common.state: ListStateDeclaration.RedistributionStrategy is used to guide the assignment of states during rescaling.
ListStateDeclarationBuilder(String, TypeDescriptor<T>) - Constructor for class org.apache.flink.api.common.state.StateDeclarations.ListStateDeclarationBuilder
LONG - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
LongFunctionWithException<R,E extends Throwable> - Interface in org.apache.flink.util.function: Similar to LongFunction but can throw Exception.

M

map(TypeDescriptor<K>, TypeDescriptor<V>) - Static method in class org.apache.flink.api.common.typeinfo.TypeDescriptors
mapState(String, TypeDescriptor<K>, TypeDescriptor<V>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the MapStateDeclaration of map state with StateDeclaration.RedistributionMode.NONE.
MapState<UK,UV> - Interface in org.apache.flink.api.common.state: State interface for partitioned key-value state.
MapState<UK,UV> - Interface in org.apache.flink.api.common.state.v2: State interface for partitioned key-value state.
mapStateBuilder(String, TypeDescriptor<K>, TypeDescriptor<V>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the builder of MapStateDeclaration.
MapStateDeclaration<K,V> - Interface in org.apache.flink.api.common.state: This represents a declaration of the map state.
MapStateDeclarationBuilder(String, TypeDescriptor<K>, TypeDescriptor<V>) - Constructor for class org.apache.flink.api.common.state.StateDeclarations.MapStateDeclarationBuilder
MapStateDeclarationBuilder(String, TypeDescriptor<K>, TypeDescriptor<V>, StateDeclaration.RedistributionMode) - Constructor for class org.apache.flink.api.common.state.StateDeclarations.MapStateDeclarationBuilder
MAX_VALUE - Static variable in class org.apache.flink.configuration.MemorySize
MEGA_BYTES - org.apache.flink.configuration.MemorySize.MemoryUnit
MemorySize - Class in org.apache.flink.configuration: MemorySize is a representation of a number of bytes, viewable in different units.
MemorySize(long) - Constructor for class org.apache.flink.configuration.MemorySize: Constructs a new MemorySize.
MemorySize.MemoryUnit - Enum in org.apache.flink.configuration: Enum which defines memory unit, mostly used to parse value from configuration file.
merge(ACC, ACC) - Method in interface org.apache.flink.api.common.functions.AggregateFunction: Merges two accumulators, returning an accumulator with the merged state.
MergingState<IN,OUT> - Interface in org.apache.flink.api.common.state: Extension of AppendingState that allows merging of state.
MergingState<IN,OUT> - Interface in org.apache.flink.api.common.state.v2: Extension of AppendingState that allows merging of state.
multiply(double) - Method in class org.apache.flink.configuration.MemorySize

N

newBuilder(String) - Static method in class org.apache.flink.api.common.SlotSharingGroup
NONE - org.apache.flink.api.common.state.StateDeclaration.RedistributionMode: Not supports redistribution.

O

ofMebiBytes(long) - Static method in class org.apache.flink.configuration.MemorySize
onNext(Consumer<T>) - Method in interface org.apache.flink.api.common.state.v2.StateIterator: Async iterate the data and call the callback when data is ready.
onNext(Function<T, StateFuture<? extends U>>) - Method in interface org.apache.flink.api.common.state.v2.StateIterator: Async iterate the data and call the callback when data is ready.
org.apache.flink.api.common - package org.apache.flink.api.common
org.apache.flink.api.common.functions - package org.apache.flink.api.common.functions
org.apache.flink.api.common.state - package org.apache.flink.api.common.state
org.apache.flink.api.common.state.v2 - package org.apache.flink.api.common.state.v2
org.apache.flink.api.common.typeinfo - package org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeinfo.utils - package org.apache.flink.api.common.typeinfo.utils
org.apache.flink.api.connector.dsv2 - package org.apache.flink.api.connector.dsv2
org.apache.flink.api.java.functions - package org.apache.flink.api.java.functions
org.apache.flink.configuration - package org.apache.flink.configuration
org.apache.flink.util.function - package org.apache.flink.util.function

P

parse(String) - Static method in class org.apache.flink.configuration.MemorySize: Parses the given string as as MemorySize.
parse(String, MemorySize.MemoryUnit) - Static method in class org.apache.flink.configuration.MemorySize: Parses the given string with a default unit.
parseBytes(String) - Static method in class org.apache.flink.configuration.MemorySize: Parses the given string as bytes.
put(K, V) - Method in interface org.apache.flink.api.common.state.BroadcastState: Associates a new value with the given key.
put(UK, UV) - Method in interface org.apache.flink.api.common.state.MapState: Associates a new value with the given key.
putAll(Map<K, V>) - Method in interface org.apache.flink.api.common.state.BroadcastState: Copies all of the mappings from the given map into the state.
putAll(Map<UK, UV>) - Method in interface org.apache.flink.api.common.state.MapState: Copies all of the mappings from the given map into the state.

Q

QuadConsumer<S,T,U,V> - Interface in org.apache.flink.util.function: Operation which is performed on four given arguments.
QuadFunction<S,T,U,V,R> - Interface in org.apache.flink.util.function: Function which takes three arguments.

R

ReadOnlyBroadcastState<K,V> - Interface in org.apache.flink.api.common.state: A read-only view of the BroadcastState.
REDISTRIBUTABLE - org.apache.flink.api.common.state.StateDeclaration.RedistributionMode: This state can be safely redistributed between different partitions, and the specific redistribution strategy is determined by the state itself.
redistributeBy(ListStateDeclaration.RedistributionStrategy) - Method in class org.apache.flink.api.common.state.StateDeclarations.ListStateDeclarationBuilder
redistributeWithMode(StateDeclaration.RedistributionMode) - Method in class org.apache.flink.api.common.state.StateDeclarations.ListStateDeclarationBuilder
reduce(T, T) - Method in interface org.apache.flink.api.common.functions.ReduceFunction: The core method of ReduceFunction, combining two values into one value of the same type.
ReduceFunction<T> - Interface in org.apache.flink.api.common.functions: Base interface for Reduce functions.
reducingState(String, TypeDescriptor<T>, ReduceFunction<T>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the ReducingStateDeclaration of list state.
ReducingState<T> - Interface in org.apache.flink.api.common.state: State interface for reducing state.
ReducingState<T> - Interface in org.apache.flink.api.common.state.v2: State interface for reducing state.
reducingStateBuilder(String, TypeDescriptor<T>, ReduceFunction<T>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the builder of ReducingStateDeclaration.
ReducingStateDeclaration<T> - Interface in org.apache.flink.api.common.state: This represents a declaration of the reducing state.
ReducingStateDeclarationBuilder(String, TypeDescriptor<T>, ReduceFunction<T>) - Constructor for class org.apache.flink.api.common.state.StateDeclarations.ReducingStateDeclarationBuilder
remove(K) - Method in interface org.apache.flink.api.common.state.BroadcastState: Deletes the mapping of the given key.
remove(UK) - Method in interface org.apache.flink.api.common.state.MapState: Deletes the mapping of the given key.
run() - Method in interface org.apache.flink.util.function.RunnableWithException: The work method.
run() - Method in interface org.apache.flink.util.function.ThrowingRunnable: The work method.
RunnableWithException - Interface in org.apache.flink.util.function: Similar to a Runnable, this interface is used to capture a block of code to be executed.
RuntimeExecutionMode - Enum in org.apache.flink.api.common: Runtime execution mode of DataStream programs.

S

SerializableFunction<T,R> - Interface in org.apache.flink.util.function: A Function that is also Serializable.
SerializableSupplier<T> - Interface in org.apache.flink.util.function: A serializable Supplier.
SerializableSupplierWithException<T,E extends Throwable> - Interface in org.apache.flink.util.function: A serializable SupplierWithException.
setCpuCores(double) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the CPU cores for this SlotSharingGroup.
setExternalResource(String, double) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Add the given external resource.
setManagedMemory(MemorySize) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the task managed memory for this SlotSharingGroup.
setManagedMemoryMB(int) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the task managed memory for this SlotSharingGroup in MB.
setTaskHeapMemory(MemorySize) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the task heap memory for this SlotSharingGroup.
setTaskHeapMemoryMB(int) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the task heap memory for this SlotSharingGroup in MB.
setTaskOffHeapMemory(MemorySize) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the task off-heap memory for this SlotSharingGroup.
setTaskOffHeapMemoryMB(int) - Method in class org.apache.flink.api.common.SlotSharingGroup.Builder: Set the task off-heap memory for this SlotSharingGroup in MB.
SHORT - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
Sink<T> - Interface in org.apache.flink.api.connector.dsv2: Sink interface for DataStream api v2.
SlotSharingGroup - Class in org.apache.flink.api.common: Describe the name and the different resource components of a slot sharing group.
SlotSharingGroup.Builder - Class in org.apache.flink.api.common: Builder for SlotSharingGroup.
Source<T> - Interface in org.apache.flink.api.connector.dsv2: Source interface for DataStream api v2.
SPLIT - org.apache.flink.api.common.state.ListStateDeclaration.RedistributionStrategy: The whole state is logically a concatenation of all lists.
State - Interface in org.apache.flink.api.common.state: Interface that different types of partitioned state must implement.
State - Interface in org.apache.flink.api.common.state.v2: Interface that different types of partitioned state must implement.
StateDeclaration - Interface in org.apache.flink.api.common.state: StateDeclaration represents a declaration of the specific state used.
StateDeclaration.RedistributionMode - Enum in org.apache.flink.api.common.state: StateDeclaration.RedistributionMode is used to indicate whether this state supports redistribution between partitions and how to redistribute this state during rescaling.
StateDeclarations - Class in org.apache.flink.api.common.state: This is a helper class for declaring various states.
StateDeclarations() - Constructor for class org.apache.flink.api.common.state.StateDeclarations
StateDeclarations.AggregatingStateDeclarationBuilder<IN,OUT,ACC> - Class in org.apache.flink.api.common.state: Builder for AggregatingStateDeclaration.
StateDeclarations.ListStateDeclarationBuilder<T> - Class in org.apache.flink.api.common.state: Builder for ListStateDeclaration.
StateDeclarations.MapStateDeclarationBuilder<K,V> - Class in org.apache.flink.api.common.state: Builder for MapStateDeclaration.
StateDeclarations.ReducingStateDeclarationBuilder<T> - Class in org.apache.flink.api.common.state: Builder for ReducingStateDeclaration.
StateDeclarations.ValueStateDeclarationBuilder<T> - Class in org.apache.flink.api.common.state: Builder for ValueStateDeclaration.
StateFuture<T> - Interface in org.apache.flink.api.common.state.v2: StateFuture is a future that act as a return value for async state interfaces.
StateIterator<T> - Interface in org.apache.flink.api.common.state.v2: Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand.
STREAMING - org.apache.flink.api.common.RuntimeExecutionMode: The Pipeline will be executed with Streaming Semantics.
STRING - Static variable in class org.apache.flink.api.common.typeinfo.TypeDescriptors
subtract(MemorySize) - Method in class org.apache.flink.configuration.MemorySize
SupplierWithException<R,E extends Throwable> - Interface in org.apache.flink.util.function: A functional interface for a Supplier that may throw exceptions.

T

TERA_BYTES - org.apache.flink.configuration.MemorySize.MemoryUnit
thenAccept(ThrowingConsumer<? super T, ? extends Exception>) - Method in interface org.apache.flink.api.common.state.v2.StateFuture: Returns a new StateFuture that, when this future completes normally, is executed with this future's result as the argument to the supplied action.
thenApply(FunctionWithException<? super T, ? extends U, ? extends Exception>) - Method in interface org.apache.flink.api.common.state.v2.StateFuture: Returns a new StateFuture that, when this future completes normally, is executed with this future's result as the argument to the supplied function.
thenCombine(StateFuture<? extends U>, BiFunctionWithException<? super T, ? super U, ? extends V, ? extends Exception>) - Method in interface org.apache.flink.api.common.state.v2.StateFuture: Returns a new StateFuture that, when this and the other given future both complete normally, is executed with the two results as arguments to the supplied function.
thenCompose(FunctionWithException<? super T, ? extends StateFuture<U>, ? extends Exception>) - Method in interface org.apache.flink.api.common.state.v2.StateFuture: Returns a new future that, when this future completes normally, is executed with this future as the argument to the supplied function.
ThrowingConsumer<T,E extends Throwable> - Interface in org.apache.flink.util.function: This interface is basically Java's Consumer interface enhanced with the ability to throw an exception.
ThrowingRunnable<E extends Throwable> - Interface in org.apache.flink.util.function: Similar to a Runnable, this interface is used to capture a block of code to be executed.
toHumanReadableString() - Method in class org.apache.flink.configuration.MemorySize
toString() - Method in class org.apache.flink.configuration.MemorySize
TriConsumer<S,T,U> - Interface in org.apache.flink.util.function: Operation which is performed on three given arguments.
TriConsumerWithException<S,T,U,E extends Throwable> - Interface in org.apache.flink.util.function: A checked extension of the TriConsumer interface.
TriFunction<S,T,U,R> - Interface in org.apache.flink.util.function: Function which takes three arguments.
TriFunctionWithException<S,T,U,R,E extends Throwable> - Interface in org.apache.flink.util.function: Function which takes three arguments.
TypeDescriptor<T> - Interface in org.apache.flink.api.common.typeinfo: Descriptor interface to create TypeInformation instances.
TypeDescriptors - Class in org.apache.flink.api.common.typeinfo: Descriptor interface to create TypeInformation instances.
TypeDescriptors() - Constructor for class org.apache.flink.api.common.typeinfo.TypeDescriptors
TypeUtils - Class in org.apache.flink.api.common.typeinfo.utils: Utility class to create objects via reflection.
TypeUtils() - Constructor for class org.apache.flink.api.common.typeinfo.utils.TypeUtils

U

unchecked(BiConsumerWithException<A, B, ?>) - Static method in interface org.apache.flink.util.function.BiConsumerWithException: Convert a BiConsumerWithException into a BiConsumer.
unchecked(BiFunctionWithException<A, B, C, ?>) - Static method in interface org.apache.flink.util.function.BiFunctionWithException: Convert at BiFunctionWithException into a BiFunction.
unchecked(CheckedSupplier<R>) - Static method in interface org.apache.flink.util.function.CheckedSupplier
unchecked(FunctionWithException<A, B, ?>) - Static method in interface org.apache.flink.util.function.FunctionWithException: Convert at FunctionWithException into a Function.
unchecked(ThrowingConsumer<A, ?>) - Static method in interface org.apache.flink.util.function.ThrowingConsumer: Convert a ThrowingConsumer into a Consumer.
unchecked(ThrowingRunnable<?>) - Static method in interface org.apache.flink.util.function.ThrowingRunnable: Converts a ThrowingRunnable into a Runnable which throws all checked exceptions as unchecked.
unchecked(TriConsumerWithException<A, B, C, ?>) - Static method in interface org.apache.flink.util.function.TriConsumerWithException: Convert a TriConsumerWithException into a TriConsumer.
unchecked(TriFunctionWithException<A, B, C, D, ?>) - Static method in interface org.apache.flink.util.function.TriFunctionWithException: Convert at TriFunctionWithException into a TriFunction.
UNION - org.apache.flink.api.common.state.ListStateDeclaration.RedistributionStrategy: The whole state is logically a concatenation of all lists.
update(List<T>) - Method in interface org.apache.flink.api.common.state.ListState: Updates the operator state accessible by AppendingState.get() by updating existing values to the given list of values.
update(T) - Method in interface org.apache.flink.api.common.state.ValueState: Updates the operator state accessible by ValueState.value() to the given value.

V

value() - Method in interface org.apache.flink.api.common.state.ValueState: Returns the current value for the state.
value(TypeDescriptor<T>) - Static method in class org.apache.flink.api.common.typeinfo.TypeDescriptors
valueOf(String) - Static method in enum org.apache.flink.api.common.RuntimeExecutionMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.api.common.state.ListStateDeclaration.RedistributionStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.api.common.state.StateDeclaration.RedistributionMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.configuration.MemorySize.MemoryUnit: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.api.common.RuntimeExecutionMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.api.common.state.ListStateDeclaration.RedistributionStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in interface org.apache.flink.api.common.state.MapState: Returns all the values in the state.
values() - Static method in enum org.apache.flink.api.common.state.StateDeclaration.RedistributionMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.configuration.MemorySize.MemoryUnit: Returns an array containing the constants of this enum type, in the order they are declared.
valueState(String, TypeDescriptor<T>) - Static method in class org.apache.flink.api.common.state.StateDeclarations: Get the ValueStateDeclaration of value state.
ValueState<T> - Interface in org.apache.flink.api.common.state.v2: State interface for partitioned single-value state.
ValueState<T> - Interface in org.apache.flink.api.common.state: State interface for partitioned single-value state.
valueStateBuilder(String, TypeDescriptor<T>) - Method in class org.apache.flink.api.common.state.StateDeclarations: Get the builder of ValueStateDeclaration.
ValueStateDeclaration<T> - Interface in org.apache.flink.api.common.state: This represents a declaration of the value state.
ValueStateDeclarationBuilder(String, TypeDescriptor<T>) - Constructor for class org.apache.flink.api.common.state.StateDeclarations.ValueStateDeclarationBuilder

Z

ZERO - Static variable in class org.apache.flink.configuration.MemorySize

A B C D E F G H I K L M N O P Q R S T U V Z
All Classes All Packages