Package org.apache.flink.runtime.highavailability.nonha.embedded

Class EmbeddedJobResultStore

java.lang.Object

org.apache.flink.runtime.highavailability.AbstractThreadsafeJobResultStore

org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedJobResultStore

All Implemented Interfaces:

JobResultStore

public class EmbeddedJobResultStore
extends AbstractThreadsafeJobResultStore

A thread-safe in-memory implementation of the JobResultStore.

Constructor Summary

Constructors

Constructor	Description
EmbeddedJobResultStore()

Method Summary

Modifier and Type	Method	Description
void	createDirtyResultInternal(JobResultEntry jobResultEntry)
Set<JobResult>	getDirtyResultsInternal()
boolean	hasCleanJobResultEntryInternal(org.apache.flink.api.common.JobID jobId)
boolean	hasDirtyJobResultEntryInternal(org.apache.flink.api.common.JobID jobId)
void	markResultAsCleanInternal(org.apache.flink.api.common.JobID jobId)

Methods inherited from class org.apache.flink.runtime.highavailability.AbstractThreadsafeJobResultStore

createDirtyResult, getDirtyResults, hasCleanJobResultEntry, hasDirtyJobResultEntry, hasJobResultEntry, markResultAsClean

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedJobResultStore

public EmbeddedJobResultStore()

Method Detail

createDirtyResultInternal

public void createDirtyResultInternal(JobResultEntry jobResultEntry)

Specified by:

createDirtyResultInternal in class AbstractThreadsafeJobResultStore

markResultAsCleanInternal

public void markResultAsCleanInternal(org.apache.flink.api.common.JobID jobId)
                               throws IOException,
                                      NoSuchElementException

Specified by:

markResultAsCleanInternal in class AbstractThreadsafeJobResultStore

Throws:

IOException

NoSuchElementException

hasDirtyJobResultEntryInternal

public boolean hasDirtyJobResultEntryInternal(org.apache.flink.api.common.JobID jobId)
                                       throws IOException

Specified by:

hasDirtyJobResultEntryInternal in class AbstractThreadsafeJobResultStore

Throws:

IOException

hasCleanJobResultEntryInternal

public boolean hasCleanJobResultEntryInternal(org.apache.flink.api.common.JobID jobId)
                                       throws IOException

Specified by:

hasCleanJobResultEntryInternal in class AbstractThreadsafeJobResultStore

Throws:

IOException

getDirtyResultsInternal

public Set<JobResult> getDirtyResultsInternal()
                                       throws IOException

Specified by:

getDirtyResultsInternal in class AbstractThreadsafeJobResultStore

Throws:

IOException