org.apache.flink.runtime.state

Class TaskExecutorLocalStateStoresManager

java.lang.Object

org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager

public class TaskExecutorLocalStateStoresManager
extends Object

This class holds the all TaskLocalStateStoreImpl objects for a task executor (manager).

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALLOCATION_DIR_PREFIX

Constructor Summary

Constructors

Constructor and Description
TaskExecutorLocalStateStoresManager(boolean localRecoveryEnabled, Reference<File[]> localStateRootDirectories, Executor discardExecutor)

Method Summary

Modifier and Type	Method and Description
TaskLocalStateStore	localStateStoreForSubtask(JobID jobId, AllocationID allocationID, JobVertexID jobVertexID, int subtaskIndex)
void	releaseLocalStateForAllocationId(AllocationID allocationID)
void	retainLocalStateForAllocations(Set<AllocationID> allocationsToRetain) Retains the given set of allocations.
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ALLOCATION_DIR_PREFIX

public static final String ALLOCATION_DIR_PREFIX

See Also:

Constant Field Values

Constructor Detail

TaskExecutorLocalStateStoresManager

public TaskExecutorLocalStateStoresManager(boolean localRecoveryEnabled,
                                           @Nonnull
                                           Reference<File[]> localStateRootDirectories,
                                           @Nonnull
                                           Executor discardExecutor)
                                    throws IOException

Throws:

IOException

Method Detail

localStateStoreForSubtask

@Nonnull
public TaskLocalStateStore localStateStoreForSubtask(@Nonnull
                                                              JobID jobId,
                                                              @Nonnull
                                                              AllocationID allocationID,
                                                              @Nonnull
                                                              JobVertexID jobVertexID,
                                                              @Nonnegative
                                                              int subtaskIndex)

releaseLocalStateForAllocationId

public void releaseLocalStateForAllocationId(@Nonnull
                                             AllocationID allocationID)

retainLocalStateForAllocations

public void retainLocalStateForAllocations(Set<AllocationID> allocationsToRetain)

Retains the given set of allocations. All other allocations will be released.

Parameters:

allocationsToRetain -

shutdown

public void shutdown()