Package org.elasticsearch.gateway
Class PersistedClusterStateService.Writer
java.lang.Object
org.elasticsearch.gateway.PersistedClusterStateService.Writer
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
- Enclosing class:
- PersistedClusterStateService
public static class PersistedClusterStateService.Writer
extends java.lang.Object
implements java.io.Closeable
-
Method Summary
Modifier and Type Method Description void
close()
boolean
isOpen()
void
writeFullStateAndCommit(long currentTerm, ClusterState clusterState)
Overrides and commits the given current term and cluster statevoid
writeIncrementalTermUpdateAndCommit(long currentTerm, long lastAcceptedVersion)
-
Method Details
-
isOpen
public boolean isOpen() -
writeFullStateAndCommit
public void writeFullStateAndCommit(long currentTerm, ClusterState clusterState) throws java.io.IOExceptionOverrides and commits the given current term and cluster state- Throws:
java.io.IOException
-
writeIncrementalTermUpdateAndCommit
public void writeIncrementalTermUpdateAndCommit(long currentTerm, long lastAcceptedVersion) throws java.io.IOException- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-