Uses of Interface
org.apache.flink.util.function.ThrowingConsumer

Packages that use ThrowingConsumer

Package	Description
org.apache.flink.api.common.state.v2
org.apache.flink.core.state
org.apache.flink.state.changelog
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.operators.asyncprocessing
org.apache.flink.table.runtime.operators.multipleinput.input
org.apache.flink.util
org.apache.flink.util.function

Uses of ThrowingConsumer in org.apache.flink.api.common.state.v2

Methods in org.apache.flink.api.common.state.v2 with parameters of type ThrowingConsumer

Modifier and Type	Method and Description
StateFuture<Void>	StateFuture.thenAccept(ThrowingConsumer<? super T,? extends Exception> action) Returns a new StateFuture that, when this future completes normally, is executed with this future's result as the argument to the supplied action.

Uses of ThrowingConsumer in org.apache.flink.core.state

Methods in org.apache.flink.core.state with parameters of type ThrowingConsumer

Modifier and Type	Method and Description
StateFuture<Void>	CompletedStateFuture.thenAccept(ThrowingConsumer<? super T,? extends Exception> action)
StateFuture<Void>	StateFutureImpl.thenAccept(ThrowingConsumer<? super T,? extends Exception> action)
void	CompletedStateFuture.thenSyncAccept(ThrowingConsumer<? super T,? extends Exception> action)
void	StateFutureImpl.thenSyncAccept(ThrowingConsumer<? super T,? extends Exception> action)
void	InternalStateFuture.thenSyncAccept(ThrowingConsumer<? super T,? extends Exception> action) Accept the action in the same thread with the one of complete (or current thread if it has been completed).

Uses of ThrowingConsumer in org.apache.flink.state.changelog

Methods in org.apache.flink.state.changelog with parameters of type ThrowingConsumer

Modifier and Type	Method and Description
void	StateChangeLogger.valueElementAdded(ThrowingConsumer<DataOutputView,IOException> dataSerializer, Namespace ns) State element added, such as append of a single element to a list.
void	StateChangeLogger.valueElementAddedOrUpdated(ThrowingConsumer<DataOutputView,IOException> dataSerializer, Namespace ns) State element added or updated, such as put into a map.
void	StateChangeLogger.valueElementRemoved(ThrowingConsumer<DataOutputView,IOException> dataSerializer, Namespace ns) State element removed, such mapping removal from a map.

Uses of ThrowingConsumer in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return ThrowingConsumer

Modifier and Type	Method and Description
ThrowingConsumer<StreamRecord<IN>,Exception>	AbstractInput.getRecordProcessor(int inputId)

Uses of ThrowingConsumer in org.apache.flink.streaming.runtime.io

Methods in org.apache.flink.streaming.runtime.io that return ThrowingConsumer

Modifier and Type	Method and Description
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	RecordProcessorUtils.getRecordProcessor(Input<T> input) Get record processor for Input, which will omit call of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>) if it doesn't have key context.
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	RecordProcessorUtils.getRecordProcessor1(TwoInputStreamOperator<T,?,?> operator) Get record processor for the first input of TwoInputStreamOperator, which will omit call of StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) if it doesn't have key context.
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	RecordProcessorUtils.getRecordProcessor2(TwoInputStreamOperator<?,T,?> operator) Get record processor for the second input of TwoInputStreamOperator, which will omit call of StreamOperator.setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) if it doesn't have key context.

Uses of ThrowingConsumer in org.apache.flink.streaming.runtime.operators.asyncprocessing

Methods in org.apache.flink.streaming.runtime.operators.asyncprocessing that return ThrowingConsumer

Modifier and Type	Method and Description
<T> ThrowingConsumer<StreamRecord<T>,Exception>	AbstractAsyncStateStreamOperatorV2.getRecordProcessor(int inputId)
<T> ThrowingConsumer<StreamRecord<T>,Exception>	AsyncStateProcessing.getRecordProcessor(int inputId) Get the record processor that could process record from input, which is the only entry for async processing.
<T> ThrowingConsumer<StreamRecord<T>,Exception>	AbstractAsyncStateStreamOperator.getRecordProcessor(int inputId)
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	AsyncStateProcessing.makeRecordProcessor(AsyncStateProcessingOperator asyncOperator, KeySelector<T,?> keySelector, ThrowingConsumer<StreamRecord<T>,Exception> processor) Static method helper to make a record processor with given infos.

Methods in org.apache.flink.streaming.runtime.operators.asyncprocessing with parameters of type ThrowingConsumer

Modifier and Type	Method and Description
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	AsyncStateProcessing.makeRecordProcessor(AsyncStateProcessingOperator asyncOperator, KeySelector<T,?> keySelector, ThrowingConsumer<StreamRecord<T>,Exception> processor) Static method helper to make a record processor with given infos.

Uses of ThrowingConsumer in org.apache.flink.table.runtime.operators.multipleinput.input

Methods in org.apache.flink.table.runtime.operators.multipleinput.input that return ThrowingConsumer

Modifier and Type	Method and Description
<T> ThrowingConsumer<StreamRecord<T>,Exception>	OneInput.getRecordProcessor(int inputId)
<T> ThrowingConsumer<StreamRecord<T>,Exception>	SecondInputOfTwoInput.getRecordProcessor(int inputId)
<T> ThrowingConsumer<StreamRecord<T>,Exception>	FirstInputOfTwoInput.getRecordProcessor(int inputId)

Uses of ThrowingConsumer in org.apache.flink.util

Methods in org.apache.flink.util with parameters of type ThrowingConsumer

Modifier and Type	Method and Description
static <T> void	LambdaUtil.applyToAllWhileSuppressingExceptions(Iterable<T> inputs, ThrowingConsumer<T,? extends Exception> throwingConsumer) This method supplies all elements from the input to the consumer.

Uses of ThrowingConsumer in org.apache.flink.util.function

Methods in org.apache.flink.util.function with parameters of type ThrowingConsumer

Modifier and Type	Method and Description
static <A> Consumer<A>	ThrowingConsumer.unchecked(ThrowingConsumer<A,?> throwingConsumer) Convert a ThrowingConsumer into a Consumer.
static <A> Consumer<A>	FunctionUtils.uncheckedConsumer(ThrowingConsumer<A,?> throwingConsumer) Converts a ThrowingConsumer into a Consumer which throws checked exceptions as unchecked.