Uses of Class
org.apache.hadoop.hbase.wal.WAL.Entry

Packages that use WAL.Entry

Package	Description
org.apache.hadoop.hbase.mapreduce	Provides HBase MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods.
org.apache.hadoop.hbase.regionserver.wal
org.apache.hadoop.hbase.replication	Multi Cluster Replication
org.apache.hadoop.hbase.replication.regionserver
org.apache.hadoop.hbase.wal

Uses of WAL.Entry in org.apache.hadoop.hbase.mapreduce

Fields in org.apache.hadoop.hbase.mapreduce declared as WAL.Entry

Modifier and Type	Field and Description
(package private) WAL.Entry	WALInputFormat.WALRecordReader.currentEntry

Uses of WAL.Entry in org.apache.hadoop.hbase.regionserver.wal

Subclasses of WAL.Entry in org.apache.hadoop.hbase.regionserver.wal

Modifier and Type	Class and Description
(package private) class	FSWALEntry A WAL Entry for AbstractFSWAL implementation.

Methods in org.apache.hadoop.hbase.regionserver.wal that return WAL.Entry

Modifier and Type	Method and Description
WAL.Entry	ReaderBase.next()
WAL.Entry	ReaderBase.next(WAL.Entry reuse)

Methods in org.apache.hadoop.hbase.regionserver.wal with parameters of type WAL.Entry

Modifier and Type	Method and Description
void	AsyncProtobufLogWriter.append(WAL.Entry entry)
void	ProtobufLogWriter.append(WAL.Entry entry)
WAL.Entry	ReaderBase.next(WAL.Entry reuse)
private long	AbstractFSWAL.postAppend(WAL.Entry e, long elapsedTime)
protected abstract boolean	ReaderBase.readNext(WAL.Entry e) Read next entry.
protected boolean	ProtobufLogReader.readNext(WAL.Entry entry)

Uses of WAL.Entry in org.apache.hadoop.hbase.replication

Fields in org.apache.hadoop.hbase.replication with type parameters of type WAL.Entry

Modifier and Type	Field and Description
(package private) List<WAL.Entry>	ReplicationEndpoint.ReplicateContext.entries

Methods in org.apache.hadoop.hbase.replication that return WAL.Entry

Modifier and Type	Method and Description
WAL.Entry	WALEntryFilter.filter(WAL.Entry entry) Applies the filter, possibly returning a different Entry instance.
WAL.Entry	ClusterMarkingEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ScopeWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	SystemTableWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ChainWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	NamespaceTableCfWALEntryFilter.filter(WAL.Entry entry)

Methods in org.apache.hadoop.hbase.replication that return types with arguments of type WAL.Entry

Modifier and Type	Method and Description
List<WAL.Entry>	ReplicationEndpoint.ReplicateContext.getEntries()

Methods in org.apache.hadoop.hbase.replication with parameters of type WAL.Entry

Modifier and Type	Method and Description
WAL.Entry	WALEntryFilter.filter(WAL.Entry entry) Applies the filter, possibly returning a different Entry instance.
WAL.Entry	ClusterMarkingEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ScopeWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	SystemTableWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ChainWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	NamespaceTableCfWALEntryFilter.filter(WAL.Entry entry)
Cell	ScopeWALEntryFilter.filterCell(WAL.Entry entry, Cell cell)
Cell	WALCellFilter.filterCell(WAL.Entry entry, Cell cell) Applies the filter, possibly returning a different Cell instance.
Cell	NamespaceTableCfWALEntryFilter.filterCell(WAL.Entry entry, Cell cell)
private void	ChainWALEntryFilter.filterCells(WAL.Entry entry)

Method parameters in org.apache.hadoop.hbase.replication with type arguments of type WAL.Entry

Modifier and Type	Method and Description
ReplicationEndpoint.ReplicateContext	ReplicationEndpoint.ReplicateContext.setEntries(List<WAL.Entry> entries)

Uses of WAL.Entry in org.apache.hadoop.hbase.replication.regionserver

Fields in org.apache.hadoop.hbase.replication.regionserver declared as WAL.Entry

Modifier and Type	Field and Description
private WAL.Entry	WALEntryStream.currentEntry

Fields in org.apache.hadoop.hbase.replication.regionserver with type parameters of type WAL.Entry

Modifier and Type	Field and Description
private List<WAL.Entry>	RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable.entries
private List<Pair<WAL.Entry,Long>>	WALEntryBatch.walEntriesWithSize

Methods in org.apache.hadoop.hbase.replication.regionserver that return WAL.Entry

Modifier and Type	Method and Description
protected WAL.Entry	ReplicationSourceWALReader.filterEntry(WAL.Entry entry)
WAL.Entry	WALEntryStream.next() Returns the next WAL entry in this stream and advance the stream.
WAL.Entry	WALEntryStream.peek() Returns the next WAL entry in this stream but does not advance.

Methods in org.apache.hadoop.hbase.replication.regionserver that return types with arguments of type WAL.Entry

Modifier and Type	Method and Description
private List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.createBatches(List<WAL.Entry> entries) Divide the entries into multiple batches, so that we can replicate each batch in a thread pool concurrently.
private List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.createParallelBatches(List<WAL.Entry> entries)
private List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.createSerialBatches(List<WAL.Entry> entries)
(package private) List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.filterNotExistColumnFamilyEdits(List<List<WAL.Entry>> oldEntryList)
(package private) List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.filterNotExistTableEdits(List<List<WAL.Entry>> oldEntryList)
List<WAL.Entry>	WALEntryBatch.getWalEntries() Returns the WAL Entries.
List<Pair<WAL.Entry,Long>>	WALEntryBatch.getWalEntriesWithSize() Returns the WAL Entries.

Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type WAL.Entry

Modifier and Type	Method and Description
void	WALEntryBatch.addEntry(WAL.Entry entry, long entrySize)
protected boolean	ReplicationSourceWALReader.addEntryToBatch(WALEntryBatch batch, WAL.Entry entry)
private boolean	SerialReplicationChecker.canPush(WAL.Entry entry, byte[] row)
boolean	SerialReplicationChecker.canPush(WAL.Entry entry, Cell firstCellInEdit)
protected WAL.Entry	ReplicationSourceWALReader.filterEntry(WAL.Entry entry)
static long	ReplicationSourceWALReader.getEntrySizeExcludeBulkLoad(WAL.Entry entry)
private long	ReplicationSourceWALReader.getEntrySizeIncludeBulkLoad(WAL.Entry entry)
private int	HBaseInterClusterReplicationEndpoint.getEstimatedEntrySize(WAL.Entry e)
boolean	RegionReplicaReplicationEndpoint.RegionReplicaOutputSink.keepRegionEvent(WAL.Entry entry)
private void	ReplicationSourceWALReader.updateBatchStats(WALEntryBatch batch, WAL.Entry entry, long entrySize)
void	SerialReplicationChecker.waitUntilCanPush(WAL.Entry entry, Cell firstCellInEdit)

Method parameters in org.apache.hadoop.hbase.replication.regionserver with type arguments of type WAL.Entry

Modifier and Type	Method and Description
void	RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter.append(TableName tableName, byte[] encodedRegionName, byte[] row, List<WAL.Entry> entries)
private List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.createBatches(List<WAL.Entry> entries) Divide the entries into multiple batches, so that we can replicate each batch in a thread pool concurrently.
private List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.createParallelBatches(List<WAL.Entry> entries)
protected Callable<Integer>	HBaseInterClusterReplicationEndpoint.createReplicator(List<WAL.Entry> entries, int batchIndex, int timeout)
private List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.createSerialBatches(List<WAL.Entry> entries)
(package private) List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.filterNotExistColumnFamilyEdits(List<List<WAL.Entry>> oldEntryList)
(package private) List<List<WAL.Entry>>	HBaseInterClusterReplicationEndpoint.filterNotExistTableEdits(List<List<WAL.Entry>> oldEntryList)
private long	HBaseInterClusterReplicationEndpoint.parallelReplicate(CompletionService<Integer> pool, ReplicationEndpoint.ReplicateContext replicateContext, List<List<WAL.Entry>> batches)
void	ReplicationSourceInterface.postShipEdits(List<WAL.Entry> entries, int batchSize) Call this after the shipper thread ship some entries to peer cluster.
void	ReplicationSource.postShipEdits(List<WAL.Entry> entries, int batchSize)
protected int	HBaseInterClusterReplicationEndpoint.replicateEntries(List<WAL.Entry> entries, int batchIndex, int timeout)
private boolean	RegionReplicaReplicationEndpoint.RegionReplicaOutputSink.requiresReplication(TableName tableName, List<WAL.Entry> entries) returns true if the specified entry must be replicated.
private int	HBaseInterClusterReplicationEndpoint.serialReplicateRegionEntries(List<WAL.Entry> entries, int batchIndex, int timeout)
void	MetricsSource.updateTableLevelMetrics(List<Pair<WAL.Entry,Long>> walEntries) Update the table level replication metrics per table

Constructor parameters in org.apache.hadoop.hbase.replication.regionserver with type arguments of type WAL.Entry

Constructor and Description
RegionReplicaReplayCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, TableName tableName, HRegionLocation location, RegionInfo regionInfo, byte[] row, List<WAL.Entry> entries, AtomicLong skippedEntries)

Uses of WAL.Entry in org.apache.hadoop.hbase.wal

Fields in org.apache.hadoop.hbase.wal with type parameters of type WAL.Entry

Modifier and Type	Field and Description
(package private) List<WAL.Entry>	EntryBuffers.RegionEntryBuffer.entries

Methods in org.apache.hadoop.hbase.wal that return WAL.Entry

Modifier and Type	Method and Description
private WAL.Entry	WALSplitter.getNextLogLine(WAL.Reader in, org.apache.hadoop.fs.Path path, boolean skipErrors)
WAL.Entry	WAL.Reader.next()
WAL.Entry	WAL.Reader.next(WAL.Entry reuse)

Methods in org.apache.hadoop.hbase.wal that return types with arguments of type WAL.Entry

Modifier and Type	Method and Description
List<WAL.Entry>	EntryBuffers.RegionEntryBuffer.getEntries()

Methods in org.apache.hadoop.hbase.wal with parameters of type WAL.Entry

Modifier and Type	Method and Description
void	WALProvider.Writer.append(WAL.Entry entry)
void	WALProvider.AsyncWriter.append(WAL.Entry entry)
void	EntryBuffers.appendEntry(WAL.Entry entry) Append a log entry into the corresponding region buffer.
(package private) long	EntryBuffers.RegionEntryBuffer.appendEntry(WAL.Entry entry)
private void	AbstractRecoveredEditsOutputSink.RecoveredEditsWriter.filterCellByStore(WAL.Entry logEntry)
private void	EntryBuffers.RegionEntryBuffer.internify(WAL.Entry entry)
boolean	BoundedRecoveredHFilesOutputSink.keepRegionEvent(WAL.Entry entry)
boolean	AbstractRecoveredEditsOutputSink.keepRegionEvent(WAL.Entry entry)
protected abstract boolean	OutputSink.keepRegionEvent(WAL.Entry entry) Some WALEdit's contain only KV's for account on what happened to a region.
private void	AbstractRecoveredEditsOutputSink.RecoveredEditsWriter.logAndThrowWriterAppendFailure(WAL.Entry logEntry, IOException e)
WAL.Entry	WAL.Reader.next(WAL.Entry reuse)
(package private) void	AbstractRecoveredEditsOutputSink.updateRegionMaximumEditLogSeqNum(WAL.Entry entry) Update region's maximum edit log SeqNum.

Method parameters in org.apache.hadoop.hbase.wal with type arguments of type WAL.Entry

Modifier and Type	Method and Description
(package private) void	AbstractRecoveredEditsOutputSink.RecoveredEditsWriter.writeRegionEntries(List<WAL.Entry> entries)