Uses of Interface
org.apache.flink.runtime.dispatcher.ExecutionGraphInfoStore

Packages that use ExecutionGraphInfoStore

Package	Description
org.apache.flink.client.deployment.application
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.entrypoint
org.apache.flink.runtime.entrypoint.component

Uses of ExecutionGraphInfoStore in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application that return ExecutionGraphInfoStore

Modifier and Type	Method and Description
protected ExecutionGraphInfoStore	ApplicationClusterEntryPoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)

Uses of ExecutionGraphInfoStore in org.apache.flink.runtime.dispatcher

Classes in org.apache.flink.runtime.dispatcher that implement ExecutionGraphInfoStore

Modifier and Type	Class and Description
class	FileExecutionGraphInfoStore Store for ExecutionGraphInfo instances.
class	MemoryExecutionGraphInfoStore ExecutionGraphInfoStore implementation which stores the ArchivedExecutionGraph in memory.

Methods in org.apache.flink.runtime.dispatcher that return ExecutionGraphInfoStore

Modifier and Type	Method and Description
ExecutionGraphInfoStore	DispatcherServices.getArchivedExecutionGraphStore()
ExecutionGraphInfoStore	PartialDispatcherServices.getArchivedExecutionGraphStore()

Constructors in org.apache.flink.runtime.dispatcher with parameters of type ExecutionGraphInfoStore

Constructor and Description

PartialDispatcherServices(Configuration configuration, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroupFactory jobManagerMetricGroupFactory, ExecutionGraphInfoStore executionGraphInfoStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist, String metricQueryServiceAddress, Executor ioExecutor, DispatcherOperationCaches operationCaches, Collection<FailureEnricher> failureEnrichers)

Uses of ExecutionGraphInfoStore in org.apache.flink.runtime.entrypoint

Methods in org.apache.flink.runtime.entrypoint that return ExecutionGraphInfoStore

Modifier and Type	Method and Description
protected abstract ExecutionGraphInfoStore	ClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
protected ExecutionGraphInfoStore	JobClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor) Deprecated.
protected ExecutionGraphInfoStore	SessionClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)

Uses of ExecutionGraphInfoStore in org.apache.flink.runtime.entrypoint.component

Methods in org.apache.flink.runtime.entrypoint.component with parameters of type ExecutionGraphInfoStore

Modifier and Type	Method and Description
DispatcherResourceManagerComponent	DefaultDispatcherResourceManagerComponentFactory.create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, Collection<FailureEnricher> failureEnrichers, FatalErrorHandler fatalErrorHandler)
DispatcherResourceManagerComponent	DispatcherResourceManagerComponentFactory.create(Configuration configuration, ResourceID resourceId, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, Collection<FailureEnricher> failureEnrichers, FatalErrorHandler fatalErrorHandler)