org.apache.hadoop.mapred

Class SequenceFileInputFilter.RegexFilter

java.lang.Object

org.apache.hadoop.mapred.SequenceFileInputFilter.FilterBase

org.apache.hadoop.mapred.SequenceFileInputFilter.RegexFilter

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, SequenceFileInputFilter.Filter

Enclosing class:

SequenceFileInputFilter<K,V>

public static class SequenceFileInputFilter.RegexFilter
extends SequenceFileInputFilter.FilterBase

Records filter by matching key to regex

Constructor Summary

Constructors

Constructor and Description
SequenceFileInputFilter.RegexFilter()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	accept(java.lang.Object key) Filtering method If key matches the regex, return true; otherwise return false
void	setConf(org.apache.hadoop.conf.Configuration conf) configure the Filter by checking the configuration
static void	setPattern(org.apache.hadoop.conf.Configuration conf, java.lang.String regex) Define the filtering regex and stores it in conf

Methods inherited from class org.apache.hadoop.mapred.SequenceFileInputFilter.FilterBase

getConf

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceFileInputFilter.RegexFilter

public SequenceFileInputFilter.RegexFilter()

Method Detail

setPattern

public static void setPattern(org.apache.hadoop.conf.Configuration conf,
              java.lang.String regex)
                       throws java.util.regex.PatternSyntaxException

Define the filtering regex and stores it in conf

Parameters:

conf - where the regex is set

regex - regex used as a filter

Throws:

java.util.regex.PatternSyntaxException

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

configure the Filter by checking the configuration

accept

public boolean accept(java.lang.Object key)

Filtering method If key matches the regex, return true; otherwise return false

Parameters:

key - record key

Returns:

true if a record is accepted; return false otherwise

See Also:

SequenceFileInputFilter.Filter.accept(Object)