import org.apache.hadoop.hbase.util.Pair; //导入方法依赖的package包/类

/**

* Checks whether cell contains any tag with type as VISIBILITY_TAG_TYPE. This

* tag type is reserved and should not be explicitly set by user.

*

* @param cell

* - the cell under consideration

* @param pair - an optional pair of type which would be reused

* if already set and new one will be created if null is passed

* @return a pair - if the boolean is false then it indicates

* that the cell has a RESERVERD_VIS_TAG and with boolean as true, not

* null tag indicates that a string modified tag was found.

*/

private Pair checkForReservedVisibilityTagPresence(Cell cell,

Pair pair) throws IOException {

if (pair == null) {

pair = new Pair(false, null);

} else {

pair.setFirst(false);

pair.setSecond(null);

}

// Bypass this check when the operation is done by a system/super user.

// This is done because, while Replication, the Cells coming to the peer cluster with reserved

// typed tags and this is fine and should get added to the peer cluster table

if (isSystemOrSuperUser()) {

// Does the cell contain special tag which indicates that the replicated

// cell visiblilty tags

// have been modified

Tag modifiedTag = null;

if (cell.getTagsLength() > 0) {

Iterator tagsIterator = CellUtil.tagsIterator(cell.getTagsArray(),

cell.getTagsOffset(), cell.getTagsLength());

while (tagsIterator.hasNext()) {

Tag tag = tagsIterator.next();

if (tag.getType() == TagType.STRING_VIS_TAG_TYPE) {

modifiedTag = tag;

break;

}

}

}

pair.setFirst(true);

pair.setSecond(modifiedTag);

return pair;

}

if (cell.getTagsLength() > 0) {

Iterator tagsItr = CellUtil.tagsIterator(cell.getTagsArray(), cell.getTagsOffset(),

cell.getTagsLength());

while (tagsItr.hasNext()) {

if (RESERVED_VIS_TAG_TYPES.contains(tagsItr.next().getType())) {

return pair;

}

}

}

pair.setFirst(true);

return pair;

}