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	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	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
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.

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
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.
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.
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	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 final 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	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.

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)
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)
boolean	RegionReplicaReplicationEndpoint.RegionReplicaOutputSink.keepRegionEvent(WAL.Entry entry)
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
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	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 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

Modifier	Constructor	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 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.entries

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 that return types with arguments of type WAL.Entry

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

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)
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)
boolean	BoundedRecoveredHFilesOutputSink.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	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)