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

Packages that use SupplierWithException

Package	Description
org.apache.flink.client
org.apache.flink.connector.file.src.util
org.apache.flink.connector.file.table.batch.compact
org.apache.flink.connector.file.table.stream.compact
org.apache.flink.runtime.client
org.apache.flink.runtime.concurrent
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.io.network.partition.hybrid
org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle
org.apache.flink.runtime.rest.handler.util
org.apache.flink.runtime.state
org.apache.flink.runtime.taskexecutor
org.apache.flink.util
org.apache.flink.util.concurrent
org.apache.flink.util.function

Uses of SupplierWithException in org.apache.flink.client

Methods in org.apache.flink.client with parameters of type SupplierWithException

Modifier and Type	Method and Description
static void	ClientUtils.waitUntilJobInitializationFinished(SupplierWithException<JobStatus,Exception> jobStatusSupplier, SupplierWithException<JobResult,Exception> jobResultSupplier, ClassLoader userCodeClassloader) This method blocks until the job status is not INITIALIZING anymore.
static void	ClientUtils.waitUntilJobInitializationFinished(SupplierWithException<JobStatus,Exception> jobStatusSupplier, SupplierWithException<JobResult,Exception> jobResultSupplier, ClassLoader userCodeClassloader) This method blocks until the job status is not INITIALIZING anymore.

Uses of SupplierWithException in org.apache.flink.connector.file.src.util

Methods in org.apache.flink.connector.file.src.util with parameters of type SupplierWithException

Modifier and Type	Method and Description
static <E> E	Utils.doWithCleanupOnException(Closeable toCleanUp, SupplierWithException<E,IOException> code) Runs the given SupplierWithException (a piece of code producing a result).

Uses of SupplierWithException in org.apache.flink.connector.file.table.batch.compact

Constructors in org.apache.flink.connector.file.table.batch.compact with parameters of type SupplierWithException

Constructor and Description
BatchCompactCoordinator(SupplierWithException<FileSystem,IOException> fsFactory, long compactAverageSize, long compactTargetSize)
BatchCompactOperator(SupplierWithException<FileSystem,IOException> fsFactory, CompactReader.Factory<T> readerFactory, CompactWriter.Factory<T> writerFactory)

Uses of SupplierWithException in org.apache.flink.connector.file.table.stream.compact

Methods in org.apache.flink.connector.file.table.stream.compact with parameters of type SupplierWithException

Modifier and Type	Method and Description
static <T> CompactWriter.Factory<T>	CompactBucketWriter.factory(SupplierWithException<BucketWriter<T,String>,IOException> factory)

Constructors in org.apache.flink.connector.file.table.stream.compact with parameters of type SupplierWithException

Constructor and Description
CompactCoordinator(SupplierWithException<FileSystem,IOException> fsFactory, long targetFileSize)
CompactOperator(SupplierWithException<FileSystem,IOException> fsFactory, CompactReader.Factory<T> readerFactory, CompactWriter.Factory<T> writerFactory)

Uses of SupplierWithException in org.apache.flink.runtime.client

Methods in org.apache.flink.runtime.client with parameters of type SupplierWithException

Modifier and Type	Method and Description
static void	ClientUtils.extractAndUploadJobGraphFiles(JobGraph jobGraph, SupplierWithException<BlobClient,IOException> clientSupplier) Extracts all files required for the execution from the given JobGraph and uploads them using the BlobClient from the given Supplier.
static void	ClientUtils.uploadJobGraphFiles(JobGraph jobGraph, Collection<Path> userJars, Collection<Tuple2<String,Path>> userArtifacts, SupplierWithException<BlobClient,IOException> clientSupplier) Uploads the given jars and artifacts required for the execution of the given JobGraph using the BlobClient from the given Supplier.

Uses of SupplierWithException in org.apache.flink.runtime.concurrent

Methods in org.apache.flink.runtime.concurrent with parameters of type SupplierWithException

Modifier and Type	Method and Description
static <T,E extends Throwable> T	ClassLoadingUtils.runWithContextClassLoader(SupplierWithException<T,E> supplier, ClassLoader contextClassLoader) Runs the given supplier in a TemporaryClassLoaderContext based on the given classloader.

Uses of SupplierWithException in org.apache.flink.runtime.io.network.partition

Methods in org.apache.flink.runtime.io.network.partition with parameters of type SupplierWithException

Modifier and Type	Method and Description
ResultPartition	ResultPartitionFactory.create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, boolean isBroadcast, SupplierWithException<BufferPool,IOException> bufferPoolFactory)

Constructors in org.apache.flink.runtime.io.network.partition with parameters of type SupplierWithException

Constructor and Description
BoundedBlockingResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
BufferWritingResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
PipelinedResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
ResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
SortMergeResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, BatchShuffleReadBufferPool readBufferPool, Executor readIOExecutor, ResultPartitionManager partitionManager, String resultFileBasePath, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)

Uses of SupplierWithException in org.apache.flink.runtime.io.network.partition.consumer

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type SupplierWithException

Constructor and Description

SingleInputGate(String owningTaskName, int gateIndex, IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange subpartitionIndexRange, int numberOfInputChannels, PartitionProducerStateProvider partitionProducerStateProvider, SupplierWithException<BufferPool,IOException> bufferPoolFactory, BufferDecompressor bufferDecompressor, MemorySegmentProvider memorySegmentProvider, int segmentSize, ThroughputCalculator throughputCalculator, BufferDebloater bufferDebloater, TieredStorageConsumerClient tieredStorageConsumerClient, TieredStorageNettyServiceImpl nettyService, List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs)

Uses of SupplierWithException in org.apache.flink.runtime.io.network.partition.hybrid

Constructors in org.apache.flink.runtime.io.network.partition.hybrid with parameters of type SupplierWithException

Constructor and Description

HsResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, BatchShuffleReadBufferPool readBufferPool, ScheduledExecutorService readIOExecutor, ResultPartitionManager partitionManager, String dataFileBashPath, int networkBufferSize, HybridShuffleConfiguration hybridShuffleConfiguration, BufferCompressor bufferCompressor, boolean isBroadcastOnly, SupplierWithException<BufferPool,IOException> bufferPoolFactory)

Uses of SupplierWithException in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle with parameters of type SupplierWithException

Modifier and Type

Method and Description

TieredResultPartition

TieredResultPartitionFactory.createTieredResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int maxParallelism, Boolean isBroadCastOnly, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory, FileChannelManager fileChannelManager, BatchShuffleReadBufferPool batchShuffleReadBufferPool, ScheduledExecutorService batchShuffleReadIOExecutor)

Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle with parameters of type SupplierWithException

Constructor and Description

TieredResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory, TieredStorageProducerClient tieredStorageProducerClient, TieredStorageResourceRegistry tieredStorageResourceRegistry, TieredStorageNettyServiceImpl nettyService, List<TieredStorageMemorySpec> tieredStorageMemorySpecs, TieredStorageMemoryManager storageMemoryManager)

Uses of SupplierWithException in org.apache.flink.runtime.rest.handler.util

Methods in org.apache.flink.runtime.rest.handler.util with parameters of type SupplierWithException

Modifier and Type	Method and Description
static <T> T	HandlerRequestUtils.fromRequestBodyOrQueryParameter(T requestValue, SupplierWithException<T,RestHandlerException> queryParameterExtractor, T defaultValue, org.slf4j.Logger log) Returns requestValue if it is not null, otherwise returns the query parameter value if it is not null, otherwise returns the default value.

Uses of SupplierWithException in org.apache.flink.runtime.state

Constructors in org.apache.flink.runtime.state with parameters of type SupplierWithException

Constructor and Description
FullSnapshotAsyncWriter(SnapshotType snapshotType, SupplierWithException<CheckpointStreamWithResultProvider,Exception> checkpointStreamSupplier, FullSnapshotResources<K> snapshotResources)

Uses of SupplierWithException in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor with parameters of type SupplierWithException

Modifier and Type	Method and Description
<E extends Exception> JobTable.Job	DefaultJobTable.getOrCreateJob(JobID jobId, SupplierWithException<? extends JobTable.JobServices,E> jobServicesSupplier)
<E extends Exception> JobTable.Job	JobTable.getOrCreateJob(JobID jobId, SupplierWithException<? extends JobTable.JobServices,E> jobServicesSupplier) Gets a registered JobTable.Job or creates one if not present.

Uses of SupplierWithException in org.apache.flink.util

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

Modifier and Type	Method and Description
static <R,E extends Throwable> R	LambdaUtil.withContextClassLoader(ClassLoader cl, SupplierWithException<R,E> s) Runs the given runnable with the given ClassLoader as the thread's context class loader.

Uses of SupplierWithException in org.apache.flink.util.concurrent

Methods in org.apache.flink.util.concurrent with parameters of type SupplierWithException

Modifier and Type	Method and Description
static <T> CompletableFuture<T>	FutureUtils.supplyAsync(SupplierWithException<T,?> supplier, Executor executor) Returns a future which is completed with the result of the SupplierWithException.

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

Subinterfaces of SupplierWithException in org.apache.flink.util.function

Modifier and Type	Interface and Description
interface	CheckedSupplier<R> Similar to Supplier but can throw Exception.
interface	SerializableSupplierWithException<T,E extends Throwable> A serializable SupplierWithException.

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

Modifier and Type	Method and Description
static <T> Supplier<T>	FunctionUtils.uncheckedSupplier(SupplierWithException<T,?> supplierWithException) Converts a SupplierWithException into a Supplier which throws all checked exceptions as unchecked.