Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.filter |
Provides row-level filters applied to HRegion scan results during calls to
ResultScanner.next() . |
org.apache.hadoop.hbase.mapred |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.quotas | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.querymatcher | |
org.apache.hadoop.hbase.rest |
HBase REST
|
org.apache.hadoop.hbase.rest.model | |
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.security.visibility |
Modifier and Type | Method and Description |
---|---|
private static void |
MetaTableAccessor.scanMeta(Connection connection,
byte[] startRow,
byte[] stopRow,
MetaTableAccessor.QueryType type,
Filter filter,
int maxRows,
MetaTableAccessor.Visitor visitor) |
Modifier and Type | Field and Description |
---|---|
protected Filter |
Query.filter |
Modifier and Type | Method and Description |
---|---|
Filter |
Scan.getFilter() |
Filter |
Query.getFilter() |
Modifier and Type | Method and Description |
---|---|
Scan |
Scan.setFilter(Filter filter) |
Query |
Query.setFilter(Filter filter)
Apply the specified server-side filter when performing the Query.
|
Get |
Get.setFilter(Filter filter) |
Constructor and Description |
---|
Scan(byte[] startRow,
Filter filter)
Deprecated.
since 2.0.0 and will be removed in 3.0.0. Use
new Scan().withStartRow(startRow).setFilter(filter) instead. |
Modifier and Type | Class and Description |
---|---|
class |
ColumnCountGetFilter
Simple filter that returns first N columns on row only.
|
class |
ColumnPaginationFilter
A filter, based on the ColumnCountGetFilter, takes two arguments: limit and offset.
|
class |
ColumnPrefixFilter
This filter is used for selecting only those keys with columns that matches
a particular prefix.
|
class |
ColumnRangeFilter
This filter is used for selecting only those keys with columns that are
between minColumn to maxColumn.
|
class |
ColumnValueFilter
Different from
SingleColumnValueFilter which returns an entire row
when specified condition is matched, ColumnValueFilter return the matched cell only. |
class |
CompareFilter
This is a generic filter to be used to filter by comparison.
|
class |
DependentColumnFilter
A filter for adding inter-column timestamp matching
Only cells with a correspondingly timestamped entry in
the target column will be retained
Not compatible with Scan.setBatch as operations need
full rows for correct filtering
|
class |
FamilyFilter
This filter is used to filter based on the column family.
|
class |
FilterBase
Abstract base class to help you implement new Filters.
|
class |
FilterList
Implementation of
Filter that represents an ordered List of Filters which will be
evaluated with a specified boolean operator FilterList.Operator.MUST_PASS_ALL (AND ) or
FilterList.Operator.MUST_PASS_ONE (OR ). |
class |
FilterListBase
Base class for FilterList.
|
class |
FilterListWithAND
FilterListWithAND represents an ordered list of filters which will be evaluated with an AND
operator.
|
class |
FilterListWithOR
FilterListWithOR represents an ordered list of filters which will be evaluated with an OR
operator.
|
class |
FilterWrapper
This is a Filter wrapper class which is used in the server side.
|
class |
FirstKeyOnlyFilter
A filter that will only return the first KV from each row.
|
class |
FirstKeyValueMatchingQualifiersFilter
Deprecated.
Deprecated in 2.0.0 and will be removed in 3.0.0.
|
class |
FuzzyRowFilter
This is optimized version of a standard FuzzyRowFilter Filters data based on fuzzy row key.
|
class |
InclusiveStopFilter
A Filter that stops after the given row.
|
class |
KeyOnlyFilter
A filter that will only return the key component of each KV (the value will
be rewritten as empty).
|
class |
MultipleColumnPrefixFilter
This filter is used for selecting only those keys with columns that matches
a particular prefix.
|
class |
MultiRowRangeFilter
Filter to support scan multiple row key ranges.
|
class |
PageFilter
Implementation of Filter interface that limits results to a specific page
size.
|
class |
PrefixFilter
Pass results that have same row prefix.
|
class |
QualifierFilter
This filter is used to filter based on the column qualifier.
|
class |
RandomRowFilter
A filter that includes rows based on a chance.
|
class |
RowFilter
This filter is used to filter based on the key.
|
class |
SingleColumnValueExcludeFilter
A
Filter that checks a single column value, but does not emit the
tested column. |
class |
SingleColumnValueFilter
This filter is used to filter cells based on value.
|
class |
SkipFilter
A wrapper filter that filters an entire row if any of the Cell checks do
not pass.
|
class |
TimestampsFilter
Filter that returns only cells whose timestamp (version) is
in the specified list of timestamps (versions).
|
class |
ValueFilter
This filter is used to filter based on column value.
|
class |
WhileMatchFilter
A wrapper filter that returns true from
WhileMatchFilter.filterAllRemaining() as soon
as the wrapped filters filterRowKey(byte[], int, int) ,
filterCell(org.apache.hadoop.hbase.Cell) ,
filterRow() or
filterAllRemaining() methods
returns true. |
Modifier and Type | Field and Description |
---|---|
private Filter |
WhileMatchFilter.filter |
private Filter |
SkipFilter.filter |
(package private) Filter |
FilterWrapper.filter |
Modifier and Type | Field and Description |
---|---|
protected ArrayList<Filter> |
FilterListBase.filters |
private List<Filter> |
FilterListWithAND.seekHintFilters |
Modifier and Type | Method and Description |
---|---|
static Filter |
ColumnPaginationFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
ColumnCountGetFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
DependentColumnFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
KeyOnlyFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
ColumnPrefixFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
MultipleColumnPrefixFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
SingleColumnValueFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
FamilyFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
SingleColumnValueExcludeFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
FirstKeyOnlyFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
PageFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
PrefixFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
ValueFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
RowFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
TimestampsFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
ColumnRangeFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
QualifierFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
static Filter |
FilterBase.createFilterFromArguments(ArrayList<byte[]> filterArguments)
Given the filter's arguments it constructs the filter
|
static Filter |
ColumnValueFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments)
Creating this filter by reflection, it is used by
ParseFilter , |
static Filter |
InclusiveStopFilter.createFilterFromArguments(ArrayList<byte[]> filterArguments) |
Filter |
WhileMatchFilter.getFilter() |
Filter |
SkipFilter.getFilter() |
Filter |
ParseFilter.parseFilterString(byte[] filterStringAsByteArray)
Parses the filterString and constructs a filter using it
|
Filter |
ParseFilter.parseFilterString(String filterString)
Parses the filterString and constructs a filter using it
|
static Filter |
Filter.parseFrom(byte[] pbBytes)
Concrete implementers can signal a failure condition in their code by throwing an
IOException . |
Filter |
ParseFilter.parseSimpleFilterExpression(byte[] filterStringAsByteArray)
Constructs a filter object given a simple filter expression
|
static Filter |
ParseFilter.popArguments(Stack<ByteBuffer> operatorStack,
Stack<Filter> filterStack)
Pops an argument from the operator stack and the number of arguments required by the operator
from the filterStack and evaluates them
|
Modifier and Type | Method and Description |
---|---|
List<Filter> |
FilterList.getFilters()
Get the filters.
|
ArrayList<Filter> |
FilterListBase.getFilters() |
Modifier and Type | Method and Description |
---|---|
void |
FilterList.addFilter(Filter filter)
Add a filter.
|
(package private) boolean |
ColumnPaginationFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
ColumnCountGetFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
DependentColumnFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
MultiRowRangeFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
KeyOnlyFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
ColumnPrefixFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
MultipleColumnPrefixFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
SingleColumnValueFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FamilyFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
SingleColumnValueExcludeFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FuzzyRowFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
RandomRowFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FirstKeyOnlyFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FirstKeyValueMatchingQualifiersFilter.areSerializedFieldsEqual(Filter o)
Deprecated.
|
(package private) boolean |
PageFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
PrefixFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
CompareFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FilterList.areSerializedFieldsEqual(Filter other) |
(package private) boolean |
ValueFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
RowFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
TimestampsFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
ColumnRangeFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
WhileMatchFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
SkipFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
QualifierFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FilterBase.areSerializedFieldsEqual(Filter other)
Default implementation so that writers of custom filters aren't forced to implement.
|
(package private) abstract boolean |
Filter.areSerializedFieldsEqual(Filter other)
Concrete implementers can signal a failure condition in their code by throwing an
IOException . |
(package private) boolean |
ColumnValueFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
InclusiveStopFilter.areSerializedFieldsEqual(Filter o) |
(package private) boolean |
FilterWrapper.areSerializedFieldsEqual(Filter o) |
private Filter.ReturnCode |
FilterListWithOR.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.
|
Modifier and Type | Method and Description |
---|---|
void |
FilterList.addFilter(List<Filter> filters) |
void |
FilterListWithOR.addFilterLists(List<Filter> filters) |
void |
FilterListWithAND.addFilterLists(List<Filter> filters) |
abstract void |
FilterListBase.addFilterLists(List<Filter> filters) |
protected static boolean |
FilterListBase.checkAndGetReversed(List<Filter> rowFilters,
boolean defaultValue) |
protected String |
FilterListWithOR.formatLogFilters(List<Filter> logFilters) |
protected String |
FilterListWithAND.formatLogFilters(List<Filter> logFilters) |
protected abstract String |
FilterListBase.formatLogFilters(List<Filter> logFilters) |
static Filter |
ParseFilter.popArguments(Stack<ByteBuffer> operatorStack,
Stack<Filter> filterStack)
Pops an argument from the operator stack and the number of arguments required by the operator
from the filterStack and evaluates them
|
void |
ParseFilter.reduce(Stack<ByteBuffer> operatorStack,
Stack<Filter> filterStack,
ByteBuffer operator)
This function is called while parsing the filterString and an operator is parsed
|
Constructor and Description |
---|
FilterList(Filter... filters)
Constructor that takes a var arg number of
Filter s. |
FilterList(FilterList.Operator operator,
Filter... filters)
Constructor that takes a var arg number of
Filter s and an operator. |
FilterWrapper(Filter filter) |
SkipFilter(Filter filter) |
WhileMatchFilter(Filter filter) |
Constructor and Description |
---|
FilterList(FilterList.Operator operator,
List<Filter> filters)
Constructor that takes a set of
Filter s and an operator. |
FilterList(List<Filter> filters)
Constructor that takes a set of
Filter s. |
FilterListBase(List<Filter> filters) |
FilterListWithAND(List<Filter> filters) |
FilterListWithOR(List<Filter> filters) |
Modifier and Type | Field and Description |
---|---|
private Filter |
TableInputFormatBase.rowFilter |
private Filter |
TableRecordReaderImpl.trrRowFilter |
Modifier and Type | Method and Description |
---|---|
protected void |
TableInputFormatBase.setRowFilter(Filter rowFilter)
Allows subclasses to set the
Filter to be used. |
void |
TableRecordReader.setRowFilter(Filter rowFilter) |
void |
TableRecordReaderImpl.setRowFilter(Filter rowFilter) |
Modifier and Type | Field and Description |
---|---|
private Filter |
Import.KeyValueSortImporter.filter
Deprecated.
|
private Filter |
Import.KeyValueImporter.filter
Deprecated.
|
private Filter |
Import.CellSortImporter.filter |
private Filter |
Import.CellImporter.filter |
private Filter |
Import.Importer.filter |
Modifier and Type | Method and Description |
---|---|
private static Filter |
ExportUtils.getExportFilter(String[] args) |
private static Filter |
CellCounter.getRowFilter(String[] args) |
static Filter |
Import.instantiateFilter(org.apache.hadoop.conf.Configuration conf)
|
Modifier and Type | Method and Description |
---|---|
static Cell |
Import.filterKv(Filter filter,
Cell c)
Attempt to filter out the keyvalue
|
Modifier and Type | Method and Description |
---|---|
static void |
Import.addFilterAndArguments(org.apache.hadoop.conf.Configuration conf,
Class<? extends Filter> clazz,
List<String> filterArgs)
Add a Filter to be instantiated on import
|
Modifier and Type | Method and Description |
---|---|
static Filter |
QuotaTableUtil.makeFilter(QuotaFilter filter)
converts quotafilter to serializeable filterlists.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
MobReferenceOnlyFilter
A filter that returns the cells which have mob reference tags.
|
Modifier and Type | Field and Description |
---|---|
protected Filter |
UserScanQueryMatcher.filter |
Modifier and Type | Method and Description |
---|---|
abstract Filter |
ScanQueryMatcher.getFilter() |
Filter |
CompactionScanQueryMatcher.getFilter() |
Filter |
UserScanQueryMatcher.getFilter() |
Modifier and Type | Method and Description |
---|---|
static Filter |
ResultGenerator.buildFilter(String filter) |
static Filter |
ScannerResultGenerator.buildFilterFromModel(ScannerModel model) |
Modifier and Type | Method and Description |
---|---|
static ResultGenerator |
ResultGenerator.fromRowSpec(String table,
RowSpec rowspec,
Filter filter,
boolean cacheBlocks) |
Constructor and Description |
---|
RowResultGenerator(String tableName,
RowSpec rowspec,
Filter filter,
boolean cacheBlocks) |
ScannerResultGenerator(String tableName,
RowSpec rowspec,
Filter filter,
boolean cacheBlocks) |
ScannerResultGenerator(String tableName,
RowSpec rowspec,
Filter filter,
int caching,
boolean cacheBlocks) |
Modifier and Type | Method and Description |
---|---|
Filter |
ScannerModel.FilterModel.build() |
static Filter |
ScannerModel.buildFilter(String s) |
Modifier and Type | Method and Description |
---|---|
static String |
ScannerModel.stringifyFilter(Filter filter) |
Constructor and Description |
---|
FilterModel(Filter filter) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AccessControlFilter
NOTE: for internal use only by AccessController implementation
|
Modifier and Type | Class and Description |
---|---|
private static class |
VisibilityController.DeleteVersionVisibilityExpressionFilter |
(package private) class |
VisibilityLabelFilter
This Filter checks the visibility expression with each KV against visibility labels associated
with the scan.
|
Modifier and Type | Method and Description |
---|---|
static Filter |
VisibilityUtils.createVisibilityLabelFilter(Region region,
Authorizations authorizations) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.