Uses of Interface
org.apache.hadoop.hbase.Cell
Packages that use Cell
Package
Description
Provides HBase Client
Provides client classes for invoking Coprocessor RPC protocols
Overview
Example Usage
Table of Contents
Provides row-level filters applied to HRegion scan results during calls to
ResultScanner.next().Provides implementations of
HFile and HFile
BlockCache.Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
Multi Cluster Replication
HBase REST
Provides an HBase Thrift
service.
Provides an HBase Thrift
service.
-
Uses of Cell in org.apache.hadoop.hbase
Subinterfaces of Cell in org.apache.hadoop.hbaseModifier and TypeInterfaceDescriptioninterfaceExtension toCellwith server side required functions.interfaceAn extended version of Cell that allows CPs manipulate Tags.Classes in org.apache.hadoop.hbase that implement CellModifier and TypeClassDescriptionclassThis class is a server side extension to theCellinterface.classThis is a key only Cell implementation which is identical toKeyValue.KeyOnlyKeyValuewith respect to key serialization but have its data in the form of Byte buffer (onheap and offheap).classThis Cell is an implementation ofByteBufferExtendedCellwhere the data resides in off heap/ on heap ByteBufferclassclassAn HBase Key/Value.static classA simple form of KeyValue that creates a keyvalue with only the key part of the byte[] Mainly used in places where we need to compare two cells.classAn extension of the ByteBufferKeyValue where the tags length is always 0classAn extension of the KeyValue where the tags length is always 0private static classThese cells are used in reseeks/seeks to improve the read performance.private static classThese cells are used in reseeks/seeks to improve the read performance.private static classprivate static classprivate static classprivate static classprivate static classprivate static classprivate static classprivate static classprivate static classprivate static classprivate static class(package private) static class(package private) static classThis can be used when a Cell has to change with addition/removal of one or more tags.(package private) static class(package private) static classclassThis Cell is an implementation ofByteBufferExtendedCellwhere the data resides in off heap/ on heap ByteBufferclassThis class is an extension to KeyValue where rowLen and keyLen are cached.classThis Cell is an implementation ofByteBufferExtendedCellwhere the data resides in off heap/ on heap ByteBufferclassThis class is an extension to ContentSizeCachedKeyValue where there are no tags in Cell.Fields in org.apache.hadoop.hbase declared as CellMethods in org.apache.hadoop.hbase that return CellModifier and TypeMethodDescriptionCellBuilder.build()static CellCellUtil.cloneIfNecessary(Cell cell) static CellCellUtil.createCell(byte[] row) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] row, byte[] value) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] row, byte[] family, byte[] qualifier) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] row, byte[] family, byte[] qualifier, long timestamp, byte type, byte[] value) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] row, byte[] family, byte[] qualifier, long timestamp, byte type, byte[] value, byte[] tags, long memstoreTS) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] row, byte[] family, byte[] qualifier, long timestamp, byte type, byte[] value, long memstoreTS) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] row, byte[] family, byte[] qualifier, long timestamp, KeyValue.Type type, byte[] value, byte[] tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(byte[] rowArray, int rowOffset, int rowLength, byte[] familyArray, int familyOffset, int familyLength, byte[] qualifierArray, int qualifierOffset, int qualifierLength) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(Cell cell, byte[] tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(Cell cell, byte[] value, byte[] tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(Cell cell, List<Tag> tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellPrivateCellUtil.createCell(Cell cell, byte[] tags) Returns A new cell which is having the extra tags also added to it.static CellPrivateCellUtil.createCell(Cell cell, byte[] value, byte[] tags) static CellPrivateCellUtil.createCell(Cell cell, List<Tag> tags) Returns A new cell which is having the extra tags also added to it.static CellRawCell.createCell(Cell cell, List<Tag> tags) Returns A new cell which is having the extra tags also added to it.static CellPrivateCellUtil.createFirstDeleteFamilyCellOnRow(byte[] row, byte[] fam) Create a Delete Family Cell for the specified row and family that would be smaller than all other possible Delete Family KeyValues that have the same row and family.static CellPrivateCellUtil.createFirstOnNextRow(Cell cell) static CellPrivateCellUtil.createFirstOnRow(byte[] row) static CellPrivateCellUtil.createFirstOnRow(byte[] row, byte[] family, byte[] col) static CellPrivateCellUtil.createFirstOnRow(byte[] row, int roffset, short rlength) static CellPrivateCellUtil.createFirstOnRow(byte[] row, int roffset, short rlength, byte[] family, int foffset, byte flength, byte[] col, int coffset, int clength) static CellPrivateCellUtil.createFirstOnRow(Cell cell) Create a Cell that is smaller than all other possible Cells for the given Cell's row.static CellPrivateCellUtil.createFirstOnRowCol(Cell cell) static CellPrivateCellUtil.createFirstOnRowCol(Cell cell, byte[] qArray, int qoffest, int qlength) Create a Cell that is smaller than all other possible Cells for the given Cell's rk:cf and passed qualifier.static CellPrivateCellUtil.createFirstOnRowColTS(Cell cell, long ts) Creates the first cell with the row/family/qualifier of this cell and the given timestamp.static CellPrivateCellUtil.createFirstOnRowFamily(Cell cell, byte[] fArray, int foff, int flen) static CellPrivateCellUtil.createLastOnRow(byte[] row) static CellPrivateCellUtil.createLastOnRow(Cell cell) Create a Cell that is larger than all other possible Cells for the given Cell's row.static CellPrivateCellUtil.createLastOnRowCol(Cell cell) Create a Cell that is larger than all other possible Cells for the given Cell's rk:cf:q.static CellPrivateCellUtil.createNextOnRowCol(Cell cell) Return a new cell is located following input cell.(package private) static CellPrivateCellUtil.createNextOnRowCol(Cell cell, long ts, byte type) CellScanner.current()Returns the current Cell which may be mutablestatic CellDeep clones the given cell if the cell supports deep cloningMethods in org.apache.hadoop.hbase that return types with arguments of type CellModifier and TypeMethodDescriptionCellComparator.getSimpleComparator()Return a dumbed-down, fast comparator for hbase2 base-type, theByteBufferKeyValue.Methods in org.apache.hadoop.hbase with parameters of type CellModifier and TypeMethodDescriptionstatic intKeyValueUtil.appendKeyTo(Cell cell, byte[] output, int offset) static intKeyValueUtil.appendKeyTo(Cell cell, ByteBuffer buf, int offset) static intKeyValueUtil.appendTo(Cell cell, ByteBuffer buf, int offset, boolean withTags) Copy the Cell content into the passed buf in KeyValue serialization format.static intKeyValueUtil.appendToByteArray(Cell cell, byte[] output, int offset, boolean withTags) copy key and valueprivate intKeyValue.calculateHashForKey(Cell cell) TagUtil.carryForwardTags(List<Tag> tagsOrNull, Cell cell) Add totagsOrNullany Tagscellis carrying or null if none.TagUtil.carryForwardTags(Cell cell) Returns A List<Tag> of any Tags found incellelse null.static byte[]CellUtil.cloneFamily(Cell cell) static CellCellUtil.cloneIfNecessary(Cell cell) static byte[]CellUtil.cloneQualifier(Cell cell) static byte[]get individual arrays for testsstatic byte[]Deprecated.As of HBase-2.0.static byte[]static byte[]CellUtil.cloneValue(Cell cell) intLexographically compares two cells.intCompare cells.final intintstatic final intCellUtil.compare(CellComparator comparator, Cell left, byte[] key, int offset, int length) Deprecated.As of HBase-2.0.intDeprecated.Compares the Key of a cell -- with fields being more significant in this order: rowkey, colfam/qual, timestamp, type, mvccintDeprecated.Compare key portion of aKeyValuefor keys inhbase:metatable.intstatic final intPrivateCellUtil.compare(CellComparator comparator, Cell left, byte[] key, int offset, int length) Used when a cell needs to be compared with a key byte[] such as cases of finding the index from the index block, bloom keys from the bloom blocks This byte[] is expected to be serialized in the KeyValue serialization format If the KeyValue (Cell's) serialization format changes this method cannot be used.private intCellComparatorImpl.compareColumns(Cell left, int leftFamLen, int leftQualLen, Cell right, int rightFamLen, int rightQualLen) final intCellComparatorImpl.compareColumns(Cell left, Cell right) Compares the family and qualifier part of the cellstatic final intCellUtil.compareColumns(Cell left, byte[] right, int rfoffset, int rflength, int rqoffset, int rqlength) Compares the cell's column (family and qualifier) with the given byte[](package private) intKeyValue.KVComparator.compareColumns(Cell left, short lrowlength, Cell right, short rrowlength) Deprecated.intCellComparator.compareFamilies(Cell leftCell, Cell rightCell) Lexicographically compares the families of the two cellsprotected intCellComparatorImpl.compareFamilies(Cell left, int leftFamLen, Cell right, int rightFamLen) This method will be overridden when we compare cells inner store to bypass family comparing.final intCellComparatorImpl.compareFamilies(Cell left, Cell right) Compare the families of left and right cellstatic final intCellUtil.compareFamilies(Cell left, byte[] right, int roffset, int rlength) Compares the cell's family with the given byte[]protected intInnerStoreCellComparator.compareFamilies(Cell left, int leftFamilyLength, Cell right, int rightFamilyLength) static intPrivateCellUtil.compareFamily(Cell cell, ByteArrayComparable comparator) Compare cell's column family against given comparatorintKeyValue.KVComparator.compareKey(Cell cell, byte[] row, int roff, int rlen, byte[] fam, int foff, int flen, byte[] col, int coff, int clen, long ts, byte type) Deprecated.static final intPrivateCellUtil.compareKeyBasedOnColHint(CellComparator comparator, Cell nextIndexedCell, Cell currentCell, int foff, int flen, byte[] colHint, int coff, int clen, long ts, byte type) Used to compare two cells based on the column hint provided.static final intPrivateCellUtil.compareKeyIgnoresMvcc(CellComparator comparator, Cell left, Cell right) Compares only the key portion of a cell.intKeyValue.KVComparator.compareOnlyKeyPortion(Cell left, Cell right) Deprecated.intKeyValue.MetaComparator.compareOnlyKeyPortion(Cell left, Cell right) Deprecated.static intPrivateCellUtil.compareQualifier(Cell cell, ByteArrayComparable comparator) Compare cell's qualifier against given comparatorintCellComparator.compareQualifiers(Cell leftCell, Cell rightCell) Lexicographically compares the qualifiers of the two cellsprivate final intCellComparatorImpl.compareQualifiers(Cell left, int leftQualLen, Cell right, int rightQualLen) final intCellComparatorImpl.compareQualifiers(Cell left, Cell right) Compare the qualifiers part of the left and right cells.static final intCellUtil.compareQualifiers(Cell left, byte[] right, int rOffset, int rLength) Compares the cell's qualifier with the given byte[]static intPrivateCellUtil.compareRow(Cell cell, ByteArrayComparable comparator) Compare cell's row against given comparatorprotected intKeyValue.KVComparator.compareRowKey(Cell left, Cell right) Deprecated.Compares the only the user specified portion of a Key.protected intKeyValue.MetaComparator.compareRowKey(Cell l, Cell r) Deprecated.Override the row key comparison to parse and compare the meta row key parts.default intCellComparator.compareRows(ByteBuffer row, Cell cell) Lexicographically compare two rowsintCellComparator.compareRows(Cell cell, byte[] bytes, int offset, int length) Compares the row part of the cell with a simple plain byte[] like the stopRow in Scan.intCellComparator.compareRows(Cell leftCell, Cell rightCell) Lexographically compares the rows of two cells.intCellComparatorImpl.compareRows(Cell left, byte[] right, int roffset, int rlength) Compares the row part of the cell with a simple plain byte[] like the stopRow in Scan.(package private) static intCellComparatorImpl.compareRows(Cell left, int leftRowLength, Cell right, int rightRowLength) intCellComparatorImpl.compareRows(Cell left, Cell right) Compares the rows of the left and right cell.intKeyValue.KVComparator.compareRows(Cell left, Cell right) Deprecated.Compares the rows of a cellintMetaCellComparator.compareRows(ByteBuffer row, Cell cell) intMetaCellComparator.compareRows(Cell left, byte[] right, int roffset, int rlength) intMetaCellComparator.compareRows(Cell left, Cell right) intCellComparator.compareTimestamps(Cell leftCell, Cell rightCell) Compares cell's timestamps in DESCENDING order.intCellComparatorImpl.compareTimestamps(Cell left, Cell right) intKeyValue.KVComparator.compareTimestamps(Cell left, Cell right) Deprecated.static intPrivateCellUtil.compareValue(Cell cell, ByteArrayComparable comparator) Compare cell's value against given comparatorintCellComparator.compareWithoutRow(Cell leftCell, Cell rightCell) Lexicographically compares the two cells excluding the row part.final intCellComparatorImpl.compareWithoutRow(Cell left, Cell right) (package private) static final intPrivateCellUtil.compareWithoutRow(CellComparator comparator, Cell left, byte[] right, int roffset, int rlength, short rowlength) Compare columnFamily, qualifier, timestamp, and key type (everything except the row).static voidPrivateCellUtil.compressFamily(OutputStream out, Cell cell, Dictionary dict) static voidPrivateCellUtil.compressQualifier(OutputStream out, Cell cell, Dictionary dict) static voidPrivateCellUtil.compressRow(OutputStream out, Cell cell, Dictionary dict) static voidPrivateCellUtil.compressTags(OutputStream out, Cell cell, TagCompressionContext tagCompressionContext) Compresses the tags to the given outputstream using the TagcompressionContextstatic byte[]TagUtil.concatTags(byte[] tags, Cell cell) static intCellUtil.copyFamilyTo(Cell cell, byte[] destination, int destinationOffset) Copies the family to the given byte[]static intCellUtil.copyFamilyTo(Cell cell, ByteBuffer destination, int destinationOffset) Copies the family to the given bytebufferstatic ByteBufferKeyValueUtil.copyKeyToNewByteBuffer(Cell cell) The position will be set to the beginning of the new ByteBufferstatic intCellUtil.copyQualifierTo(Cell cell, byte[] destination, int destinationOffset) Copies the qualifier to the given byte[]static intCellUtil.copyQualifierTo(Cell cell, ByteBuffer destination, int destinationOffset) Copies the qualifier to the given bytebufferstatic byte[]Copies the row to a new byte[]static intCopies the row to the given byte[]static intCellUtil.copyRowTo(Cell cell, ByteBuffer destination, int destinationOffset) Copies the row to the given bytebufferstatic intPrivateCellUtil.copyTagsTo(Cell cell, byte[] destination, int destinationOffset) Copies the tags info into the tag portion of the cellstatic intPrivateCellUtil.copyTagsTo(Cell cell, ByteBuffer destination, int destinationOffset) Copies the tags info into the tag portion of the cellstatic intDeprecated.As of HBase-2.0.static intCellUtil.copyTagTo(Cell cell, ByteBuffer destination, int destinationOffset) Deprecated.As of HBase-2.0.static byte[]KeyValueUtil.copyToNewByteArray(Cell cell) static KeyValueKeyValueUtil.copyToNewKeyValue(Cell cell) copy the cell to create a new keyvaluestatic intCellUtil.copyValueTo(Cell cell, byte[] destination, int destinationOffset) Copies the value to the given byte[]static intCellUtil.copyValueTo(Cell cell, ByteBuffer destination, int destinationOffset) Copies the value to the given bytebufferstatic CellCellUtil.createCell(Cell cell, byte[] tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(Cell cell, byte[] value, byte[] tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellCellUtil.createCell(Cell cell, List<Tag> tags) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static CellPrivateCellUtil.createCell(Cell cell, byte[] tags) Returns A new cell which is having the extra tags also added to it.static CellPrivateCellUtil.createCell(Cell cell, byte[] value, byte[] tags) static CellPrivateCellUtil.createCell(Cell cell, List<Tag> tags) Returns A new cell which is having the extra tags also added to it.static CellRawCell.createCell(Cell cell, List<Tag> tags) Returns A new cell which is having the extra tags also added to it.static CellScannerCellUtil.createCellScanner(Cell[] cellArray) Returns CellScanner interface overcellArraystatic CellPrivateCellUtil.createFirstOnNextRow(Cell cell) static CellPrivateCellUtil.createFirstOnRow(Cell cell) Create a Cell that is smaller than all other possible Cells for the given Cell's row.static CellPrivateCellUtil.createFirstOnRowCol(Cell cell) static CellPrivateCellUtil.createFirstOnRowCol(Cell cell, byte[] qArray, int qoffest, int qlength) Create a Cell that is smaller than all other possible Cells for the given Cell's rk:cf and passed qualifier.static CellPrivateCellUtil.createFirstOnRowColTS(Cell cell, long ts) Creates the first cell with the row/family/qualifier of this cell and the given timestamp.static CellPrivateCellUtil.createFirstOnRowFamily(Cell cell, byte[] fArray, int foff, int flen) static CellPrivateCellUtil.createLastOnRow(Cell cell) Create a Cell that is larger than all other possible Cells for the given Cell's row.static CellPrivateCellUtil.createLastOnRowCol(Cell cell) Create a Cell that is larger than all other possible Cells for the given Cell's rk:cf:q.static CellPrivateCellUtil.createNextOnRowCol(Cell cell) Return a new cell is located following input cell.(package private) static CellPrivateCellUtil.createNextOnRowCol(Cell cell, long ts, byte type) static CellDeep clones the given cell if the cell supports deep cloningstatic KeyValueKeyValueUtil.ensureKeyValue(Cell cell) Deprecated.without any replacement.static booleanequalsstatic booleanCellUtil.equalsIgnoreMvccVersion(Cell a, Cell b) Deprecated.As of HBase-2.0.static booleanPrivateCellUtil.equalsIgnoreMvccVersion(Cell a, Cell b) special case for Cell.equalsstatic longCellUtil.estimatedHeapSizeOf(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static intCellUtil.estimatedSerializedSizeOf(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static intPrivateCellUtil.estimatedSerializedSizeOf(Cell cell) Estimate based on keyvalue's serialization format in the RPC layer.static intCellUtil.estimatedSerializedSizeOfKey(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static intPrivateCellUtil.estimatedSerializedSizeOfKey(Cell cell) Calculates the serialized key size.static ByteRangeCellUtil.fillFamilyRange(Cell cell, ByteRange range) Deprecated.As of HBase-2.0.static ByteRangePrivateCellUtil.fillFamilyRange(Cell cell, ByteRange range) static ByteRangeCellUtil.fillQualifierRange(Cell cell, ByteRange range) Deprecated.As of HBase-2.0.static ByteRangePrivateCellUtil.fillQualifierRange(Cell cell, ByteRange range) static ByteRangeCellUtil.fillRowRange(Cell cell, ByteRange range) Deprecated.As of HBase-2.0.static ByteRangePrivateCellUtil.fillRowRange(Cell cell, ByteRange range) ByteRangestatic ByteRangeCellUtil.fillTagRange(Cell cell, ByteRange range) Deprecated.As of HBase-2.0.static ByteRangePrivateCellUtil.fillTagRange(Cell cell, ByteRange range) static ByteRangeCellUtil.fillValueRange(Cell cell, ByteRange range) Deprecated.As of HBase-2.0.static ByteRangePrivateCellUtil.fillValueRange(Cell cell, ByteRange range) static intCellUtil.findCommonPrefixInFlatKey(Cell c1, Cell c2, boolean bypassFamilyCheck, boolean withTsType) Deprecated.As of HBase-2.0.static intPrivateCellUtil.findCommonPrefixInFlatKey(Cell c1, Cell c2, boolean bypassFamilyCheck, boolean withTsType) Find length of common prefix in keys of the cells, considering key as byte[] if serialized inKeyValue.static StringCellUtil.getCellKeyAsString(Cell cell) Return the key portion of the passedcellas a String.static StringCellUtil.getCellKeyAsString(Cell cell, Function<Cell, String> rowConverter) Return the Key portion of the passedcellas a String.static byte[]CellUtil.getCellKeySerializedAsKeyValueKey(Cell cell) Deprecated.As of HBase-2.0.static byte[]PrivateCellUtil.getCellKeySerializedAsKeyValueKey(Cell cell) This method exists just to encapsulate how we serialize keys.static List<RegionInfo>MetaTableAccessor.getMergeRegions(Cell[] cells) Returns Deserialized regioninfo values taken from column values that match the regex 'info:merge.*' in array ofcells.static Map<String,RegionInfo> MetaTableAccessor.getMergeRegionsWithName(Cell[] cells) Returns Deserialized values of <qualifier,regioninfo> pairs taken from column values that match the regex 'info:merge.*' in array ofcells.static ByteBufferCellUtil.getQualifierBufferShallowCopy(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static bytePrivateCellUtil.getQualifierByte(Cell cell, int index) private static longMetaTableAccessor.getReplicationBarrier(Cell c) static intPrivateCellUtil.getRowAsInt(Cell cell) Converts the rowkey bytes of the given cell into an int valuestatic byteCellUtil.getRowByte(Cell cell, int index) Deprecated.static bytePrivateCellUtil.getRowByte(Cell cell, int index) miscstatic intKeyValueUtil.getSerializedSize(Cell cell, boolean withTags) private static intCellUtil.getSumOfCellElementLengths(Cell cell) Return sum of the lengths of all the elements in a Cell; does not count in any infrastructureprivate static intCellUtil.getSumOfCellKeyElementLengths(Cell cell) Return sum of all elements that make up a key; does not include infrastructure, tags or values.static TagDeprecated.As of 2.0.0 and will be removed in HBase-3.0.0 UseRawCell.getTag(byte)Retrieve Cell's first tag, matching the passed in typestatic byte[]CellUtil.getTagArray(Cell cell) Deprecated.As of HBase-2.0.Deprecated.As of 2.0.0 and will be removed in 3.0.0Return tags in the given Cell as a Liststatic BigDecimalPrivateCellUtil.getValueAsBigDecimal(Cell cell) Converts the value bytes of the given cell into a BigDecimalstatic doublePrivateCellUtil.getValueAsDouble(Cell cell) Converts the value bytes of the given cell into a double valuestatic intPrivateCellUtil.getValueAsInt(Cell cell) Converts the value bytes of the given cell into a int valuestatic longPrivateCellUtil.getValueAsLong(Cell cell) Converts the value bytes of the given cell into a long valuestatic ByteBufferCellUtil.getValueBufferShallowCopy(Cell cell) Deprecated.As of HBase-2.0.static ByteBufferPrivateCellUtil.getValueBufferShallowCopy(Cell cell) static booleanMetaTableAccessor.hasMergeRegions(Cell[] cells) Returns True if any merge regions present incells; i.e.static booleanReturn true if a delete type, aKeyValue.Type.Deleteor a {KeyValue.Type#DeleteFamily} or aKeyValue.Type.DeleteColumnKeyValue type.static booleanCellUtil.isDeleteColumnOrFamily(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanPrivateCellUtil.isDeleteColumnOrFamily(Cell cell) Returns True if this cell is a delete family or column type.static booleanCellUtil.isDeleteColumns(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanPrivateCellUtil.isDeleteColumns(Cell cell) static booleanCellUtil.isDeleteColumnVersion(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanPrivateCellUtil.isDeleteColumnVersion(Cell cell) static booleanCellUtil.isDeleteFamily(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanPrivateCellUtil.isDeleteFamily(Cell cell) static booleanCellUtil.isDeleteFamilyVersion(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanPrivateCellUtil.isDeleteFamilyVersion(Cell cell) static booleanCellUtil.isDeleteType(Cell cell) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanPrivateCellUtil.isDeleteType(Cell cell) Returns True if this cell is aKeyValue.Type.Deletetype.private static booleanMetaTableAccessor.isMergeQualifierPrefix(Cell cell) Returns True if the column incellmatches the regex 'info:merge.*'.static booleanReturns True if this cell is a Put.static intReturns number of bytes this cell's key part would have been used if serialized as inKeyValue.static booleanCellUtil.matchingColumn(Cell left, byte[] fam, byte[] qual) static booleanCellUtil.matchingColumn(Cell left, byte[] fam, int foffset, int flength, byte[] qual, int qoffset, int qlength) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.private static booleanCellUtil.matchingColumn(Cell left, byte lFamLen, int lQualLength, Cell right, byte rFamLen, int rQualLength) static booleanCellUtil.matchingColumn(Cell left, Cell right) static booleanPrivateCellUtil.matchingColumn(Cell left, byte[] fam, int foffset, int flength, byte[] qual, int qoffset, int qlength) static booleanCellUtil.matchingColumnFamilyAndQualifierPrefix(Cell left, byte[] fam, byte[] qual) Returns True if matching column family and the qualifier starts withqualstatic booleanCellUtil.matchingFamily(Cell left, byte[] buf) static booleanCellUtil.matchingFamily(Cell left, byte[] buf, int offset, int length) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanCellUtil.matchingFamily(Cell left, byte lfamlength, Cell right, byte rfamlength) static booleanCellUtil.matchingFamily(Cell left, Cell right) static booleanPrivateCellUtil.matchingFamily(Cell left, byte[] buf, int offset, int length) static booleanCellUtil.matchingQualifier(Cell left, byte[] buf) Finds if the qualifier part of the cell and the KV serialized byte[] are equal.static booleanCellUtil.matchingQualifier(Cell left, byte[] buf, int offset, int length) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.private static booleanCellUtil.matchingQualifier(Cell left, int lqlength, Cell right, int rqlength) static booleanCellUtil.matchingQualifier(Cell left, Cell right) static booleanPrivateCellUtil.matchingQualifier(Cell left, byte[] buf, int offset, int length) Finds if the qualifier part of the cell and the KV serialized byte[] are equalstatic booleanCellUtil.matchingRow(Cell left, byte[] buf) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanCellUtil.matchingRow(Cell left, byte[] buf, int offset, int length) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanCellUtil.matchingRow(Cell left, Cell right) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.static booleanCellUtil.matchingRowColumn(Cell left, Cell right) Compares the row and column of two keyvalues for equalitybooleanKeyValue.KVComparator.matchingRowColumn(Cell left, Cell right) Deprecated.Compares the row and column of two keyvalues for equalitystatic booleanCellUtil.matchingRowColumnBytes(Cell left, Cell right) Compares the row and column of two keyvalues for equalitystatic booleanCellUtil.matchingRows(Cell left, byte[] buf) static booleanCellUtil.matchingRows(Cell left, short lrowlength, Cell right, short rrowlength) Compares the row of two keyvalues for equalitystatic booleanCellUtil.matchingRows(Cell left, Cell right) Compares the row of two keyvalues for equalityprivate booleanKeyValue.KVComparator.matchingRows(Cell left, short lrowlength, Cell right, short rrowlength) Deprecated.Compares the row of two keyvalues for equalitybooleanKeyValue.KVComparator.matchingRows(Cell left, Cell right) Deprecated.Compares the row of two keyvalues for equalitystatic booleanPrivateCellUtil.matchingRows(Cell left, byte[] buf, int offset, int length) static booleanCellUtil.matchingTags(Cell left, Cell right) static booleanPrivateCellUtil.matchingTags(Cell left, Cell right, int llength, int rlength) static booleanCellUtil.matchingTimestamp(Cell a, Cell b) static booleanCellUtil.matchingType(Cell a, Cell b) Deprecated.As of HBase-2.0.static booleanPrivateCellUtil.matchingType(Cell a, Cell b) static booleanCellUtil.matchingValue(Cell left, byte[] buf) static booleanCellUtil.matchingValue(Cell left, Cell right) static booleanPrivateCellUtil.matchingValue(Cell left, Cell right, int lvlength, int rvlength) static intKeyValueUtil.oswrite(Cell cell, OutputStream out, boolean withTags) static booleanPrivateCellUtil.qualifierStartsWith(Cell left, byte[] startsWith) Finds if the start of the qualifier part of the Cell matchesbufstatic voidCellUtil.setSequenceId(Cell cell, long seqId) Deprecated.As of HBase-2.0.static voidPrivateCellUtil.setSequenceId(Cell cell, long seqId) Sets the given seqId to the cell.static voidCellUtil.setTimestamp(Cell cell, byte[] ts, int tsOffset) Deprecated.As of HBase-2.0.static voidCellUtil.setTimestamp(Cell cell, long ts) Deprecated.As of HBase-2.0.static voidPrivateCellUtil.setTimestamp(Cell cell, byte[] ts) Sets the given timestamp to the cell.static voidPrivateCellUtil.setTimestamp(Cell cell, long ts) Sets the given timestamp to the cell.PrivateCellUtil.tagsIterator(Cell cell) Utility method to iterate through the tags in the given cell.static KeyValueKeyValueUtil.toNewKeyCell(Cell cell) Copies the key to a new KeyValuestatic StringReturns a string representation of the cellstatic booleanCellUtil.updateLatestStamp(Cell cell, byte[] ts, int tsOffset) Deprecated.As of HBase-2.0.static booleanCellUtil.updateLatestStamp(Cell cell, long ts) Deprecated.As of HBase-2.0.static booleanPrivateCellUtil.updateLatestStamp(Cell cell, byte[] ts) Sets the given timestamp to the cell iff current timestamp isHConstants.LATEST_TIMESTAMP.static booleanPrivateCellUtil.updateLatestStamp(Cell cell, long ts) Sets the given timestamp to the cell iff current timestamp isHConstants.LATEST_TIMESTAMP.(package private) static intPrivateCellUtil.ValueAndTagRewriteCell.write(OutputStream out, boolean withTags, Cell cell, byte[] value, byte[] tags) Made into a static method so as to reuse the logic within ValueAndTagRewriteByteBufferExtendedCell(package private) static voidPrivateCellUtil.ValueAndTagRewriteCell.write(ByteBuffer buf, int offset, Cell cell, byte[] value, byte[] tags) Made into a static method so as to reuse the logic within ValueAndTagRewriteByteBufferExtendedCellstatic intPrivateCellUtil.writeCell(Cell cell, OutputStream out, boolean withTags) Writes the cell to the given OutputStreamstatic voidPrivateCellUtil.writeCellToBuffer(Cell cell, ByteBuffer buf, int offset) Writes a cell to the buffer at the given offsetstatic voidPrivateCellUtil.writeFamily(OutputStream out, Cell cell, byte flength) Writes the family from the given cell to the output streamstatic voidCellUtil.writeFlatKey(Cell cell, DataOutputStream out) Deprecated.As of HBase-2.0.static voidPrivateCellUtil.writeFlatKey(Cell cell, DataOutput out) Writes the Cell's key part as it would have serialized in a KeyValue.static intPrivateCellUtil.writeFlatKey(Cell cell, OutputStream out) static voidPrivateCellUtil.writeQualifier(OutputStream out, Cell cell, int qlength) Writes the qualifier from the given cell to the output streamstatic voidPrivateCellUtil.writeQualifierSkippingBytes(DataOutputStream out, Cell cell, int qlength, int commonPrefix) Writes the qualifier from the given cell to the output stream excluding the common prefixstatic voidPrivateCellUtil.writeRow(OutputStream out, Cell cell, short rlength) Writes the row from the given cell to the output streamstatic voidCellUtil.writeRowKeyExcludingCommon(Cell cell, short rLen, int commonPrefix, DataOutputStream out) Deprecated.As of HBase-2.0.static voidPrivateCellUtil.writeRowKeyExcludingCommon(Cell cell, short rLen, int commonPrefix, DataOutputStream out) Write rowkey excluding the common part.static voidCellUtil.writeRowSkippingBytes(DataOutputStream out, Cell cell, short rlength, int commonPrefix) Deprecated.As of 2.0.static voidPrivateCellUtil.writeRowSkippingBytes(DataOutputStream out, Cell cell, short rlength, int commonPrefix) Writes the row from the given cell to the output stream excluding the common prefixstatic voidPrivateCellUtil.writeTags(OutputStream out, Cell cell, int tagsLength) Writes the tag from the given cell to the output streamstatic voidPrivateCellUtil.writeValue(OutputStream out, Cell cell, int vlength) Writes the value from the given cell to the output streamMethod parameters in org.apache.hadoop.hbase with type arguments of type CellModifier and TypeMethodDescriptionstatic voidCellUtil.cloneIfNecessary(ArrayList<Cell> cells) static booleanKeyValueTestUtil.containsIgnoreMvccVersion(Collection<? extends Cell> kvCollection1, Collection<? extends Cell> kvCollection2) Checks whether KeyValues from kvCollection2 are contained in kvCollection1.static CellScannerCellUtil.createCellScanner(Iterable<Cell> cellIterable) Returns CellScanner interface overcellIterablestatic CellScannerCellUtil.createCellScanner(Iterator<Cell> cells) Returns CellScanner interface overcellIterableor null ifcellsis nullstatic CellScannerCellUtil.createCellScanner(NavigableMap<byte[], List<Cell>> map) Flatten the map of cells out under the CellScannerKeyValueUtil.ensureKeyValues(List<Cell> cells) Deprecated.static StringCellUtil.getCellKeyAsString(Cell cell, Function<Cell, String> rowConverter) Return the Key portion of the passedcellas a String.Constructors in org.apache.hadoop.hbase with parameters of type CellModifierConstructorDescriptionTagRewriteCell(Cell cell, byte[] tags) Construct a TagRewriteCellValueAndTagRewriteCell(Cell cell, byte[] value, byte[] tags) -
Uses of Cell in org.apache.hadoop.hbase.backup.impl
Methods in org.apache.hadoop.hbase.backup.impl with parameters of type CellModifier and TypeMethodDescriptionprivate StringBackupSystemTable.cellKeyToBackupSetName(Cell current) Converts cell key to backup set name.private BackupInfoBackupSystemTable.cellToBackupInfo(Cell current) Converts cell to backup info instance.private String[]BackupSystemTable.cellValueToBackupSet(Cell current) Converts cell to backup set list. -
Uses of Cell in org.apache.hadoop.hbase.backup.mapreduce
Methods in org.apache.hadoop.hbase.backup.mapreduce with parameters of type CellModifier and TypeMethodDescriptionvoidMapReduceHFileSplitterJob.HFileCellMapper.map(org.apache.hadoop.io.NullWritable key, Cell value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable, Cell, ImmutableBytesWritable, Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) -
Uses of Cell in org.apache.hadoop.hbase.client
Classes in org.apache.hadoop.hbase.client that implement CellFields in org.apache.hadoop.hbase.client declared as CellModifier and TypeFieldDescriptionprivate final CellMutation.CellWrapper.cellprivate Cell[]Result.cellsprivate CellAllowPartialScanResultCache.lastCellprivate CellBatchScanResultCache.lastCellFields in org.apache.hadoop.hbase.client with type parameters of type CellModifier and TypeFieldDescriptionprotected NavigableMap<byte[],List<Cell>> Mutation.familyMapClientSideRegionScanner.valuesMethods in org.apache.hadoop.hbase.client that return CellModifier and TypeMethodDescriptionResult.current()Result.getColumnLatestCell(byte[] family, byte[] qualifier) The Cell for the most recent timestamp for a given column.Result.getColumnLatestCell(byte[] family, int foffset, int flength, byte[] qualifier, int qoffset, int qlength) The Cell for the most recent timestamp for a given column.Cell[]Result.rawCells()Return the array of Cells backing this Result instance.Methods in org.apache.hadoop.hbase.client that return types with arguments of type CellModifier and TypeMethodDescriptionMutation.get(byte[] family, byte[] qualifier) Returns a list of all KeyValue objects with matching column family and qualifier.Mutation.getCellList(byte[] family) Creates an empty list if one doesn't exist for the given column family or else it returns the associated list of Cell objects.Result.getColumnCells(byte[] family, byte[] qualifier) Return the Cells for the specific column.NavigableMap<byte[],List<Cell>> Mutation.getFamilyCellMap()Method for retrieving the put's familyMapResult.listCells()Create a sorted list of the Cell's in this result.Methods in org.apache.hadoop.hbase.client with parameters of type CellModifier and TypeMethodDescriptionAdd column and value to this Append operation.Add an existing delete marker to this Delete object.Add the specified KeyValue to this operation.(package private) MutationAdd the specified KeyValue to this Put operation.Delete.addDeleteMarker(Cell kv) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.protected intResult.binarySearch(Cell[] kvs, byte[] family, byte[] qualifier) protected intResult.binarySearch(Cell[] kvs, byte[] family, int foffset, int flength, byte[] qualifier, int qoffset, int qlength) Searches for the latest value for the specified column.Mutation.cellToStringMap(Cell c) static ResultInstantiate a Result with the specified array of KeyValues.static Resultstatic Result(package private) static ResultConnectionUtils.filterCells(Result result, Cell keepCellsAfter) Method parameters in org.apache.hadoop.hbase.client with type arguments of type CellModifier and TypeMethodDescriptionstatic ResultInstantiate a Result with the specified List of KeyValues.static Resultstatic Resultstatic ResultAppend.setFamilyCellMap(NavigableMap<byte[], List<Cell>> map) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.Delete.setFamilyCellMap(NavigableMap<byte[], List<Cell>> map) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.Increment.setFamilyCellMap(NavigableMap<byte[], List<Cell>> map) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.Mutation.setFamilyCellMap(NavigableMap<byte[], List<Cell>> map) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.Put.setFamilyCellMap(NavigableMap<byte[], List<Cell>> map) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.Constructors in org.apache.hadoop.hbase.client with parameters of type CellConstructor parameters in org.apache.hadoop.hbase.client with type arguments of type CellModifierConstructorDescriptionAppend(byte[] row, long ts, NavigableMap<byte[], List<Cell>> familyMap) Construct the Append with user defined data.Delete(byte[] row, long ts, NavigableMap<byte[], List<Cell>> familyMap) Construct the Delete with user defined data.Increment(byte[] row, long ts, NavigableMap<byte[], List<Cell>> familyMap) Construct the Increment with user defined data.protectedMutation(byte[] row, long ts, NavigableMap<byte[], List<Cell>> familyMap) Construct the mutation with user defined data.Put(byte[] row, long ts, NavigableMap<byte[], List<Cell>> familyMap) Construct the Put with user defined data. -
Uses of Cell in org.apache.hadoop.hbase.client.coprocessor
Methods in org.apache.hadoop.hbase.client.coprocessor with parameters of type CellModifier and TypeMethodDescription -
Uses of Cell in org.apache.hadoop.hbase.codec
Fields in org.apache.hadoop.hbase.codec declared as CellModifier and TypeFieldDescriptionprivate CellBaseDecoder.currentprotected CellKeyValueCodec.ByteBuffKeyValueDecoder.currentMethods in org.apache.hadoop.hbase.codec that return CellModifier and TypeMethodDescriptionprotected CellKeyValueCodec.ByteBuffKeyValueDecoder.createCell(byte[] buf, int offset, int len) protected CellKeyValueCodec.ByteBuffKeyValueDecoder.createCell(ByteBuffer bb, int pos, int len) protected CellKeyValueCodecWithTags.ByteBuffKeyValueDecoder.createCell(byte[] buf, int offset, int len) protected CellKeyValueCodecWithTags.ByteBuffKeyValueDecoder.createCell(ByteBuffer bb, int pos, int len) BaseDecoder.current()KeyValueCodec.ByteBuffKeyValueDecoder.current()protected abstract CellBaseDecoder.parseCell()Extract a Cell.protected CellCellCodec.CellDecoder.parseCell()protected CellCellCodecWithTags.CellDecoder.parseCell()protected CellKeyValueCodec.KeyValueDecoder.parseCell()protected CellKeyValueCodecWithTags.KeyValueDecoder.parseCell()protected CellMessageCodec.MessageDecoder.parseCell()Methods in org.apache.hadoop.hbase.codec with parameters of type CellModifier and TypeMethodDescriptionabstract voidvoidvoidvoidvoidvoid -
Uses of Cell in org.apache.hadoop.hbase.coprocessor
Methods in org.apache.hadoop.hbase.coprocessor that return CellModifier and TypeMethodDescriptiondefault CellRegionObserver.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell) Deprecated.since 2.2.0 and will be removedin 4.0.0.Methods in org.apache.hadoop.hbase.coprocessor that return types with arguments of type CellModifier and TypeMethodDescriptionRegionObserver.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an append operation, but before they are committed to the WAL or memstore.RegionObserver.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an append operation, but before they are committed to the WAL or memstore.RegionObserver.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an increment operation, but before they are committed to the WAL or memstore.RegionObserver.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an increment operation, but before they are committed to the WAL or memstore.Methods in org.apache.hadoop.hbase.coprocessor with parameters of type CellModifier and TypeMethodDescriptionabstract TReturns value of type Tdefault CellRegionObserver.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell) Deprecated.since 2.2.0 and will be removedin 4.0.0.default booleanRegionObserver.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, Cell curRowCell, boolean hasMore) This will be called by the scan flow when the current scanned row is being filtered out by the filter.default voidRegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell, byte[] byteNow, Get get) Deprecated.Since hbase-2.0.0.Method parameters in org.apache.hadoop.hbase.coprocessor with type arguments of type CellModifier and TypeMethodDescriptionRegionObserver.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an append operation, but before they are committed to the WAL or memstore.RegionObserver.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an append operation, but before they are committed to the WAL or memstore.default voidRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called after the client performs a GetRegionObserver.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an increment operation, but before they are committed to the WAL or memstore.RegionObserver.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an increment operation, but before they are committed to the WAL or memstore.voidMetaTableMetrics.ExampleRegionObserverMeta.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) default voidRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called before the client performs a Get -
Uses of Cell in org.apache.hadoop.hbase.coprocessor.example
Methods in org.apache.hadoop.hbase.coprocessor.example that return CellModifier and TypeMethodDescriptionprivate CellWriteHeavyIncrementObserver.createCell(byte[] row, byte[] family, byte[] qualifier, long ts, long value) Method parameters in org.apache.hadoop.hbase.coprocessor.example with type arguments of type CellModifier and TypeMethodDescriptionprivate DeleteBulkDeleteEndpoint.createDeleteMutation(List<Cell> deleteRow, org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.BulkDeleteRequest.DeleteType deleteType, Long timestamp) booleanDelegatingInternalScanner.next(List<Cell> result, ScannerContext scannerContext) voidExampleRegionObserverWithMetrics.ExampleRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) voidExampleRegionObserverWithMetrics.ExampleRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) voidWriteHeavyIncrementObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) -
Uses of Cell in org.apache.hadoop.hbase.filter
Classes in org.apache.hadoop.hbase.filter that implement CellModifier and TypeClassDescription(package private) static class(package private) static classFields in org.apache.hadoop.hbase.filter declared as CellFields in org.apache.hadoop.hbase.filter with type parameters of type CellMethods in org.apache.hadoop.hbase.filter that return CellModifier and TypeMethodDescriptionprivate CellKeyOnlyFilter.createKeyOnlyCell(Cell c) ColumnPaginationFilter.getNextCellHint(Cell cell) ColumnPrefixFilter.getNextCellHint(Cell cell) ColumnRangeFilter.getNextCellHint(Cell cell) abstract CellFilter.getNextCellHint(Cell currentCell) If the filter returns the match code SEEK_NEXT_USING_HINT, then it should also tell which is the next key it must seek to.FilterBase.getNextCellHint(Cell currentCell) Filters that are not sure which key must be next seeked to, can inherit this implementation that, by default, returns a null Cell.FilterList.getNextCellHint(Cell currentCell) FilterListWithAND.getNextCellHint(Cell currentCell) FilterListWithOR.getNextCellHint(Cell currentCell) FilterWrapper.getNextCellHint(Cell currentCell) FuzzyRowFilter.getNextCellHint(Cell currentCell) MultipleColumnPrefixFilter.getNextCellHint(Cell cell) MultiRowRangeFilter.getNextCellHint(Cell currentKV) TimestampsFilter.getNextCellHint(Cell currentCell) Pick the next cell that the scanner should seek to.abstract CellFilter.transformCell(Cell v) Give the filter a chance to transform the passed KeyValue.FilterBase.transformCell(Cell v) By default no transformation takes place Give the filter a chance to transform the passed KeyValue.FilterList.transformCell(Cell c) FilterListBase.transformCell(Cell c) For FilterList, we can consider a filter list as a node in a tree.FilterWrapper.transformCell(Cell v) KeyOnlyFilter.transformCell(Cell cell) SkipFilter.transformCell(Cell v) WhileMatchFilter.transformCell(Cell v) Methods in org.apache.hadoop.hbase.filter with parameters of type CellModifier and TypeMethodDescriptionprivate Filter.ReturnCodeFilterListWithOR.calculateReturnCodeByPrevCellAndRC(Filter subFilter, Cell currentCell, Cell prevCell, Filter.ReturnCode prevCode) For MUST_PASS_ONE, we cannot make sure that when filter-A in filter list return NEXT_COL then the next cell passing to filterList will be the first cell in next column, because if filter-B in filter list return SKIP, then the filter list will return SKIP.protected intFilterListBase.compareCell(Cell a, Cell b) protected booleanCompareFilter.compareFamily(CompareOperator op, ByteArrayComparable comparator, Cell cell) protected booleanCompareFilter.compareFamily(CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Cell cell) Deprecated.Since 2.0.0.protected booleanCompareFilter.compareQualifier(CompareOperator op, ByteArrayComparable comparator, Cell cell) protected booleanCompareFilter.compareQualifier(CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Cell cell) Deprecated.Since 2.0.0.private static intColumnPrefixFilter.compareQualifierPart(Cell cell, int length, byte[] prefix) protected booleanCompareFilter.compareRow(CompareOperator op, ByteArrayComparable comparator, Cell cell) protected booleanCompareFilter.compareRow(CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Cell cell) Deprecated.Since 2.0.0.private booleanColumnValueFilter.compareValue(CompareOperator op, ByteArrayComparable comparator, Cell cell) This method is used to determine a cell should be included or filtered out.protected booleanCompareFilter.compareValue(CompareOperator op, ByteArrayComparable comparator, Cell cell) protected booleanCompareFilter.compareValue(CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Cell cell) Deprecated.Since 2.0.0.private CellKeyOnlyFilter.createKeyOnlyCell(Cell c) ColumnCountGetFilter.filterCell(Cell c) ColumnPaginationFilter.filterCell(Cell c) ColumnPrefixFilter.filterCell(Cell cell) ColumnRangeFilter.filterCell(Cell c) ColumnValueFilter.filterCell(Cell c) DependentColumnFilter.filterCell(Cell c) FamilyFilter.filterCell(Cell c) Filter.filterCell(Cell c) A way to filter based on the column family, column qualifier and/or the column value.FilterList.filterCell(Cell c) FilterListWithAND.filterCell(Cell c) FilterListWithOR.filterCell(Cell c) FilterWrapper.filterCell(Cell c) FirstKeyOnlyFilter.filterCell(Cell c) FirstKeyValueMatchingQualifiersFilter.filterCell(Cell c) Deprecated.FuzzyRowFilter.filterCell(Cell c) InclusiveStopFilter.filterCell(Cell c) KeyOnlyFilter.filterCell(Cell ignored) MultipleColumnPrefixFilter.filterCell(Cell c) MultiRowRangeFilter.filterCell(Cell ignored) PageFilter.filterCell(Cell ignored) PrefixFilter.filterCell(Cell c) QualifierFilter.filterCell(Cell c) RandomRowFilter.filterCell(Cell c) RowFilter.filterCell(Cell v) SingleColumnValueFilter.filterCell(Cell c) SkipFilter.filterCell(Cell c) TimestampsFilter.filterCell(Cell c) ValueFilter.filterCell(Cell c) WhileMatchFilter.filterCell(Cell c) ColumnPrefixFilter.filterColumn(Cell cell) MultipleColumnPrefixFilter.filterColumn(Cell cell) private booleanSingleColumnValueFilter.filterColumnValue(Cell cell) ColumnCountGetFilter.filterKeyValue(Cell c) Deprecated.ColumnPaginationFilter.filterKeyValue(Cell c) Deprecated.ColumnPrefixFilter.filterKeyValue(Cell c) Deprecated.ColumnRangeFilter.filterKeyValue(Cell c) Deprecated.DependentColumnFilter.filterKeyValue(Cell c) Deprecated.FamilyFilter.filterKeyValue(Cell c) Deprecated.Filter.filterKeyValue(Cell c) Deprecated.As of release 2.0.0, this will be removed in HBase 3.0.0.FilterList.filterKeyValue(Cell c) Deprecated.FilterListBase.filterKeyValue(Cell c) FilterWrapper.filterKeyValue(Cell c) Deprecated.FirstKeyOnlyFilter.filterKeyValue(Cell c) Deprecated.FirstKeyValueMatchingQualifiersFilter.filterKeyValue(Cell c) Deprecated.FuzzyRowFilter.filterKeyValue(Cell c) Deprecated.InclusiveStopFilter.filterKeyValue(Cell c) Deprecated.KeyOnlyFilter.filterKeyValue(Cell ignored) Deprecated.MultipleColumnPrefixFilter.filterKeyValue(Cell c) Deprecated.MultiRowRangeFilter.filterKeyValue(Cell ignored) Deprecated.PageFilter.filterKeyValue(Cell c) Deprecated.PrefixFilter.filterKeyValue(Cell c) Deprecated.QualifierFilter.filterKeyValue(Cell c) Deprecated.RandomRowFilter.filterKeyValue(Cell c) Deprecated.RowFilter.filterKeyValue(Cell c) Deprecated.SingleColumnValueFilter.filterKeyValue(Cell c) Deprecated.SkipFilter.filterKeyValue(Cell c) Deprecated.TimestampsFilter.filterKeyValue(Cell c) Deprecated.ValueFilter.filterKeyValue(Cell c) Deprecated.WhileMatchFilter.filterKeyValue(Cell c) Deprecated.booleanColumnCountGetFilter.filterRowKey(Cell cell) booleanColumnPaginationFilter.filterRowKey(Cell cell) booleanColumnPrefixFilter.filterRowKey(Cell cell) booleanColumnRangeFilter.filterRowKey(Cell cell) booleanColumnValueFilter.filterRowKey(Cell cell) booleanCompareFilter.filterRowKey(Cell cell) abstract booleanFilter.filterRowKey(Cell firstRowCell) Filters a row based on the row key.booleanFilterBase.filterRowKey(Cell cell) booleanFilterList.filterRowKey(Cell firstRowCell) booleanFilterListWithAND.filterRowKey(Cell firstRowCell) booleanFilterListWithOR.filterRowKey(Cell firstRowCell) booleanFilterWrapper.filterRowKey(Cell cell) booleanFirstKeyOnlyFilter.filterRowKey(Cell cell) booleanInclusiveStopFilter.filterRowKey(Cell firstRowCell) booleanKeyOnlyFilter.filterRowKey(Cell cell) booleanMultipleColumnPrefixFilter.filterRowKey(Cell cell) booleanMultiRowRangeFilter.filterRowKey(Cell firstRowCell) booleanPageFilter.filterRowKey(Cell cell) booleanPrefixFilter.filterRowKey(Cell firstRowCell) booleanRandomRowFilter.filterRowKey(Cell firstRowCell) booleanRowFilter.filterRowKey(Cell firstRowCell) booleanSingleColumnValueFilter.filterRowKey(Cell cell) booleanSkipFilter.filterRowKey(Cell cell) booleanTimestampsFilter.filterRowKey(Cell cell) booleanWhileMatchFilter.filterRowKey(Cell cell) ColumnPaginationFilter.getNextCellHint(Cell cell) ColumnPrefixFilter.getNextCellHint(Cell cell) ColumnRangeFilter.getNextCellHint(Cell cell) abstract CellFilter.getNextCellHint(Cell currentCell) If the filter returns the match code SEEK_NEXT_USING_HINT, then it should also tell which is the next key it must seek to.FilterBase.getNextCellHint(Cell currentCell) Filters that are not sure which key must be next seeked to, can inherit this implementation that, by default, returns a null Cell.FilterList.getNextCellHint(Cell currentCell) FilterListWithAND.getNextCellHint(Cell currentCell) FilterListWithOR.getNextCellHint(Cell currentCell) FilterWrapper.getNextCellHint(Cell currentCell) FuzzyRowFilter.getNextCellHint(Cell currentCell) MultipleColumnPrefixFilter.getNextCellHint(Cell cell) MultiRowRangeFilter.getNextCellHint(Cell currentKV) TimestampsFilter.getNextCellHint(Cell currentCell) Pick the next cell that the scanner should seek to.private booleanFirstKeyValueMatchingQualifiersFilter.hasOneMatchingQualifier(Cell c) Deprecated.(package private) booleanabstract CellFilter.transformCell(Cell v) Give the filter a chance to transform the passed KeyValue.FilterBase.transformCell(Cell v) By default no transformation takes place Give the filter a chance to transform the passed KeyValue.FilterList.transformCell(Cell c) FilterListBase.transformCell(Cell c) For FilterList, we can consider a filter list as a node in a tree.FilterWrapper.transformCell(Cell v) KeyOnlyFilter.transformCell(Cell cell) SkipFilter.transformCell(Cell v) WhileMatchFilter.transformCell(Cell v) private voidFilterListWithOR.updatePrevCellList(int index, Cell currentCell, Filter.ReturnCode currentRC) (package private) booleanFuzzyRowFilter.RowTracker.updateTracker(Cell currentCell) (package private) voidFuzzyRowFilter.RowTracker.updateWith(Cell currentCell, Pair<byte[], byte[]> fuzzyData) Method parameters in org.apache.hadoop.hbase.filter with type arguments of type CellModifier and TypeMethodDescriptionvoidDependentColumnFilter.filterRowCells(List<Cell> kvs) abstract voidFilter.filterRowCells(List<Cell> kvs) Chance to alter the list of Cells to be submitted.voidFilterBase.filterRowCells(List<Cell> ignored) Filters that never filter by modifying the returned List of Cells can inherit this implementation that does nothing.voidFilterList.filterRowCells(List<Cell> cells) Filters that never filter by modifying the returned List of Cells can inherit this implementation that does nothing.voidFilterListBase.filterRowCells(List<Cell> cells) Filters that never filter by modifying the returned List of Cells can inherit this implementation that does nothing.voidFilterWrapper.filterRowCells(List<Cell> kvs) voidSingleColumnValueExcludeFilter.filterRowCells(List<Cell> kvs) FilterWrapper.filterRowCellsWithRet(List<Cell> kvs) Constructors in org.apache.hadoop.hbase.filter with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.io
Fields in org.apache.hadoop.hbase.io declared as CellFields in org.apache.hadoop.hbase.io with type parameters of type CellMethods in org.apache.hadoop.hbase.io that return types with arguments of type CellModifier and TypeMethodDescriptionHalfStoreFileReader.getFirstKey()HalfStoreFileReader.getLastKey()HalfStoreFileReader.midKey()Methods in org.apache.hadoop.hbase.io with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.io.encoding
Classes in org.apache.hadoop.hbase.io.encoding that implement CellModifier and TypeClassDescriptionprotected static classprotected static classCopies only the key part of the keybuffer by doing a deep copy and passes the seeker state members for taking a clone.Fields in org.apache.hadoop.hbase.io.encoding declared as CellModifier and TypeFieldDescriptionprivate CellRowIndexEncoderV1.lastCellThe Cell previously appended.protected CellEncodingState.prevCellThe previous Cell the encoder encoded.Methods in org.apache.hadoop.hbase.io.encoding that return CellModifier and TypeMethodDescriptionprotected CellAbstractDataBlockEncoder.createFirstKeyCell(ByteBuffer key, int keyLength) BufferedDataBlockEncoder.BufferedEncodedSeeker.getCell()DataBlockEncoder.EncodedSeeker.getCell()Returns the Cell at the current position.RowIndexSeekerV1.getCell()CopyKeyDataBlockEncoder.getFirstKeyCellInBlock(ByteBuff block) DataBlockEncoder.getFirstKeyCellInBlock(ByteBuff block) Return first key in block as a cell.DiffKeyDeltaEncoder.getFirstKeyCellInBlock(ByteBuff block) FastDiffDeltaEncoder.getFirstKeyCellInBlock(ByteBuff block) PrefixKeyDeltaEncoder.getFirstKeyCellInBlock(ByteBuff block) RowIndexCodecV1.getFirstKeyCellInBlock(ByteBuff block) BufferedDataBlockEncoder.BufferedEncodedSeeker.getKey()DataBlockEncoder.EncodedSeeker.getKey()From the current position creates a cell using the key part of the current bufferRowIndexSeekerV1.getKey()BufferedDataBlockEncoder.SeekerState.toCell()RowIndexSeekerV1.SeekerState.toCell()private CellBufferedDataBlockEncoder.SeekerState.toOffheapCell(ByteBuffer valAndTagsBuffer, int vOffset, int tagsLenSerializationSize) private CellBufferedDataBlockEncoder.SeekerState.toOnheapCell(ByteBuffer valAndTagsBuffer, int vOffset, int tagsLenSerializationSize) Methods in org.apache.hadoop.hbase.io.encoding that return types with arguments of type CellModifier and TypeMethodDescriptionEncodedDataBlock.getIterator(int headerSize) Provides access to compressed value.Methods in org.apache.hadoop.hbase.io.encoding with parameters of type CellModifier and TypeMethodDescriptionprotected final intBufferedDataBlockEncoder.afterEncodingKeyValue(Cell cell, DataOutputStream out, HFileBlockDefaultEncodingContext encodingCtx) Returns unencoded size addedprivate intRowIndexSeekerV1.binarySearch(Cell seekCell, boolean seekBefore) protected booleanstatic intBufferedDataBlockEncoder.compareCommonFamilyPrefix(Cell left, Cell right, int familyCommonPrefix) static intBufferedDataBlockEncoder.compareCommonQualifierPrefix(Cell left, Cell right, int qualCommonPrefix) static intBufferedDataBlockEncoder.compareCommonRowPrefix(Cell left, Cell right, int rowCommonPrefix) common prefixesintBufferedDataBlockEncoder.BufferedEncodedSeeker.compareKey(CellComparator comparator, Cell key) intDataBlockEncoder.EncodedSeeker.compareKey(CellComparator comparator, Cell key) Compare the given key against the current keyintRowIndexSeekerV1.compareKey(CellComparator comparator, Cell key) private intBufferedDataBlockEncoder.BufferedEncodedSeeker.compareTypeBytes(Cell key, Cell right) private intDiffKeyDeltaEncoder.compressSingleKeyValue(DataOutputStream out, Cell cell, Cell prevCell) private intFastDiffDeltaEncoder.compressSingleKeyValue(DataOutputStream out, Cell cell, Cell prevCell) voidBufferedDataBlockEncoder.encode(Cell cell, HFileBlockEncodingContext encodingCtx, DataOutputStream out) voidDataBlockEncoder.encode(Cell cell, HFileBlockEncodingContext encodingCtx, DataOutputStream out) Encodes a KeyValue.voidRowIndexCodecV1.encode(Cell cell, HFileBlockEncodingContext encodingCtx, DataOutputStream out) private static intBufferedDataBlockEncoder.BufferedEncodedSeeker.findCommonPrefixInFamilyPart(Cell left, KeyValue.KeyOnlyKeyValue right, int familyCommonPrefix) private static intBufferedDataBlockEncoder.BufferedEncodedSeeker.findCommonPrefixInQualifierPart(Cell left, KeyValue.KeyOnlyKeyValue right, int qualifierCommonPrefix) private static intBufferedDataBlockEncoder.BufferedEncodedSeeker.findCommonPrefixInRowPart(Cell left, KeyValue.KeyOnlyKeyValue right, int rowCommonPrefix) abstract intBufferedDataBlockEncoder.internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingCtx, DataOutputStream out) intCopyKeyDataBlockEncoder.internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingContext, DataOutputStream out) intDiffKeyDeltaEncoder.internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingContext, DataOutputStream out) intFastDiffDeltaEncoder.internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingContext, DataOutputStream out) intPrefixKeyDeltaEncoder.internalEncode(Cell cell, HFileBlockDefaultEncodingContext encodingContext, DataOutputStream out) intBufferedDataBlockEncoder.BufferedEncodedSeeker.seekToKeyInBlock(Cell seekCell, boolean seekBefore) intDataBlockEncoder.EncodedSeeker.seekToKeyInBlock(Cell key, boolean seekBefore) Moves the seeker position within the current block to: the last key that that is less than or equal to the given key ifseekBeforeis false the last key that is strictly less than the given key ifseekBeforeis true.intRowIndexSeekerV1.seekToKeyInBlock(Cell seekCell, boolean seekBefore) intvoidprivate voidPrefixKeyDeltaEncoder.writeKeyExcludingCommon(Cell cell, int commonPrefix, DataOutputStream out) -
Uses of Cell in org.apache.hadoop.hbase.io.hfile
Fields in org.apache.hadoop.hbase.io.hfile declared as CellModifier and TypeFieldDescriptionprivate CellHFileInfo.biggestCellBiggest Cell in the file, key only.private Cell[]HFileBlockIndex.CellBasedKeyBlockIndexReader.blockKeysprivate Cell[]NoOpIndexBlockEncoder.NoOpEncodedSeeker.blockKeysprotected CellHFileWriterImpl.firstCellInBlockFirst cell in a block.protected CellHFileWriterImpl.lastCellThe Cell previously appended.private CellHFileWriterImpl.lastCellOfPreviousBlockThe last(stop) Cell of the previous data block.private CellHFileInfo.lastKeyCellLast key in the file.private final CellBlockWithScanInfo.nextIndexedKeyThe first key in the next block following this one in the HFile.protected CellHFileReaderImpl.HFileScannerImpl.nextIndexedKeyThe next indexed key is to keep track of the indexed key of the next data block.private CellCompoundBloomFilterWriter.prevCellThe prev Cell that was processedprivate CellHFilePrettyPrinter.KeyValueStatsCollector.prevCellFields in org.apache.hadoop.hbase.io.hfile with type parameters of type CellModifier and TypeFieldDescriptionprivate AtomicReference<Cell>HFileBlockIndex.CellBasedKeyBlockIndexReader.midKeyPre-computed mid-keyprivate AtomicReference<Cell>NoOpIndexBlockEncoder.NoOpEncodedSeeker.midKeyPre-computed mid-keyMethods in org.apache.hadoop.hbase.io.hfile that return CellModifier and TypeMethodDescriptionHFileReaderImpl.EncodedScanner.getCell()HFileReaderImpl.HFileScannerImpl.getCell()HFileScanner.getCell()Returns Instance ofCell.protected CellHFileReaderImpl.EncodedScanner.getFirstKeyCellInBlock(HFileBlock curBlock) protected CellHFileReaderImpl.HFileScannerImpl.getFirstKeyCellInBlock(HFileBlock curBlock) HFileReaderImpl.EncodedScanner.getKey()HFileReaderImpl.HFileScannerImpl.getKey()HFileScanner.getKey()Gets the current key in the form of a cell.HFileWriterImpl.getLastCell()HFileInfo.getLastKeyCell()static CellHFileWriterImpl.getMidpoint(CellComparator comparator, Cell left, Cell right) Try to return a Cell that falls betweenleftandrightbut that is shorter; i.e.BlockWithScanInfo.getNextIndexedKey()HFileReaderImpl.HFileScannerImpl.getNextIndexedKey()HFileScanner.getNextIndexedKey()Returns the next key in the index (the key to seek to the next block)CompoundBloomFilterWriter.getPrevCell()HFileBlockIndex.CellBasedKeyBlockIndexReader.getRootBlockKey(int i) from 0 to- 1HFileBlockIndex.CellBasedKeyBlockIndexReaderV2.getRootBlockKey(int i) from 0 to- 1HFileIndexBlockEncoder.EncodedSeeker.getRootBlockKey(int i) NoOpIndexBlockEncoder.NoOpEncodedSeeker.getRootBlockKey(int i) abstract CellHFileBlockIndex.BlockIndexReader.midkey(HFile.CachingBlockReader cachingBlockReader) An approximation to theHFile's mid-key.HFileBlockIndex.ByteArrayKeyBlockIndexReader.midkey(HFile.CachingBlockReader cachingBlockReader) HFileBlockIndex.CellBasedKeyBlockIndexReader.midkey(HFile.CachingBlockReader cachingBlockReader) HFileBlockIndex.CellBasedKeyBlockIndexReaderV2.midkey(HFile.CachingBlockReader cachingBlockReader) HFileIndexBlockEncoder.EncodedSeeker.midkey(HFile.CachingBlockReader cachingBlockReader) NoOpIndexBlockEncoder.NoOpEncodedSeeker.midkey(HFile.CachingBlockReader cachingBlockReader) Methods in org.apache.hadoop.hbase.io.hfile that return types with arguments of type CellModifier and TypeMethodDescriptionHFile.Reader.getFirstKey()HFileReaderImpl.getFirstKey()HFile.Reader.getLastKey()HFileReaderImpl.getLastKey()HFile.Reader.midKey()HFileReaderImpl.midKey()Methods in org.apache.hadoop.hbase.io.hfile with parameters of type CellModifier and TypeMethodDescriptionvoidvoidAdd key/value to file.(package private) static intHFileBlockIndex.BlockIndexReader.binarySearchNonRootIndex(Cell key, ByteBuff nonRootIndex, CellComparator comparator) Performs a binary search over a non-root level index block.protected intWithin a loaded block, seek looking for the last key that is smaller than (or equal to?) the key we are interested in.protected booleanChecks that the given Cell's key does not violate the key order.voidintHFileReaderImpl.EncodedScanner.compareKey(CellComparator comparator, Cell key) intHFileReaderImpl.HFileScannerImpl.compareKey(CellComparator comparator, Cell key) booleanprivate booleanCompoundBloomFilter.containsInternal(Cell keyCell, ByteBuff bloom, BloomType type) voidHFileDataBlockEncoder.encode(Cell cell, HFileBlockEncodingContext encodingCtx, DataOutputStream out) Encodes a KeyValue.voidHFileDataBlockEncoderImpl.encode(Cell cell, HFileBlockEncodingContext encodingCtx, DataOutputStream out) voidNoOpDataBlockEncoder.encode(Cell cell, HFileBlockEncodingContext encodingCtx, DataOutputStream out) private StringHFileWriterImpl.getLexicalErrorMessage(Cell cell) static CellHFileWriterImpl.getMidpoint(CellComparator comparator, Cell left, Cell right) Try to return a Cell that falls betweenleftandrightbut that is shorter; i.e.protected intHFileReaderImpl.EncodedScanner.loadBlockAndSeekToKey(HFileBlock seekToBlock, Cell nextIndexedKey, boolean rewind, Cell key, boolean seekBefore) protected intHFileReaderImpl.HFileScannerImpl.loadBlockAndSeekToKey(HFileBlock seekToBlock, Cell nextIndexedKey, boolean rewind, Cell key, boolean seekBefore) abstract BlockWithScanInfoHFileBlockIndex.BlockIndexReader.loadDataBlockWithScanInfo(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) Return the BlockWithScanInfo, a data structure which contains the Data HFileBlock with other scan info such as the key that starts the next HFileBlock.HFileBlockIndex.ByteArrayKeyBlockIndexReader.loadDataBlockWithScanInfo(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) HFileBlockIndex.CellBasedKeyBlockIndexReader.loadDataBlockWithScanInfo(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) HFileBlockIndex.CellBasedKeyBlockIndexReaderV2.loadDataBlockWithScanInfo(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) HFileIndexBlockEncoder.EncodedSeeker.loadDataBlockWithScanInfo(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) NoOpIndexBlockEncoder.NoOpEncodedSeeker.loadDataBlockWithScanInfo(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) (package private) static intHFileBlockIndex.BlockIndexReader.locateNonRootIndexEntry(ByteBuff nonRootBlock, Cell key, CellComparator comparator) Search for one key using the secondary index in a non-root block.intintReseek to or just before the passedcell.abstract intHFileBlockIndex.BlockIndexReader.rootBlockContainingKey(Cell key) Finds the root-level index block containing the given key.intHFileBlockIndex.ByteArrayKeyBlockIndexReader.rootBlockContainingKey(Cell key) intHFileBlockIndex.CellBasedKeyBlockIndexReader.rootBlockContainingKey(Cell key) intHFileBlockIndex.CellBasedKeyBlockIndexReaderV2.rootBlockContainingKey(Cell key) intHFileIndexBlockEncoder.EncodedSeeker.rootBlockContainingKey(Cell key) intNoOpIndexBlockEncoder.NoOpEncodedSeeker.rootBlockContainingKey(Cell key) booleanHFileReaderImpl.HFileScannerImpl.seekBefore(Cell key) booleanHFileScanner.seekBefore(Cell cell) Consider the cell stream of all the cells in the file,c[0] ..intintAn internal API function.intSeekTo or just before the passedcell.HFileBlockIndex.BlockIndexReader.seekToDataBlock(Cell key, HFileBlock currentBlock, boolean cacheBlocks, boolean pread, boolean isCompaction, DataBlockEncoding expectedDataBlockEncoding, HFile.CachingBlockReader cachingBlockReader) Return the data block which contains this key.(package private) voidWrites the Cell to this blockConstructors in org.apache.hadoop.hbase.io.hfile with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.mapreduce
Fields in org.apache.hadoop.hbase.mapreduce declared as CellModifier and TypeFieldDescriptionprivate CellImport.CellWritableComparable.kvprivate CellHFileInputFormat.HFileRecordReader.valueA private cache of the key value so it doesn't need to be loaded twice from the scanner.Methods in org.apache.hadoop.hbase.mapreduce with type parameters of type CellModifier and TypeMethodDescription(package private) static <V extends Cell>
org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,V> HFileOutputFormat2.createRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context, org.apache.hadoop.mapreduce.OutputCommitter committer) Methods in org.apache.hadoop.hbase.mapreduce that return CellModifier and TypeMethodDescriptionprivate CellSyncTable.SyncMapper.checkAndResetTimestamp(Cell sourceCell) private static CellCellCreator.create(byte[] row, int roffset, int rlength, byte[] family, int foffset, int flength, byte[] qualifier, int qoffset, int qlength, long timestamp, byte[] value, int voffset, int vlength) CellCreator.create(byte[] row, int roffset, int rlength, byte[] family, int foffset, int flength, byte[] qualifier, int qoffset, int qlength, long timestamp, byte[] value, int voffset, int vlength, String visExpression) Deprecated.since 0.98.9CellCreator.create(byte[] row, int roffset, int rlength, byte[] family, int foffset, int flength, byte[] qualifier, int qoffset, int qlength, long timestamp, byte[] value, int voffset, int vlength, List<Tag> tags) static CellAttempt to filter out the keyvalueHFileInputFormat.HFileRecordReader.getCurrentValue()SyncTable.SyncMapper.CellScanner.nextCellInRow()Returns the next Cell in the current row or null iff none remain.Methods in org.apache.hadoop.hbase.mapreduce that return types with arguments of type CellModifier and TypeMethodDescriptionorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,Cell> HFileInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) org.apache.hadoop.mapreduce.RecordWriter<ImmutableBytesWritable,Cell> HFileOutputFormat2.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Methods in org.apache.hadoop.hbase.mapreduce with parameters of type CellModifier and TypeMethodDescriptionprotected voidImport.Importer.addPutToKv(Put put, Cell kv) private CellSyncTable.SyncMapper.checkAndResetTimestamp(Cell sourceCell) private intSyncTable.SyncMapper.compareCellKeysWithinRow(Cell c1, Cell c2) Compare families, qualifiers, and timestamps of the given Cells.private static CellCellSerialization.CellDeserializer.deserialize(Cell ignore) protected booleanWALPlayer.WALMapper.filter(org.apache.hadoop.mapreduce.Mapper<WALKey, WALEdit, ImmutableBytesWritable, Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context, Cell cell) static CellAttempt to filter out the keyvalueintImport.CellWritableComparablePartitioner.getPartition(Import.CellWritableComparable key, Cell value, int numPartitions) voidMethod parameters in org.apache.hadoop.hbase.mapreduce with type arguments of type CellModifier and TypeMethodDescriptionCellSerialization.getDeserializer(Class<Cell> t) CellSerialization.getSerializer(Class<Cell> c) protected voidCellSortReducer.reduce(ImmutableBytesWritable row, Iterable<Cell> kvs, org.apache.hadoop.mapreduce.Reducer<ImmutableBytesWritable, Cell, ImmutableBytesWritable, Cell>.org.apache.hadoop.mapreduce.Reducer.Context context) protected voidImport.CellReducer.reduce(Import.CellWritableComparable row, Iterable<Cell> kvs, org.apache.hadoop.mapreduce.Reducer<Import.CellWritableComparable, Cell, ImmutableBytesWritable, Cell>.org.apache.hadoop.mapreduce.Reducer.Context context) Constructors in org.apache.hadoop.hbase.mapreduce with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.master.region
Fields in org.apache.hadoop.hbase.master.region with type parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.mob
Fields in org.apache.hadoop.hbase.mob declared as CellMethods in org.apache.hadoop.hbase.mob that return CellModifier and TypeMethodDescriptionstatic CellMobUtils.createMobRefCell(Cell cell, byte[] fileName, byte[] refCellTags) static CellMobUtils.createMobRefCell(Cell cell, byte[] fileName, Tag tableNameTag) Creates a mob reference KeyValue.MobCell.getCell()Methods in org.apache.hadoop.hbase.mob with parameters of type CellModifier and TypeMethodDescriptionstatic CellMobUtils.createMobRefCell(Cell cell, byte[] fileName, byte[] refCellTags) static CellMobUtils.createMobRefCell(Cell cell, byte[] fileName, Tag tableNameTag) Creates a mob reference KeyValue.static StringMobUtils.getMobFileName(Cell cell) Gets the mob file name from the mob ref cell.static intMobUtils.getMobValueLength(Cell cell) Gets the mob value length from the mob ref cell.MobUtils.getTableName(Cell cell) Get the table name from when this cell was written into a mob hfile as a TableName.MobUtils.getTableNameString(Cell cell) Gets the table name from when this cell was written into a mob hfile as a string.MobUtils.getTableNameTag(Cell cell) Gets the table name tag.static booleanMobUtils.hasValidMobRefCellValue(Cell cell) Indicates whether the current mob ref cell has a valid value.static booleanMobUtils.isMobReferenceCell(Cell cell) Whether the current cell is a mob reference cell.Reads a cell from the mob file.Reads a cell from the mob file.Constructors in org.apache.hadoop.hbase.mob with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.procedure2.store.region
Methods in org.apache.hadoop.hbase.procedure2.store.region with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.quotas
Methods in org.apache.hadoop.hbase.quotas with parameters of type CellModifier and TypeMethodDescriptionprotected static StringQuotaTableUtil.extractSnapshotNameFromSizeCell(Cell c) (package private) static longQuotaTableUtil.parseSnapshotSize(Cell c) Parses the snapshot size from the given Cell's value. -
Uses of Cell in org.apache.hadoop.hbase.regionserver
Classes in org.apache.hadoop.hbase.regionserver that implement CellModifier and TypeClassDescriptionclassByteBuffer based cell which has the chunkid at the 0th offsetclassByteBuffer based cell which has the chunkid at the 0th offset and with no tagsFields in org.apache.hadoop.hbase.regionserver declared as CellModifier and TypeFieldDescriptionprivate final Cell[]CellArrayMap.blockprivate final CellCellFlatMap.CellFlatMapEntry.cellprivate CellStoreFileScanner.curprotected CellSegmentScanner.currentprivate CellSnapshotSegmentScanner.currentprivate CellStoreFileScanner.delayedSeekKVprotected CellRegionScannerImpl.joinedContinuationRowIf the joined heap data gathering is interrupted due to scan limits, this will contain the row for which we are populating the values.private CellSegmentScanner.lastprivate CellStripeMultiFileWriter.BoundaryMultiWriter.lastCellprivate CellStripeMultiFileWriter.SizeMultiWriter.lastCellprivate CellScannerContext.lastPeekedCellstatic final CellKeyValueScanner.NO_NEXT_INDEXED_KEYThe byte array represents for NO_NEXT_INDEXED_KEY; The actual value is irrelevant because this is always compared by reference.private CellStoreScanner.prevCellprivate CellStoreFileScanner.previousRowprivate CellSegmentScanner.stopSkippingKVsRowFields in org.apache.hadoop.hbase.regionserver with type parameters of type CellModifier and TypeFieldDescriptionprivate final Comparator<? super Cell>CellFlatMap.comparatorprivate final NavigableMap<Cell,Cell> CellSet.delegateeprivate final NavigableMap<Cell,Cell> CellSet.delegateeHStoreFile.firstKeySegmentScanner.iterSnapshotSegmentScanner.iterMemStoreCompactorSegmentsIterator.kvsMemStoreCompactorSegmentsIterator.kvsIteratorHStoreFile.lastKeyRegionScannerImpl.MOCKED_LISTA mocked list implementation - discards all updates.Methods in org.apache.hadoop.hbase.regionserver that return CellModifier and TypeMethodDescriptionCellFlatMap.ceilingKey(Cell k) private CellMemStoreLABImpl.copyBBECellInto(ByteBufferExtendedCell cell, int maxAlloc) Mostly a duplicate ofMemStoreLABImpl.copyCellInto(Cell, int)} done for perf sake.private static CellMemStoreLABImpl.copyBBECToChunkCell(ByteBufferExtendedCell cell, ByteBuffer buf, int offset, int len) Clone the passed cell by copying its data into the passed buf and create a cell with a chunkid out of itImmutableMemStoreLAB.copyCellInto(Cell cell) MemStoreLAB.copyCellInto(Cell cell) Allocates slice in this LAB and copy the passed Cell into this area.MemStoreLABImpl.copyCellInto(Cell cell) private CellMemStoreLABImpl.copyCellInto(Cell cell, int maxAlloc) private CellCellChunkImmutableSegment.copyCellIntoMSLAB(Cell cell, MemStoreSizing memstoreSizing) private static CellMemStoreLABImpl.copyToChunkCell(Cell cell, ByteBuffer buf, int offset, int len) Clone the passed cell by copying its data into the passed buf and create a cell with a chunkid out of itprivate static CellMemStoreLABImpl.createChunkCell(ByteBuffer buf, int offset, int len, int tagsLen, long sequenceId) private static CellAbstractMemStore.deepCopyIfNeeded(Cell cell) CellSet.first()(package private) CellMutableSegment.first()Returns the first cell in the segmentCellFlatMap.firstKey()ImmutableMemStoreLAB.forceCopyOfBigCellInto(Cell cell) The process of merging assumes all cells are allocated on mslab.MemStoreLAB.forceCopyOfBigCellInto(Cell cell) Allocates slice in this LAB and copy the passed Cell into this area.MemStoreLABImpl.forceCopyOfBigCellInto(Cell cell) When a cell's size is too big (bigger than maxAlloc), copyCellInto does not allocate it on MSLAB.protected CellCellArrayMap.getCell(int i) protected CellCellChunkMap.getCell(int i) protected abstract CellCellFlatMap.getCell(int i) private CellSegmentScanner.getHighest(Cell first, Cell second) Private internal method that returns the higher of the two key values, or null if they are both nullCellFlatMap.CellFlatMapEntry.getKey()(package private) CellScannerContext.getLastPeekedCell()protected CellKeyValueHeap.getNextIndexedKey()KeyValueScanner.getNextIndexedKey()NonLazyKeyValueScanner.getNextIndexedKey()SegmentScanner.getNextIndexedKey()StoreFileScanner.getNextIndexedKey()StoreScanner.getNextIndexedKey()protected CellAbstractMemStore.getNextRow(Cell key, NavigableSet<Cell> set) (package private) CellCompactingMemStore.getNextRow(Cell cell) (package private) CellDefaultMemStore.getNextRow(Cell cell) CellFlatMap.CellFlatMapEntry.getValue()CellSet.last()CompositeImmutableSegment.last()Segment.last()CellFlatMap.lastKey()private CellAbstractMemStore.maybeCloneWithAllocator(MutableSegment currentActive, Cell cell, boolean forceCloneOfBigCell) If the segment has a memory allocator the cell is being cloned to this space, and returned; Otherwise the given cell is returned When a cell's size is too big (bigger than maxAlloc), it is not allocated on MSLAB.CompositeImmutableSegment.maybeCloneWithAllocator(Cell cell, boolean forceCloneOfBigCell) If the segment has a memory allocator the cell is being cloned to this space, and returned; otherwise the given cell is returnedSegment.maybeCloneWithAllocator(Cell cell, boolean forceCloneOfBigCell) If the segment has a memory allocator the cell is being cloned to this space, and returned; otherwise the given cell is returned When a cell's size is too big (bigger than maxAlloc), it is not allocated on MSLAB.CellFlatMap.CellFlatMapIterator.next()KeyValueHeap.next()KeyValueScanner.next()Return the next Cell in this scanner, iterating the scannerMemStoreCompactorSegmentsIterator.next()MemStoreMergerSegmentsIterator.next()ReversedKeyValueHeap.next()SegmentScanner.next()Return the next Cell in this scanner, iterating the scannerSnapshotSegmentScanner.next()StoreFileScanner.next()KeyValueHeap.peek()KeyValueScanner.peek()Look at the next Cell in this scanner, but do not iterate scanner.SegmentScanner.peek()Look at the next Cell in this scanner, but do not iterate the scannerSnapshotSegmentScanner.peek()StoreFileScanner.peek()StoreScanner.peek()CellSet.pollFirst()CellSet.pollLast()private static CellHRegion.MutationBatchOperation.reckonDelta(Cell delta, Cell currentCell, byte[] columnFamily, long now, Mutation mutation, Function<Cell, byte[]> supplier) Methods in org.apache.hadoop.hbase.regionserver that return types with arguments of type CellModifier and TypeMethodDescriptionCellFlatMap.ceilingEntry(Cell k) CellFlatMap.ceilingEntry(Cell k) Comparator<? super Cell>CellFlatMap.comparator()Comparator<? super Cell>CellSet.comparator()SnapshotSegmentScanner.createIterator(Segment segment) CellSet.descendingIterator()CellFlatMap.descendingKeySet()CellFlatMap.descendingMap()CellFlatMap.descendingMap()CellSet.descendingSet()CellFlatMap.entrySet()CellFlatMap.entrySet()CellFlatMap.firstEntry()CellFlatMap.firstEntry()CellFlatMap.floorEntry(Cell k) CellFlatMap.floorEntry(Cell k) Do a get based on the get parameter.(package private) NavigableMap<Cell,Cell> CellSet.getDelegatee()(package private) NavigableMap<Cell,Cell> CellSet.getDelegatee()HStoreFile.getFirstKey()StoreFile.getFirstKey()Get the first key in this store file.StoreFileReader.getFirstKey()HRegion.getInternal(Get get, boolean withCoprocessor, long nonceGroup, long nonce) SegmentScanner.getIterator(Cell cell) HStoreFile.getLastKey()StoreFile.getLastKey()Get the last key in this store file.StoreFileReader.getLastKey()CellFlatMap.higherEntry(Cell k) CellFlatMap.higherEntry(Cell k) CellFlatMap.CellFlatMapCollection.iterator()CellSet.iterator()CompositeImmutableSegment.iterator()Segment.iterator()CellFlatMap.keySet()CellFlatMap.lastEntry()CellFlatMap.lastEntry()CellFlatMap.lowerEntry(Cell k) CellFlatMap.lowerEntry(Cell k) StoreFileReader.midKey()CellFlatMap.navigableKeySet()CellFlatMap.pollFirstEntry()CellFlatMap.pollFirstEntry()CellFlatMap.pollLastEntry()CellFlatMap.pollLastEntry()HRegion.MutationBatchOperation.reckonDeltas(Mutation mutation, List<Cell> results, long now) HRegion.MutationBatchOperation.reckonDeltasByStore(HStore store, Mutation mutation, long now, List<Cell> deltas, List<Cell> results) Reckon the Cells to apply to WAL, memstore, and to return to the Client in passed column family/Store.Returns a subset of the segment cell set, which starts with the given cellReturns a subset of the segment cell set, which starts with the given cellCellFlatMap.values()Methods in org.apache.hadoop.hbase.regionserver with parameters of type CellModifier and TypeMethodDescriptionvoidAbstractMemStore.add(Cell cell, MemStoreSizing memstoreSizing) booleanbooleanvoidHStore.add(Cell cell, MemStoreSizing memstoreSizing) Adds a value to the memstorevoidMemStore.add(Cell cell, MemStoreSizing memstoreSizing) Write an updatevoidMutableSegment.add(Cell cell, boolean mslabUsed, MemStoreSizing memStoreSizing, boolean sizeAddedPreOperation) Adds the given cell into the segmentvoidAppend the given cellvoidvoidvoidvoidprivate voidStoreFileWriter.appendDeleteFamilyBloomFilter(Cell cell) private voidStoreFileWriter.appendGeneralBloomfilter(Cell cell) private voidHRegion.applyToMemStore(HStore store, Cell cell, MemStoreSizing memstoreAccounting) booleanKeyValueScanner.backwardSeek(Cell key) Seek the scanner at or before the row of specified Cell, it firstly tries to seek the scanner at or after the specified Cell, return if peek KeyValue of scanner has the same row with specified Cell, otherwise seek the scanner at the first Cell of the row which is the previous row of specified KeyValuebooleanNonReversedNonLazyKeyValueScanner.backwardSeek(Cell key) booleanReversedKeyValueHeap.backwardSeek(Cell seekKey) booleanReversedStoreScanner.backwardSeek(Cell key) booleanSegmentScanner.backwardSeek(Cell key) Seek the scanner at or before the row of specified Cell, it firstly tries to seek the scanner at or after the specified Cell, return if peek KeyValue of scanner has the same row with specified Cell, otherwise seek the scanner at the first Cell of the row which is the previous row of specified KeyValuebooleanStoreFileScanner.backwardSeek(Cell key) CellFlatMap.ceilingEntry(Cell k) CellFlatMap.ceilingKey(Cell k) protected booleanCompactingMemStore.checkAndAddToActiveSize(MutableSegment currActive, Cell cellToAdd, MemStoreSizing memstoreSizing) Check whether anything need to be done based on the current active set size.private booleanStoreFileReader.checkGeneralBloomFilter(byte[] key, Cell kvKey, BloomFilter bloomFilter) protected voidReversedStoreScanner.checkScanOrder(Cell prevKV, Cell kv, CellComparator comparator) protected voidStoreScanner.checkScanOrder(Cell prevKV, Cell kv, CellComparator comparator) Check whether scan as expected orderintintCompares two KeyValueintintCompositeImmutableSegment.compareRows(Cell left, Cell right) intReversedKeyValueHeap.ReversedKVScannerComparator.compareRows(Cell left, Cell right) Compares rows of two KeyValueintSegment.compareRows(Cell left, Cell right) ImmutableMemStoreLAB.copyCellInto(Cell cell) MemStoreLAB.copyCellInto(Cell cell) Allocates slice in this LAB and copy the passed Cell into this area.MemStoreLABImpl.copyCellInto(Cell cell) private CellMemStoreLABImpl.copyCellInto(Cell cell, int maxAlloc) private CellCellChunkImmutableSegment.copyCellIntoMSLAB(Cell cell, MemStoreSizing memstoreSizing) private static CellMemStoreLABImpl.copyToChunkCell(Cell cell, ByteBuffer buf, int offset, int len) Clone the passed cell by copying its data into the passed buf and create a cell with a chunkid out of itprivate static CellAbstractMemStore.deepCopyIfNeeded(Cell cell) protected voidAbstractMemStore.doAdd(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) private voidAbstractMemStore.doAddOrUpsert(Cell cell, long readpoint, MemStoreSizing memstoreSizing, boolean doAdd) static booleanNonLazyKeyValueScanner.doRealSeek(KeyValueScanner scanner, Cell kv, boolean forward) private voidAbstractMemStore.doUpsert(MutableSegment currentActive, Cell cell, long readpoint, MemStoreSizing memstoreSizing) MobReferenceOnlyFilter.filterCell(Cell cell) private booleanRegionScannerImpl.filterRowKey(Cell current) private intBinary search for a given key in between given boundaries of the array.CellFlatMap.floorEntry(Cell k) ImmutableMemStoreLAB.forceCopyOfBigCellInto(Cell cell) The process of merging assumes all cells are allocated on mslab.MemStoreLAB.forceCopyOfBigCellInto(Cell cell) Allocates slice in this LAB and copy the passed Cell into this area.MemStoreLABImpl.forceCopyOfBigCellInto(Cell cell) When a cell's size is too big (bigger than maxAlloc), copyCellInto does not allocate it on MSLAB.private booleanKeyValueHeap.generalizedSeek(boolean isLazy, Cell seekKey, boolean forward, boolean useBloom) (package private) static intSegment.getCellLength(Cell cell) Get cell length after serialized inKeyValueprivate CellSegmentScanner.getHighest(Cell first, Cell second) Private internal method that returns the higher of the two key values, or null if they are both nullSegmentScanner.getIterator(Cell cell) private static longHRegion.MutationBatchOperation.getLongValue(Cell cell) Returns Get the long out of the passed in Cellprotected Cellprotected CellAbstractMemStore.getNextRow(Cell key, NavigableSet<Cell> set) (package private) CellCompactingMemStore.getNextRow(Cell cell) (package private) CellDefaultMemStore.getNextRow(Cell cell) private HStoreReturn HStore instance.private intCellFlatMap.getValidIndex(Cell key, boolean inclusive, boolean tail) Get the index of the given anchor key for creating subsequent set.protected longSegment.heapSizeChange(Cell cell, boolean allocated) CellFlatMap.higherEntry(Cell k) voidTimeRangeTracker.includeTimestamp(Cell cell) Update the current TimestampRange to include the timestamp fromcell.private voidAbstractMemStore.internalAdd(MutableSegment currentActive, Cell toAdd, boolean mslabUsed, MemStoreSizing memstoreSizing) protected voidCompositeImmutableSegment.internalAdd(Cell cell, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected voidSegment.internalAdd(Cell cell, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) private booleanStripeMultiFileWriter.BoundaryMultiWriter.isCellAfterCurrentWriter(Cell cell) private static final booleanprivate booleanStoreFileScanner.isStillAtSeekTargetAfterSkippingNewerKvs(Cell seekKey) private booleanRegionScannerImpl.joinedHeapMayHaveData(Cell currentRowCell) Returns true when the joined heap may have data for the current rowCellFlatMap.lowerEntry(Cell k) private CellAbstractMemStore.maybeCloneWithAllocator(MutableSegment currentActive, Cell cell, boolean forceCloneOfBigCell) If the segment has a memory allocator the cell is being cloned to this space, and returned; Otherwise the given cell is returned When a cell's size is too big (bigger than maxAlloc), it is not allocated on MSLAB.CompositeImmutableSegment.maybeCloneWithAllocator(Cell cell, boolean forceCloneOfBigCell) If the segment has a memory allocator the cell is being cloned to this space, and returned; otherwise the given cell is returnedSegment.maybeCloneWithAllocator(Cell cell, boolean forceCloneOfBigCell) If the segment has a memory allocator the cell is being cloned to this space, and returned; otherwise the given cell is returned When a cell's size is too big (bigger than maxAlloc), it is not allocated on MSLAB.private booleanRegionScannerImpl.moreCellsInRow(Cell nextKv, Cell currentRowCell) Based on the nextKv in the heap, and the current row, decide whether or not there are more cells to be read in the heap.protected booleanRegionScannerImpl.nextRow(ScannerContext scannerContext, Cell curRowCell) protected booleanReversedRegionScannerImpl.nextRow(ScannerContext scannerContext, Cell curRowCell) private final intStripeStoreFileManager.nonOpenRowCompare(Cell k1, byte[] k2) protected longSegment.offHeapSizeChange(Cell cell, boolean allocated) private voidStoreScanner.parallelSeek(List<? extends KeyValueScanner> scanners, Cell kv) Seek storefiles in parallel to optimize IO latency as much as possiblebooleanStoreFileReader.passesGeneralRowColBloomFilter(Cell cell) A method for checking Bloom filters.private booleanRegionScannerImpl.populateResult(List<Cell> results, KeyValueHeap heap, ScannerContext scannerContext, Cell currentRowCell) Fetches records with currentRow into results list, until next row, batchLimit (if not -1) is reached, or remainingResultSize (if not -1) is reacedbooleanRegionCoprocessorHost.postScannerFilterRow(InternalScanner s, Cell curRowCell) This will be called by the scan flow when the current scanned row is being filtered out by the filter.private voidStripeMultiFileWriter.BoundaryMultiWriter.prepareWriterFor(Cell cell) booleanRegionCoprocessorHost.prePrepareTimeStampForDeleteVersion(Mutation mutation, Cell kv, byte[] byteNow, Get get) Deprecated.In hbase-2.0.0.protected abstract booleanAbstractMemStore.preUpdate(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) Issue any synchronization and test needed before applying the updateprotected booleanCompactingMemStore.preUpdate(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) Issue any synchronization and test needed before applying the update For compacting memstore this means checking the update can increase the size without overflowprotected booleanDefaultMemStore.preUpdate(MutableSegment currentActive, Cell cell, MemStoreSizing memstoreSizing) private MobCellHMobStore.readCell(List<org.apache.hadoop.fs.Path> locations, String fileName, Cell search, boolean cacheMobBlocks, long readPt, boolean readEmptyValueOnMobCellMiss) Reads the cell from a mob file.private static CellHRegion.MutationBatchOperation.reckonDelta(Cell delta, Cell currentCell, byte[] columnFamily, long now, Mutation mutation, Function<Cell, byte[]> supplier) booleanKeyValueHeap.requestSeek(Cell key, boolean forward, boolean useBloom) Similar toKeyValueScanner.seek(org.apache.hadoop.hbase.Cell)(orKeyValueScanner.reseek(org.apache.hadoop.hbase.Cell)if forward is true) but only does a seek operation after checking that it is really necessary for the row/column combination specified by the kv parameter.booleanKeyValueScanner.requestSeek(Cell kv, boolean forward, boolean useBloom) Similar toKeyValueScanner.seek(org.apache.hadoop.hbase.Cell)(orKeyValueScanner.reseek(org.apache.hadoop.hbase.Cell)if forward is true) but only does a seek operation after checking that it is really necessary for the row/column combination specified by the kv parameter.booleanNonLazyKeyValueScanner.requestSeek(Cell kv, boolean forward, boolean useBloom) booleanReversedKeyValueHeap.requestSeek(Cell key, boolean forward, boolean useBloom) booleanSegmentScanner.requestSeek(Cell c, boolean forward, boolean useBloom) booleanStoreFileScanner.requestSeek(Cell kv, boolean forward, boolean useBloom) Pretend we have done a seek but don't do it yet, if possible.booleanThis function is identical to theKeyValueHeap.seek(Cell)function except that scanner.seek(seekKey) is changed to scanner.reseek(seekKey).booleanReseek the scanner at or after the specified KeyValue.booleanbooleanbooleanReseek the scanner at or after the specified KeyValue.booleanbooleanbooleanprivate booleanStoreFileScanner.reseekAtOrAfter(Cell seekKey) (package private) static booleanStoreFileScanner.reseekAtOrAfter(HFileScanner s, Cell k) private voidStoreScanner.resetQueryMatcher(Cell lastTopKey) Reads the cell from the mob file, and the read point does not count.Reads the cell from the mob file with readEmptyValueOnMobCellMissHMobStore.resolve(Cell reference, boolean cacheBlocks, long readPt, boolean readEmptyValueOnMobCellMiss) Reads the cell from the mob file.protected voidHRegion.restoreEdit(HStore s, Cell cell, MemStoreSizing memstoreAccounting) Used by testsprotected voidStripeMultiFileWriter.sanityCheckLeft(byte[] left, Cell cell) Subclasses can call this method to make sure the first KV is within multi-writer range.protected voidStripeMultiFileWriter.sanityCheckRight(byte[] right, Cell cell) Subclasses can call this method to make sure the last KV is within multi-writer range.booleanSeeks all scanners at or below the specified seek key.booleanSeek the scanner at or after the specified KeyValue.booleanbooleanbooleanSeek the scanner at or after the specified Cell.booleanbooleanbooleanprotected booleanReversedStoreScanner.seekAsDirection(Cell kv) Do a backwardSeek in a reversed StoreScanner(scan backward)protected booleanStoreScanner.seekAsDirection(Cell kv) Do a reseek in a normal StoreScanner(scan forward)private booleanStoreFileScanner.seekAtOrAfter(Cell seekKey) static booleanStoreFileScanner.seekAtOrAfter(HFileScanner s, Cell k) Returns false if not found or if k is after the end.private booleanStoreFileScanner.seekBefore(Cell seekKey) private voidStoreFileScanner.seekBeforeAndSaveKeyToPreviousRow(Cell seekKey) Seeks before the seek target cell and saves the location toStoreFileScanner.previousRow.private voidStoreScanner.seekOrSkipToNextColumn(Cell cell) private voidStoreScanner.seekOrSkipToNextRow(Cell cell) protected voidReversedStoreScanner.seekScanners(List<? extends KeyValueScanner> scanners, Cell seekKey, boolean isLazy, boolean isParallelSeek) protected voidStoreScanner.seekScanners(List<? extends KeyValueScanner> scanners, Cell seekKey, boolean isLazy, boolean isParallelSeek) Seek the specified scanners with the given keyprotected booleanReversedStoreScanner.seekToNextRow(Cell kv) protected booleanStoreScanner.seekToNextRow(Cell c) booleanKeyValueScanner.seekToPreviousRow(Cell key) Seek the scanner at the first Cell of the row which is the previous row of specified keybooleanNonReversedNonLazyKeyValueScanner.seekToPreviousRow(Cell key) booleanReversedKeyValueHeap.seekToPreviousRow(Cell seekKey) booleanReversedStoreScanner.seekToPreviousRow(Cell key) booleanSegmentScanner.seekToPreviousRow(Cell cell) Seek the scanner at the first Cell of the row which is the previous row of specified keybooleanStoreFileScanner.seekToPreviousRow(Cell originalKey) private booleanStoreFileScanner.seekToPreviousRowStateless(Cell originalKey) This variant of theStoreFileScanner.seekToPreviousRow(Cell)method requires two seeks.private booleanStoreFileScanner.seekToPreviousRowWithoutHint(Cell originalKey) This variant of theStoreFileScanner.seekToPreviousRow(Cell)method requires two seeks and one reseek.protected voidStoreFileScanner.setCurrentCell(Cell newVal) (package private) voidScannerContext.setLastPeekedCell(Cell lastPeekedCell) protected booleanRegionScannerImpl.shouldStop(Cell currentRowCell) protected booleanReversedRegionScannerImpl.shouldStop(Cell currentRowCell) Returns a subset of the segment cell set, which starts with the given cellReturns a subset of the segment cell set, which starts with the given cellvoidStoreFileWriter.trackTimestamps(Cell cell) Record the earlest Put timestamp.protected booleanStoreScanner.trySkipToNextColumn(Cell cell) protected booleanStoreScanner.trySkipToNextRow(Cell cell) See if we should actually SEEK or rather just SKIP to the next Cell (see HBASE-13109).DefaultStoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles, KeyValue targetKey, Cell candidate) StoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles, KeyValue targetKey, Cell candidate) Updates the candidate list for finding row key before.StripeStoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator<HStoreFile> candidateFiles, KeyValue targetKey, Cell candidate) SeeStoreFileManager.getCandidateFilesForRowKeyBefore(KeyValue)andStoreFileManager.updateCandidateFilesForRowKeyBefore(Iterator, KeyValue, Cell)for details on this methods.private voidHRegion.updateDeleteLatestVersionTimestamp(Cell cell, Get get, int count, byte[] byteNow) protected voidCompositeImmutableSegment.updateMetaInfo(Cell cellToAdd, boolean succ, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected voidSegment.updateMetaInfo(Cell cellToAdd, boolean succ, boolean mslabUsed, MemStoreSizing memstoreSizing, boolean sizeAddedPreOperation) protected voidSegment.updateMetaInfo(Cell cellToAdd, boolean succ, MemStoreSizing memstoreSizing) private voidAbstractMemStore.upsert(Cell cell, long readpoint, MemStoreSizing memstoreSizing) voidMutableSegment.upsert(Cell cell, long readpoint, MemStoreSizing memStoreSizing, boolean sizeAddedPreOperation) Method parameters in org.apache.hadoop.hbase.regionserver with type arguments of type CellModifier and TypeMethodDescriptionvoidAbstractMemStore.add(Iterable<Cell> cells, MemStoreSizing memstoreSizing) voidHStore.add(Iterable<Cell> cells, MemStoreSizing memstoreSizing) Adds the specified value to the memstorevoidMemStore.add(Iterable<Cell> cells, MemStoreSizing memstoreSizing) Write the updatesbooleanCellFlatMap.CellFlatMapCollection.addAll(Collection<? extends Cell> collection) booleanCellSet.addAll(Collection<? extends Cell> c) protected voidHRegion.BatchOperation.applyFamilyMapToMemStore(Map<byte[], List<Cell>> familyMap, MemStoreSizing memstoreAccounting) Atomically apply the given map of family->edits to the memstore.private voidHRegion.applyToMemStore(HStore store, List<Cell> cells, boolean delta, MemStoreSizing memstoreAccounting) voidHRegion.checkTimestamps(Map<byte[], List<Cell>> familyMap, long now) Check the collection of families for valid timestampsprotected CellAbstractMemStore.getNextRow(Cell key, NavigableSet<Cell> set) private voidHRegion.MutationBatchOperation.mergeFamilyMaps(Map<byte[], List<Cell>> familyMap, Map<byte[], List<Cell>> toBeMerged) (package private) voidHRegion.metricsUpdateForGet(List<Cell> results, long before) private ScannerContext.NextStateStoreScanner.needToReturn(List<Cell> outResult) If the top cell won't be flushed into disk, the new top cell may be changed after #reopenAfterFlush.default booleanGrab the next row's worth of values.booleanInternalScanner.next(List<Cell> result, ScannerContext scannerContext) Grab the next row's worth of values.booleanKeyValueHeap.next(List<Cell> result, ScannerContext scannerContext) Gets the next row of keys from the top-most scanner.booleanMobStoreScanner.next(List<Cell> outResult, ScannerContext ctx) Firstly reads the cells from the HBase.booleanbooleanRegionScannerImpl.next(List<Cell> outResults, ScannerContext scannerContext) booleanReversedMobStoreScanner.next(List<Cell> outResult, ScannerContext ctx) Firstly reads the cells from the HBase.booleanStoreScanner.next(List<Cell> outResult, ScannerContext scannerContext) Get the next row of values from this Store.private booleanRegionScannerImpl.nextInternal(List<Cell> results, ScannerContext scannerContext) booleanGrab the next row's worth of values.booleanRegionScanner.nextRaw(List<Cell> result, ScannerContext scannerContext) Grab the next row's worth of values.booleanbooleanRegionScannerImpl.nextRaw(List<Cell> outResults, ScannerContext scannerContext) private booleanRegionScannerImpl.populateFromJoinedHeap(List<Cell> results, ScannerContext scannerContext) Returns true if more cells exist after this batch, false if scanner is doneprivate booleanRegionScannerImpl.populateResult(List<Cell> results, KeyValueHeap heap, ScannerContext scannerContext, Cell currentRowCell) Fetches records with currentRow into results list, until next row, batchLimit (if not -1) is reached, or remainingResultSize (if not -1) is reacedvoidbooleanSupports Coprocessor 'bypass'.private voidHRegion.prepareDeleteTimestamps(Mutation mutation, Map<byte[], List<Cell>> familyMap, byte[] byteNow) Set up correct timestamps in the KVs in Delete object.voidvoidprivate static CellHRegion.MutationBatchOperation.reckonDelta(Cell delta, Cell currentCell, byte[] columnFamily, long now, Mutation mutation, Function<Cell, byte[]> supplier) HRegion.MutationBatchOperation.reckonDeltas(Mutation mutation, List<Cell> results, long now) HRegion.MutationBatchOperation.reckonDeltasByStore(HStore store, Mutation mutation, long now, List<Cell> deltas, List<Cell> results) Reckon the Cells to apply to WAL, memstore, and to return to the Client in passed column family/Store.private voidHRegion.recordMutationWithoutWal(Map<byte[], List<Cell>> familyMap) Update LongAdders for number of puts without wal and the size of possible data loss.private voidHRegion.rewriteCellTags(Map<byte[], List<Cell>> familyMap, Mutation m) Possibly rewrite incoming cell tags.private static voidHRegion.updateCellTimestamps(Iterable<List<Cell>> cellItr, byte[] now) Replace any cell timestamps set toHConstants.LATEST_TIMESTAMPprovided current timestamp.private voidHRegion.updateSequenceId(Iterable<List<Cell>> cellItr, long sequenceId) voidAbstractMemStore.upsert(Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing) voidHStore.upsert(Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing) Adds or replaces the specified KeyValues.voidMemStore.upsert(Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing) Update or insert the specified cells.Constructors in org.apache.hadoop.hbase.regionserver with parameters of type CellModifierConstructorDescriptionCellArrayMap(Comparator<? super Cell> comparator, Cell[] b, int min, int max, boolean descending) CellFlatMapEntry(Cell cell) Constructor parameters in org.apache.hadoop.hbase.regionserver with type arguments of type CellModifierConstructorDescriptionCellArrayMap(Comparator<? super Cell> comparator, Cell[] b, int min, int max, boolean descending) CellChunkMap(Comparator<? super Cell> comparator, Chunk[] chunks, int min, int max, boolean descending) C-tor for creating CellChunkMap from existing Chunk array, which must be ordered (decreasingly or increasingly according to parameter "descending")CellFlatMap(Comparator<? super Cell> comparator, int min, int max, boolean d) (package private)CellSet(NavigableMap<Cell, Cell> m) (package private)CellSet(NavigableMap<Cell, Cell> m) (package private)CellSet(NavigableMap<Cell, Cell> m, int numUniqueKeys) (package private)CellSet(NavigableMap<Cell, Cell> m, int numUniqueKeys) -
Uses of Cell in org.apache.hadoop.hbase.regionserver.handler
Fields in org.apache.hadoop.hbase.regionserver.handler declared as CellConstructors in org.apache.hadoop.hbase.regionserver.handler with parameters of type CellModifierConstructorDescriptionParallelSeekHandler(KeyValueScanner scanner, Cell keyValue, long readPoint, CountDownLatch latch) -
Uses of Cell in org.apache.hadoop.hbase.regionserver.querymatcher
Fields in org.apache.hadoop.hbase.regionserver.querymatcher declared as CellModifier and TypeFieldDescriptionprivate CellScanWildcardColumnTracker.columnCellprivate CellUserScanQueryMatcher.curColCellprotected CellScanQueryMatcher.currentRowRow the query is onprotected CellScanDeleteTracker.deleteCellprotected final CellScanQueryMatcher.startKeyKey to seek to in memstore and StoreFilesMethods in org.apache.hadoop.hbase.regionserver.querymatcher that return CellModifier and TypeMethodDescriptionprivate static CellUserScanQueryMatcher.createStartKey(Scan scan, ScanInfo scanInfo) protected static CellScanQueryMatcher.createStartKeyFromRow(byte[] startRow, ScanInfo scanInfo) ScanQueryMatcher.currentRow()Returns a cell represent the current rowScanQueryMatcher.getKeyForNextColumn(Cell cell) CompactionScanQueryMatcher.getNextKeyHint(Cell cell) abstract CellScanQueryMatcher.getNextKeyHint(Cell cell) Delegate toFilter.getNextCellHint(Cell).UserScanQueryMatcher.getNextKeyHint(Cell cell) ScanQueryMatcher.getStartKey()Returns the start keyMethods in org.apache.hadoop.hbase.regionserver.querymatcher with parameters of type CellModifier and TypeMethodDescriptionvoidAdd the specified cell to the list of deletes to check against for this row operation.voidvoidAdd the specified Cell to the list of deletes to check against for this row operation.voidNewVersionBehaviorTracker.DeleteVersionsNode.addVersionDelete(Cell cell) ColumnTracker.checkColumn(Cell cell, byte type) Checks if the column is present in the list of requested columns by returning the match code instance.ExplicitColumnTracker.checkColumn(Cell cell, byte type) Checks if the column is present in the list of requested columns by returning the match code instance.NewVersionBehaviorTracker.checkColumn(Cell cell, byte type) ScanWildcardColumnTracker.checkColumn(Cell cell, byte type) Checks if the column is present in the list of requested columns by returning the match code instance.protected final ScanQueryMatcher.MatchCodeScanQueryMatcher.checkDeleted(DeleteTracker deletes, Cell cell) ColumnTracker.checkVersions(Cell cell, long timestamp, byte type, boolean ignoreCount) Keeps track of the number of versions for the columns asked for.ExplicitColumnTracker.checkVersions(Cell cell, long timestamp, byte type, boolean ignoreCount) NewVersionBehaviorTracker.checkVersions(Cell cell, long timestamp, byte type, boolean ignoreCount) ScanWildcardColumnTracker.checkVersions(Cell cell, long timestamp, byte type, boolean ignoreCount) Keeps track of the number of versions for the columns asked for.intScanQueryMatcher.compareKeyForNextColumn(Cell nextIndexed, Cell currentCell) intScanQueryMatcher.compareKeyForNextRow(Cell nextIndexed, Cell currentCell) default voidColumnTracker.doneWithColumn(Cell cell) This method is used to inform the column tracker that we are done with this column.voidExplicitColumnTracker.doneWithColumn(Cell cell) ScanQueryMatcher.getKeyForNextColumn(Cell cell) CompactionScanQueryMatcher.getNextKeyHint(Cell cell) abstract CellScanQueryMatcher.getNextKeyHint(Cell cell) Delegate toFilter.getNextCellHint(Cell).UserScanQueryMatcher.getNextKeyHint(Cell cell) ColumnTracker.getNextRowOrNextColumn(Cell cell) Retrieve the MatchCode for the next row or columnExplicitColumnTracker.getNextRowOrNextColumn(Cell cell) NewVersionBehaviorTracker.getNextRowOrNextColumn(Cell cell) ScanWildcardColumnTracker.getNextRowOrNextColumn(Cell cell) private static booleanScanQueryMatcher.isCellTTLExpired(Cell cell, long oldestTimestamp, long now) Returns true if the cell is expiredprivate booleanNewVersionBehaviorTracker.isColumnQualifierChanged(Cell cell) Check if the specified cell buffer has been deleted by a previously seen delete.This method is not idempotent, we will save some info to judge VERSION_MASKED.Check if the specified Cell buffer has been deleted by a previously seen delete.abstract ScanQueryMatcher.MatchCodeDetermines if the caller should do one of several things: seek/skip to the next row (MatchCode.SEEK_NEXT_ROW) seek/skip to the next column (MatchCode.SEEK_NEXT_COL) include the current KeyValue (MatchCode.INCLUDE) ignore the current KeyValue (MatchCode.SKIP) got to the next row (MatchCode.DONE)protected final ScanQueryMatcher.MatchCodeUserScanQueryMatcher.matchColumn(Cell cell, long timestamp, byte typeByte) private final ScanQueryMatcher.MatchCodeUserScanQueryMatcher.mergeFilterResponse(Cell cell, ScanQueryMatcher.MatchCode matchCode, Filter.ReturnCode filterResponse) Call this when scan has filter.booleanCompactionScanQueryMatcher.moreRowsMayExistAfter(Cell cell) abstract booleanScanQueryMatcher.moreRowsMayExistAfter(Cell cell) booleanUserScanQueryMatcher.moreRowsMayExistAfter(Cell cell) protected final ScanQueryMatcher.MatchCodeCheck before the delete logic.protected longReset the map if it is different with the last Cell.private voidvoidScanQueryMatcher.setToNewRow(Cell currentRow) Set the row when there is change in rowprotected final voidCompactionScanQueryMatcher.trackDelete(Cell cell) protected final ScanQueryMatcher.MatchCodeDropDeletesCompactionScanQueryMatcher.tryDropDelete(Cell cell) Constructors in org.apache.hadoop.hbase.regionserver.querymatcher with parameters of type CellModifierConstructorDescriptionprotectedScanQueryMatcher(Cell startKey, ScanInfo scanInfo, ColumnTracker columns, long oldestUnexpiredTS, long now) -
Uses of Cell in org.apache.hadoop.hbase.regionserver.throttle
Method parameters in org.apache.hadoop.hbase.regionserver.throttle with type arguments of type Cell -
Uses of Cell in org.apache.hadoop.hbase.regionserver.wal
Methods in org.apache.hadoop.hbase.regionserver.wal that return CellModifier and TypeMethodDescriptionprotected CellSecureWALCellCodec.EncryptedKvDecoder.parseCell()protected CellWALCellCodec.CompressedKvDecoder.parseCell()Methods in org.apache.hadoop.hbase.regionserver.wal with parameters of type CellModifier and TypeMethodDescriptionvoidvoidvoidprivate voidWALCellCodec.CompressedKvEncoder.writeCompressedValue(OutputStream out, Cell cell) Method parameters in org.apache.hadoop.hbase.regionserver.wal with type arguments of type CellModifier and TypeMethodDescription(package private) static Set<byte[]>FSWALEntry.collectFamilies(List<Cell> cells) static voidWALUtil.filterCells(WALEdit edit, Function<Cell, Cell> mapper) static voidWALUtil.filterCells(WALEdit edit, Function<Cell, Cell> mapper) -
Uses of Cell in org.apache.hadoop.hbase.replication
Methods in org.apache.hadoop.hbase.replication that return CellModifier and TypeMethodDescriptionBulkLoadCellFilter.filterCell(Cell cell, org.apache.hbase.thirdparty.com.google.common.base.Predicate<byte[]> famPredicate) Filters the bulk load cell using the supplied predicate.NamespaceTableCfWALEntryFilter.filterCell(WAL.Entry entry, Cell cell) ScopeWALEntryFilter.filterCell(WAL.Entry entry, Cell cell) WALCellFilter.filterCell(WAL.Entry entry, Cell cell) Applies the filter, possibly returning a different Cell instance.Methods in org.apache.hadoop.hbase.replication with parameters of type CellModifier and TypeMethodDescriptionprivate voidBulkLoadCellFilter.filterCell(Cell cell, org.apache.hbase.thirdparty.com.google.common.base.Predicate<byte[]> famPredicate) Filters the bulk load cell using the supplied predicate.NamespaceTableCfWALEntryFilter.filterCell(WAL.Entry entry, Cell cell) ScopeWALEntryFilter.filterCell(WAL.Entry entry, Cell cell) WALCellFilter.filterCell(WAL.Entry entry, Cell cell) Applies the filter, possibly returning a different Cell instance. -
Uses of Cell in org.apache.hadoop.hbase.replication.regionserver
Fields in org.apache.hadoop.hbase.replication.regionserver declared as CellModifier and TypeFieldDescriptionprivate CellSerialReplicationSourceWALReader.firstCellInEntryBeforeFilteringMethods in org.apache.hadoop.hbase.replication.regionserver with parameters of type CellModifier and TypeMethodDescriptionbooleanprivate booleanReplicationSink.isNewRowOrType(Cell previousCell, Cell cell) Returns True if we have crossed over onto a new row or typeprivate PutReplicationSink.processReplicationMarkerEntry(Cell cell) voidSerialReplicationChecker.waitUntilCanPush(WAL.Entry entry, Cell firstCellInEdit) -
Uses of Cell in org.apache.hadoop.hbase.rest
Fields in org.apache.hadoop.hbase.rest declared as CellModifier and TypeFieldDescriptionprivate CellRowResultGenerator.cacheprivate CellScannerResultGenerator.cacheFields in org.apache.hadoop.hbase.rest with type parameters of type CellMethods in org.apache.hadoop.hbase.rest that return CellMethods in org.apache.hadoop.hbase.rest with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.rest.model
Constructors in org.apache.hadoop.hbase.rest.model with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.security.access
Methods in org.apache.hadoop.hbase.security.access that return CellModifier and TypeMethodDescriptionprivate CellAccessController.createNewCellWithTags(Mutation mutation, Cell oldCell, Cell newCell) Methods in org.apache.hadoop.hbase.security.access that return types with arguments of type CellModifier and TypeMethodDescriptionAccessController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) AccessController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) AccessController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) AccessController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Methods in org.apache.hadoop.hbase.security.access with parameters of type CellModifier and TypeMethodDescriptionbooleanAuthManager.authorizeCell(User user, TableName table, Cell cell, Permission.Action action) Check if user has given action privilige in cell scope.private CellAccessController.createNewCellWithTags(Mutation mutation, Cell oldCell, Cell newCell) AccessControlFilter.filterCell(Cell cell) booleanAccessControlFilter.filterRowKey(Cell cell) static List<Permission>PermissionStorage.getCellPermissionsForUser(User user, Cell cell) private static Pair<String,Permission> PermissionStorage.parsePermissionRecord(byte[] entryName, Cell kv, byte[] cf, byte[] cq, boolean filterPerms, String filterUser) Method parameters in org.apache.hadoop.hbase.security.access with type arguments of type CellModifier and TypeMethodDescriptionprivate static voidAccessController.addCellPermissions(byte[] perms, Map<byte[], List<Cell>> familyMap) AccessController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) AccessController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) AccessController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) AccessController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) voidAccessController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) private voidAccessController.updateACL(RegionCoprocessorEnvironment e, Map<byte[], List<Cell>> familyMap) Writes all table ACLs for the tables in the given Map up into ZooKeeper znodes. -
Uses of Cell in org.apache.hadoop.hbase.security.visibility
Methods in org.apache.hadoop.hbase.security.visibility that return CellModifier and TypeMethodDescriptionprivate CellVisibilityController.createNewCellWithTags(Mutation mutation, Cell newCell) Methods in org.apache.hadoop.hbase.security.visibility that return types with arguments of type CellModifier and TypeMethodDescriptionDefaultVisibilityLabelServiceImpl.getExistingLabelsWithAuths()VisibilityController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Methods in org.apache.hadoop.hbase.security.visibility with parameters of type CellModifier and TypeMethodDescriptionvoidvoidvoidVisibilityNewVersionBehaivorTracker.VisibilityDeleteVersionsNode.addVersionDelete(Cell cell) VisibilityController.checkForReservedVisibilityTagPresence(Cell cell, Pair<Boolean, Tag> pair) Checks whether cell contains any tag with type as VISIBILITY_TAG_TYPE.private CellVisibilityController.createNewCellWithTags(Mutation mutation, Cell newCell) booleanEvaluates whether the passed cell passes Scan/Get Authorization.static ByteExtracts and partitions the visibility tags and nonVisibility Tagsprivate booleanVisibilityScanDeleteTracker.extractDeleteCellVisTags(Cell delCell, KeyValue.Type type) static ByteVisibilityUtils.extractVisibilityTags(Cell cell, List<Tag> tags) Extract the visibility tags of the given Cell into the given ListVisibilityController.DeleteVersionVisibilityExpressionFilter.filterCell(Cell cell) VisibilityLabelFilter.filterCell(Cell cell) booleanVisibilityController.DeleteVersionVisibilityExpressionFilter.filterRowKey(Cell cell) booleanVisibilityLabelFilter.filterRowKey(Cell cell) static booleanVisibilityUtils.isVisibilityTagsPresent(Cell cell) voidVisibilityController.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation delete, Cell cell, byte[] byteNow, Get get) private booleanVisibilityNewVersionBehaivorTracker.tagMatched(Cell put, VisibilityNewVersionBehaivorTracker.TagInfo delInfo) Method parameters in org.apache.hadoop.hbase.security.visibility with type arguments of type CellModifier and TypeMethodDescriptionDefaultVisibilityLabelServiceImpl.extractLabelsAndAuths(List<List<Cell>> labelDetails) VisibilityController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) voidVisibilityController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) Constructors in org.apache.hadoop.hbase.security.visibility with parameters of type Cell -
Uses of Cell in org.apache.hadoop.hbase.thrift
Methods in org.apache.hadoop.hbase.thrift with parameters of type CellModifier and TypeMethodDescriptionstatic List<org.apache.hadoop.hbase.thrift.generated.TCell>ThriftUtilities.cellFromHBase(Cell in) This utility method creates a list of Thrift TCell "struct" based on an Hbase Cell object.static List<org.apache.hadoop.hbase.thrift.generated.TCell>ThriftUtilities.cellFromHBase(Cell[] in) This utility method creates a list of Thrift TCell "struct" based on an Hbase Cell array. -
Uses of Cell in org.apache.hadoop.hbase.thrift2
Fields in org.apache.hadoop.hbase.thrift2 declared as CellMethods in org.apache.hadoop.hbase.thrift2 that return CellModifier and TypeMethodDescriptionstatic CellThriftUtilities.toCell(ExtendedCellBuilder cellBuilder, byte[] row, org.apache.hadoop.hbase.thrift2.generated.TColumnValue columnValue) -
Uses of Cell in org.apache.hadoop.hbase.util
Classes in org.apache.hadoop.hbase.util that implement CellModifier and TypeClassDescriptionclassA wrapper for a cell to be used with mapreduce, as the output value class for mappers/reducers.Fields in org.apache.hadoop.hbase.util declared as CellModifier and TypeFieldDescriptionprivate final CellMapReduceExtendedCell.cellprivate CellCollectionBackedScanner.currentFields in org.apache.hadoop.hbase.util with type parameters of type CellMethods in org.apache.hadoop.hbase.util that return CellModifier and TypeMethodDescriptionBloomContext.getLastCell()BloomFilterWriter.getPrevCell()Returns the previous cell written by this writerprivate CellRowPrefixFixedLengthBloomContext.getRowPrefixCell(Cell cell) CollectionBackedScanner.next()CollectionBackedScanner.peek()Methods in org.apache.hadoop.hbase.util with parameters of type CellModifier and TypeMethodDescriptionvoidstatic intBytes.binarySearch(byte[][] arr, Cell key, org.apache.hadoop.io.RawComparator<Cell> comparator) Deprecated.since 2.0.0 and will be removed in 3.0.0.static intBytes.binarySearch(Cell[] arr, Cell key, CellComparator comparator) Binary search for keys in indexes.booleanCheck if the specified key is contained in the bloom filter.static booleanBloomFilterUtil.contains(Cell cell, ByteBuff bloomBuf, int bloomOffset, int bloomSize, Hash hash, int hashCount, BloomType type) private CellRowPrefixFixedLengthBloomContext.getRowPrefixCell(Cell cell) protected abstract booleanReturns true if the cell is a new key as per the bloom typeprotected booleanprotected booleanbooleanprivate voidBloomContext.sanityCheck(Cell cell) booleanvoidBloomContext.writeBloom(Cell cell) Bloom information from the cell is retrievedvoidRowPrefixFixedLengthBloomContext.writeBloom(Cell cell) Method parameters in org.apache.hadoop.hbase.util with type arguments of type CellModifier and TypeMethodDescriptionstatic intBytes.binarySearch(byte[][] arr, Cell key, org.apache.hadoop.io.RawComparator<Cell> comparator) Deprecated.since 2.0.0 and will be removed in 3.0.0.Constructors in org.apache.hadoop.hbase.util with parameters of type CellModifierConstructorDescriptionCellHashKey(Cell cell) CollectionBackedScanner(CellComparator comparator, Cell... array) MapReduceExtendedCell(Cell cell) RowBloomHashKey(Cell cell) RowColBloomHashKey(Cell cell) Constructor parameters in org.apache.hadoop.hbase.util with type arguments of type CellModifierConstructorDescriptionCollectionBackedScanner(List<Cell> list) CollectionBackedScanner(List<Cell> list, CellComparator comparator) CollectionBackedScanner(SortedSet<Cell> set, CellComparator comparator) -
Uses of Cell in org.apache.hadoop.hbase.wal
Fields in org.apache.hadoop.hbase.wal with type parameters of type CellMethods in org.apache.hadoop.hbase.wal that return types with arguments of type CellMethods in org.apache.hadoop.hbase.wal with parameters of type CellModifier and TypeMethodDescriptionprivate WALEditstatic org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.BulkLoadDescriptorWALEdit.getBulkLoadDescriptor(Cell cell) Deserialized and returns a BulkLoadDescriptor from the passed in Cellstatic org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.CompactionDescriptorWALEdit.getCompaction(Cell kv) Deserialized and returns a CompactionDescriptor is the KeyValue contains one.static org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptorWALEdit.getFlushDescriptor(Cell cell) static org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.RegionEventDescriptorWALEdit.getRegionEventDescriptor(Cell cell) static booleanWALEdit.isCompactionMarker(Cell cell) Returns true if the given cell is a serializedWALProtos.CompactionDescriptorstatic booleanWALEdit.isMetaEditFamily(Cell cell) Replaying WALs can read Cell-at-a-time so need this method in those cases.WALPrettyPrinter.toStringMap(Cell cell) WALPrettyPrinter.toStringMap(Cell cell, boolean printRowKeyOnly, String rowPrefix, String row, boolean outputValues) Method parameters in org.apache.hadoop.hbase.wal with type arguments of type Cell