
this.futures = new ArrayList<>();
</BUG>
this.buffer = new byte[4096];
<BUG>this.invalidMutations = new HashMap<>();
</BUG>
this.replayedCount = new AtomicInteger();
this.checksum = new PureJavaCrc32();
<BUG>cfPositions = new HashMap<>();
</BUG>
Ordering<ReplayPosition> replayPositionOrdering = Ordering.from(ReplayPosition.comparator);

private final ReplayPosition globalPosition;
private final PureJavaCrc32 checksum;
private byte[] buffer;
public CommitLogReplayer()
{
this.keyspacesRecovered = new NonBlockingHashSet<Keyspace>();
this.futures = new ArrayList<Future<?>>();
this.buffer = new byte[4096];
this.invalidMutations = new HashMap<UUID, AtomicInteger>();
this.replayedCount = new AtomicInteger();
this.checksum = new PureJavaCrc32();
cfPositions = new HashMap<UUID, ReplayPosition>();
Ordering<ReplayPosition> replayPositionOrdering = Ordering.from(ReplayPosition.comparator);
