Field Detail

• METAFAMILY

  public static final byte[] METAFAMILY

• METAROW

  public static final byte[] METAROW

• COMPACTION

  public static final byte[] COMPACTION

• FLUSH

  public static final byte[] FLUSH

• REGION_EVENT

  public static final byte[] REGION_EVENT

• BULK_LOAD

  public static final byte[] BULK_LOAD

• EMPTY_WALEDIT

  public static final WALEdit EMPTY_WALEDIT

Constructor Detail

• WALEdit

  public WALEdit()

• WALEdit

  public WALEdit(boolean isReplay)

• WALEdit

  public WALEdit(int cellCount)

• WALEdit

  public WALEdit(int cellCount,
         boolean isReplay)

Method Detail

• isMetaEditFamily

  public static boolean isMetaEditFamily(byte[] f)

  Parameters:

  f -

  Returns:

  True is f is METAFAMILY

• isMetaEditFamily

  public static boolean isMetaEditFamily(Cell cell)

• isMetaEdit

  public boolean isMetaEdit()

• isReplay

  public boolean isReplay()

  Returns:

  True when current WALEdit is created by log replay. Replication skips WALEdits from replay.

• setCompressionContext

  public void setCompressionContext(CompressionContext compressionContext)

• add

  public WALEdit add(Cell cell)

• isEmpty

  public boolean isEmpty()

• size

  public int size()

• getCells

  public ArrayList<Cell> getCells()

• setCells

  @InterfaceAudience.Private
  public void setCells(ArrayList<Cell> cells)

  This is not thread safe. This will change the WALEdit and shouldn't be used unless you are sure that nothing else depends on the contents being immutable.

  Parameters:

  cells - the list of cells that this WALEdit now contains.

• getAndRemoveScopes

  public NavigableMap<byte[],Integer> getAndRemoveScopes()

• readFields

  public void readFields(DataInput in)
                  throws IOException

  Specified by:

  readFields in interface org.apache.hadoop.io.Writable

  Throws:

  IOException

• write

  public void write(DataOutput out)
             throws IOException

  Specified by:

  write in interface org.apache.hadoop.io.Writable

  Throws:

  IOException

• readFromCells

  public int readFromCells(Codec.Decoder cellDecoder,
                  int expectedCount)
                    throws IOException

  Reads WALEdit from cells.

  Parameters:

  cellDecoder - Cell decoder.

  expectedCount - Expected cell count.

  Returns:

  Number of KVs read.

  Throws:

  IOException

• heapSize

  public long heapSize()

  Specified by:

  heapSize in interface HeapSize

  Returns:

  Approximate 'exclusive deep size' of implementing object. Includes count of payload and hosting object sizings.

• estimatedSerializedSizeOf

  public long estimatedSerializedSizeOf()

• toString

  public String toString()

  Overrides:

  toString in class Object

• createFlushWALEdit

  public static WALEdit createFlushWALEdit(HRegionInfo hri,
                           org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor f)

• getFlushDescriptor

  public static org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor getFlushDescriptor(Cell cell)
                                                                                                 throws IOException

  Throws:

  IOException

• createRegionEventWALEdit

  public static WALEdit createRegionEventWALEdit(HRegionInfo hri,
                                 org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor regionEventDesc)

• getRegionEventDescriptor

  public static org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor getRegionEventDescriptor(Cell cell)
                                                                                                             throws IOException

  Throws:

  IOException

• createCompaction

  public static WALEdit createCompaction(HRegionInfo hri,
                         org.apache.hadoop.hbase.protobuf.generated.WALProtos.CompactionDescriptor c)

  Create a compaction WALEdit

  Parameters:

  c -

  Returns:

  A WALEdit that has c serialized as its value

• getRowForRegion

  public static byte[] getRowForRegion(HRegionInfo hri)

• getCompaction

  public static org.apache.hadoop.hbase.protobuf.generated.WALProtos.CompactionDescriptor getCompaction(Cell kv)
                                                                                                 throws IOException

  Deserialized and returns a CompactionDescriptor is the KeyValue contains one.

  Parameters:

  kv - the key value

  Returns:

  deserialized CompactionDescriptor or null.

  Throws:

  IOException

• isCompactionMarker

  public static boolean isCompactionMarker(Cell cell)

  Returns true if the given cell is a serialized WALProtos.CompactionDescriptor

  See Also:

  getCompaction(Cell)

• createBulkLoadEvent

  public static WALEdit createBulkLoadEvent(HRegionInfo hri,
                            org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor bulkLoadDescriptor)

  Create a bulk loader WALEdit

  Parameters:

  hri - The HRegionInfo for the region in which we are bulk loading

  bulkLoadDescriptor - The descriptor for the Bulk Loader

  Returns:

  The WALEdit for the BulkLoad

• getBulkLoadDescriptor

  public static org.apache.hadoop.hbase.protobuf.generated.WALProtos.BulkLoadDescriptor getBulkLoadDescriptor(Cell cell)
                                                                                                       throws IOException

  Deserialized and returns a BulkLoadDescriptor from the passed in Cell

  Parameters:

  cell - the key value

  Returns:

  deserialized BulkLoadDescriptor or null.

  Throws:

  IOException