public class EmbeddedJobResultStore extends AbstractThreadsafeJobResultStore
JobResultStore
.Constructor and Description |
---|
EmbeddedJobResultStore() |
Modifier and Type | Method and Description |
---|---|
void |
createDirtyResultInternal(JobResultEntry jobResultEntry) |
Set<JobResult> |
getDirtyResultsInternal() |
boolean |
hasCleanJobResultEntryInternal(JobID jobId) |
boolean |
hasDirtyJobResultEntryInternal(JobID jobId) |
void |
markResultAsCleanInternal(JobID jobId) |
createDirtyResult, getDirtyResults, hasCleanJobResultEntry, hasDirtyJobResultEntry, hasJobResultEntry, markResultAsClean
public void createDirtyResultInternal(JobResultEntry jobResultEntry)
createDirtyResultInternal
in class AbstractThreadsafeJobResultStore
public void markResultAsCleanInternal(JobID jobId) throws IOException, NoSuchElementException
markResultAsCleanInternal
in class AbstractThreadsafeJobResultStore
IOException
NoSuchElementException
public boolean hasDirtyJobResultEntryInternal(JobID jobId) throws IOException
hasDirtyJobResultEntryInternal
in class AbstractThreadsafeJobResultStore
IOException
public boolean hasCleanJobResultEntryInternal(JobID jobId) throws IOException
hasCleanJobResultEntryInternal
in class AbstractThreadsafeJobResultStore
IOException
public Set<JobResult> getDirtyResultsInternal() throws IOException
getDirtyResultsInternal
in class AbstractThreadsafeJobResultStore
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.