InMemoryCheckpointHandler

public class InMemoryCheckpointHandler extends Object
implements CheckpointHandler

CheckpointHandler implementation to maintain in-memory checkpoint values.

Public Constructor Summary

Public Method Summary

synchronized byte[]
readCheckpoint(String checkpointName)
Read current value of saved checkpoint.
synchronized void
saveCheckpoint(String checkpointName, byte[] checkpoint)
Saves checkpoint value.

Inherited Method Summary

Public Constructors

public InMemoryCheckpointHandler ()

Public Methods

public synchronized byte[] readCheckpoint (String checkpointName)

Read current value of saved checkpoint.

Parameters
checkpointName the name of the checkpoint to read
Returns
  • current value of checkpoint. null if checkpoint is empty or not available
Throws
IOException

public synchronized void saveCheckpoint (String checkpointName, byte[] checkpoint)

Saves checkpoint value.

Parameters
checkpointName the name of the checkpoint to save
checkpoint value to save
Throws
IOException

Send feedback about...

Cloud Search
Cloud Search