@Override
  public short getVersion() {
    return CHECKPOINT_VERSION;
  }
Constructs a new checkpoint based off a map of Samza stream offsets.

@param offsets Map of Samza streams to their current offset.
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java