org.apache.flink.runtime.jobmanager

Interface JobPersistenceComponentFactory

All Known Implementing Classes:

HaServicesJobPersistenceComponentFactory

public interface JobPersistenceComponentFactory

Factory for components that are responsible for persisting a job for recovery.

Method Summary

Modifier and Type	Method and Description
JobGraphStore	createJobGraphStore() Creates a JobGraphStore.
JobResultStore	createJobResultStore() Creates JobResultStore instances.

Method Detail

createJobGraphStore

JobGraphStore createJobGraphStore()

Creates a JobGraphStore.

Returns:

a JobGraphStore instance

createJobResultStore

JobResultStore createJobResultStore()

Creates JobResultStore instances.

Returns:

a JobResultStore instance.