Package uk.gov.gchq.gaffer.accumulostore.inputformat

Class ElementInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<K,V>

org.apache.accumulo.core.client.mapreduce.AbstractInputFormat<K,V>

org.apache.accumulo.core.client.mapreduce.InputFormatBase<Element,org.apache.hadoop.io.NullWritable>

uk.gov.gchq.gaffer.accumulostore.inputformat.ElementInputFormat

public class ElementInputFormat
extends org.apache.accumulo.core.client.mapreduce.InputFormatBase<Element,org.apache.hadoop.io.NullWritable>

An InputFormatBase that allows the data in an Accumulo store to be read as Element, NullWritable pairs.

Field Summary

Fields

Modifier and Type	Field	Description
static String	KEY_PACKAGE
static String	SCHEMA
static String	VIEW

Constructor Summary

Constructors

Constructor	Description
ElementInputFormat()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.mapreduce.RecordReader<Element,org.apache.hadoop.io.NullWritable>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
static boolean	doPostFilter(Element element, View view)
static boolean	postFilter(Element element, ElementFilter postFilter)

Methods inherited from class org.apache.accumulo.core.client.mapreduce.InputFormatBase

addIterator, fetchColumns, isBatchScan, setAutoAdjustRanges, setBatchScan, setInputTableName, setLocalIterators, setOfflineTableScan, setRanges, setSamplerConfiguration, setScanIsolation

Methods inherited from class org.apache.accumulo.core.client.mapreduce.AbstractInputFormat

getClassLoaderContext, getSplits, setClassLoaderContext, setConnectorInfo, setConnectorInfo, setLogLevel, setScanAuthorizations, setZooKeeperInstance, setZooKeeperInstance

Methods inherited from class java.lang.Object

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

Field Detail

KEY_PACKAGE

public static final String KEY_PACKAGE

See Also:

Constant Field Values

SCHEMA

public static final String SCHEMA

See Also:

Constant Field Values

VIEW

public static final String VIEW

See Also:

Constant Field Values

Constructor Detail

ElementInputFormat

public ElementInputFormat()

Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<Element,org.apache.hadoop.io.NullWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                                    org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                             throws IOException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<Element,org.apache.hadoop.io.NullWritable>

Throws:

IOException

doPostFilter

public static boolean doPostFilter(Element element,
                                   View view)

postFilter

public static boolean postFilter(Element element,
                                 ElementFilter postFilter)