private WALEntryBatch |
ReplicationSourceWALReader.createBatch(WALEntryStream entryStream) |
protected void |
SerialReplicationSourceWALReader.readWALEntries(WALEntryStream entryStream,
WALEntryBatch batch) |
protected void |
ReplicationSourceWALReader.readWALEntries(WALEntryStream entryStream,
WALEntryBatch batch) |
private void |
SerialReplicationSourceWALReader.removeEntryFromStream(WALEntryStream entryStream,
WALEntryBatch batch) |
protected static boolean |
ReplicationSourceWALReader.switched(WALEntryStream entryStream,
org.apache.hadoop.fs.Path path) |
private WALEntryBatch |
ReplicationSourceWALReader.tryAdvanceStreamAndCreateWALBatch(WALEntryStream entryStream) |