Package org.apache.hadoop.hbase.security.visibility

Class VisibilityNewVersionBehaivorTracker

java.lang.Object

org.apache.hadoop.hbase.regionserver.querymatcher.NewVersionBehaviorTracker

org.apache.hadoop.hbase.security.visibility.VisibilityNewVersionBehaivorTracker

All Implemented Interfaces:

ColumnTracker, DeleteTracker, ShipperListener

@Private
public class VisibilityNewVersionBehaivorTracker
extends NewVersionBehaviorTracker

Similar to MvccSensitiveTracker but tracks the visibility expression also before deciding if a Cell can be considered deleted

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	VisibilityNewVersionBehaivorTracker.TagInfo
private class	VisibilityNewVersionBehaivorTracker.VisibilityDeleteVersionsNode

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.NewVersionBehaviorTracker

NewVersionBehaviorTracker.DeleteVersionsNode

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker

DeleteTracker.DeleteResult

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.NewVersionBehaviorTracker

delColMap, delFamMap, maxVersions

Constructor Summary

Constructors

Constructor	Description
VisibilityNewVersionBehaivorTracker(NavigableSet<byte[]> columns, CellComparator cellComparator, int minVersion, int maxVersion, int resultMaxVersions, long oldestUnexpiredTS)

Method Summary

Modifier and Type	Method	Description
void	add(Cell cell)	Add the specified cell to the list of deletes to check against for this row operation.
DeleteTracker.DeleteResult	isDeleted(Cell cell)	This method is not idempotent, we will save some info to judge VERSION_MASKED.
protected void	resetInternal()
private boolean	tagMatched(Cell put, VisibilityNewVersionBehaivorTracker.TagInfo delInfo)

Methods inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.NewVersionBehaviorTracker

beforeShipped, checkColumn, checkVersions, done, getCellComparator, getColumnHint, getNextRowOrNextColumn, isDone, isEmpty, prepare, reset, update

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.regionserver.querymatcher.ColumnTracker

doneWithColumn

Field Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

VisibilityNewVersionBehaivorTracker

public VisibilityNewVersionBehaivorTracker(NavigableSet<byte[]> columns,
 CellComparator cellComparator,
 int minVersion,
 int maxVersion,
 int resultMaxVersions,
 long oldestUnexpiredTS)

Method Details

add

public void add(Cell cell)

Description copied from interface: DeleteTracker

Add the specified cell to the list of deletes to check against for this row operation.

This is called when a Delete is encountered in a StoreFile.

Specified by:

add in interface DeleteTracker

Overrides:

add in class NewVersionBehaviorTracker

Parameters:

cell - - the delete cell

tagMatched

private boolean tagMatched(Cell put,
 VisibilityNewVersionBehaivorTracker.TagInfo delInfo)
                    throws IOException

Throws:

IOException

isDeleted

public DeleteTracker.DeleteResult isDeleted(Cell cell)

Description copied from class: NewVersionBehaviorTracker

This method is not idempotent, we will save some info to judge VERSION_MASKED.

Specified by:

isDeleted in interface DeleteTracker

Overrides:

isDeleted in class NewVersionBehaviorTracker

Parameters:

cell - - current cell to check if deleted by a previously seen delete

Returns:

We don't distinguish DeleteColumn and DeleteFamily. We only return code for column.

resetInternal

protected void resetInternal()

Overrides:

resetInternal in class NewVersionBehaviorTracker