class OffsetCheckpointMark implements CheckpointMark {

  @Override
  public void finalizeCheckpoint() throws IOException {
    if (!finalizer.isPresent()) {
      return;
    }
    try {
      finalizer.get().finalizeOffsets(partitionOffsetMap);
    } catch (StatusException e) {
      throw new IOException(e);
    }
  }

    OffsetCheckpointMark(OffsetFinalizer finalizer, Map<Partition, Offset> partitionOffsetMap);
  private  OffsetCheckpointMark(Map<Long, Long> encodedMap);

}