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