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

Packages that use WAL.Entry

Package	Description
org.apache.hadoop.hbase.client	Provides HBase Client
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.client

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

Modifier and Type	Field	Description
private final WAL.Entry[]	AsyncRegionReplicationRetryingCaller.entries

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

Modifier and Type	Method	Description
CompletableFuture<Void>	AsyncClusterConnection.replicate(RegionInfo replica, List<WAL.Entry> entries, int numRetries, long rpcTimeoutNs, long operationTimeoutNs)	Replicate wal edits to a secondary replica.
CompletableFuture<Void>	AsyncClusterConnectionImpl.replicate(RegionInfo replica, List<WAL.Entry> entries, int retries, long rpcTimeoutNs, long operationTimeoutNs)

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

Modifier	Constructor	Description
	AsyncRegionReplicationRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer, AsyncClusterConnectionImpl conn, int maxAttempts, long rpcTimeoutNs, long operationTimeoutNs, RegionInfo replica, List<WAL.Entry> entries)

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	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	Description
(package private) class	FSWALEntry	A WAL Entry for AbstractFSWAL implementation.

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

Modifier and Type	Field	Description
(package private) final WAL.Entry	ProtobufWALTailingReader.ReadWALKeyResult.entry

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

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

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

Modifier and Type	Method	Description
void	AsyncProtobufLogWriter.append(WAL.Entry entry)
void	CombinedAsyncWriter.append(WAL.Entry entry)
void	CombinedWriter.append(WAL.Entry entry)
void	ProtobufLogWriter.append(WAL.Entry entry)
WAL.Entry	ProtobufWALStreamReader.next(WAL.Entry reuse)
private long	AbstractFSWAL.postAppend(WAL.Entry e, long elapsedTime)
private WALTailingReader.Result	ProtobufWALTailingReader.readWALEdit(WAL.Entry entry, int followingKvCount)

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

Modifier	Constructor	Description
	ReadWALKeyResult(WALTailingReader.State state, WAL.Entry entry, int followingKvCount)

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	Description
(package private) List<WAL.Entry>	ReplicationEndpoint.ReplicateContext.entries

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

Modifier and Type	Method	Description
protected final WAL.Entry	WALEntryFilterBase.clearOrNull(WAL.Entry entry)	Call this method when you do not need to replicate the entry.
WAL.Entry	ChainWALEmptyEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ChainWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ClusterMarkingEntryFilter.filter(WAL.Entry entry)
WAL.Entry	NamespaceTableCfWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ScopeWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	SystemTableWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	WALEntryFilter.filter(WAL.Entry entry)	Applies the filter, possibly returning a different Entry instance.
protected WAL.Entry	ChainWALEntryFilter.filterEntry(WAL.Entry entry)

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

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

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

Modifier and Type	Method	Description
protected final WAL.Entry	WALEntryFilterBase.clearOrNull(WAL.Entry entry)	Call this method when you do not need to replicate the entry.
WAL.Entry	ChainWALEmptyEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ChainWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ClusterMarkingEntryFilter.filter(WAL.Entry entry)
WAL.Entry	NamespaceTableCfWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	ScopeWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	SystemTableWALEntryFilter.filter(WAL.Entry entry)
WAL.Entry	WALEntryFilter.filter(WAL.Entry entry)	Applies the filter, possibly returning a different Entry instance.
private Cell	ChainWALEntryFilter.filterCell(WAL.Entry entry, Cell cell)
Cell	NamespaceTableCfWALEntryFilter.filterCell(WAL.Entry entry, Cell cell)
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.
protected void	ChainWALEntryFilter.filterCells(WAL.Entry entry)
protected WAL.Entry	ChainWALEntryFilter.filterEntry(WAL.Entry entry)

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

Modifier and Type	Method	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	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	Description
private List<Pair<WAL.Entry,Long>>	WALEntryBatch.walEntriesWithSize

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

Modifier and Type	Method	Description
protected final 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	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.
private List<WAL.Entry>	ReplaySyncReplicationWALCallable.readWALEntries(WALStreamReader reader, String wal)

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

Modifier and Type	Method	Description
(package private) boolean	ReplicationSourceManager.acquireWALEntryBufferQuota(WALEntryBatch walEntryBatch, WAL.Entry entry)	Acquire the buffer quota for WAL.Entry which is added to WALEntryBatch.
void	WALEntryBatch.addEntry(WAL.Entry entry, long entrySize)
protected final 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)
private boolean	ReplaySyncReplicationWALCallable.filter(WAL.Entry entry)
protected final WAL.Entry	ReplicationSourceWALReader.filterEntry(WAL.Entry entry)
(package private) static long	WALEntryBatch.getEntrySizeExcludeBulkLoad(WAL.Entry entry)
private long	ReplicationSourceWALReader.getEntrySizeIncludeBulkLoad(WAL.Entry entry)
private int	HBaseInterClusterReplicationEndpoint.getEstimatedEntrySize(WAL.Entry e)
long	WALEntryBatch.incrementUsedBufferSize(WAL.Entry entry)
private void	SerialReplicationSourceWALReader.removeEntryFromStream(WAL.Entry entry, WALEntryStream entryStream, WALEntryBatch batch)
private void	ReplicationSourceWALReader.updateBatchStats(WALEntryBatch batch, WAL.Entry entry, long entrySize)
private void	ReplicationSourceWALReader.updateReplicationMarkerEdit(WAL.Entry entry, long offset)
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	Description
protected CompletableFuture<Integer>	HBaseInterClusterReplicationEndpoint.asyncReplicate(List<WAL.Entry> entries, int batchIndex, int timeout)	Replicate entries to peer cluster by async API.
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)
private long	HBaseInterClusterReplicationEndpoint.parallelReplicate(ReplicationEndpoint.ReplicateContext replicateContext, List<List<WAL.Entry>> batches)
void	ReplicationSource.postShipEdits(List<WAL.Entry> entries, long batchSize)
void	ReplicationSourceInterface.postShipEdits(List<WAL.Entry> entries, long batchSize)	Call this after the shipper thread ship some entries to peer cluster.
protected CompletableFuture<Integer>	HBaseInterClusterReplicationEndpoint.replicateEntries(List<WAL.Entry> entries, int batchIndex, int timeout)
private CompletableFuture<Integer>	HBaseInterClusterReplicationEndpoint.serialReplicateRegionEntries(org.apache.hbase.thirdparty.com.google.common.collect.PeekingIterator<WAL.Entry> walEntryPeekingIterator, int batchIndex, int timeout)	Here for HBaseInterClusterReplicationEndpoint#isSerialis is true, we iterator over the WAL WAL.Entry list, once we reached a batch limit, we send it out, and in the callback, we send the next batch, until we send all entries out.
void	MetricsSource.updateTableLevelMetrics(List<Pair<WAL.Entry,Long>> walEntries)	Update the table level replication metrics per table

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

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

Modifier and Type	Field	Description
private final WAL.Entry	WALTailingReader.Result.entry

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

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

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

Modifier and Type	Method	Description
WAL.Entry	WALTailingReader.Result.getEntry()
private WAL.Entry	WALSplitter.getNextLogLine(WALStreamReader in, org.apache.hadoop.fs.Path path, boolean skipErrors)
default WAL.Entry	WALStreamReader.next()	Read the next entry in WAL.
WAL.Entry	WALStreamReader.next(WAL.Entry reuse)	Read the next entry in WAL, use the given WAL.Entry if not null to hold the data.

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

Modifier and Type	Method	Description
void	WALProvider.AsyncWriter.append(WAL.Entry entry)
void	WALProvider.Writer.append(WAL.Entry entry)
(package private) 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	AbstractRecoveredEditsOutputSink.keepRegionEvent(WAL.Entry entry)
(package private) boolean	BoundedRecoveredHFilesOutputSink.keepRegionEvent(WAL.Entry entry)
(package private) 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	WALStreamReader.next(WAL.Entry reuse)	Read the next entry in WAL, use the given WAL.Entry if not null to hold the data.
(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	Description
(package private) void	AbstractRecoveredEditsOutputSink.RecoveredEditsWriter.writeRegionEntries(List<WAL.Entry> entries)

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

Modifier	Constructor	Description
	Result(WALTailingReader.State state, WAL.Entry entry, long entryEndPos)