org.apache.accumulo.examples.simple.filedata
Class ChunkInputFormat
java.lang.Object
org.apache.hadoop.mapreduce.InputFormat<K,V>
org.apache.accumulo.core.client.mapreduce.InputFormatBase<List<Map.Entry<Key,Value>>,InputStream>
org.apache.accumulo.examples.simple.filedata.ChunkInputFormat
public class ChunkInputFormat
- extends InputFormatBase<List<Map.Entry<Key,Value>>,InputStream>
An InputFormat that turns the file data ingested with FileDataIngest
into an InputStream using ChunkInputStream
. Mappers used with this
InputFormat must close the InputStream.
Methods inherited from class org.apache.accumulo.core.client.mapreduce.InputFormatBase |
addIterator, addIterator, disableAutoAdjustRanges, fetchColumns, fetchColumns, getAuthorizations, getAutoAdjustRanges, getAutoAdjustRanges, getFetchedColumns, getFetchedColumns, getInputTableName, getInstance, getInstance, getIteratorOptions, getIterators, getIterators, getLogLevel, getLogLevel, getMaxVersions, getPrincipal, getPrincipal, getRanges, getRanges, getScanAuthorizations, getSplits, getTablename, getTabletLocator, getTabletLocator, getToken, getToken, getTokenClass, isConnectorInfoSet, isIsolated, isIsolated, isOfflineScan, isOfflineScan, setAutoAdjustRanges, setConnectorInfo, setInputInfo, setInputTableName, setIsolated, setLocalIterators, setLocalIterators, setLogLevel, setLogLevel, setMaxVersions, setMockInstance, setMockInstance, setOfflineTableScan, setRanges, setRanges, setScanAuthorizations, setScanIsolation, setScanOffline, setZooKeeperInstance, setZooKeeperInstance, usesLocalIterators, usesLocalIterators, validateOptions, validateOptions |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ChunkInputFormat
public ChunkInputFormat()
createRecordReader
public org.apache.hadoop.mapreduce.RecordReader<List<Map.Entry<Key,Value>>,InputStream> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException,
InterruptedException
- Specified by:
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<List<Map.Entry<Key,Value>>,InputStream>
- Throws:
IOException
InterruptedException
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.