org.apache.accumulo.examples.simple.filedata
public class ChunkInputFormat extends InputFormatBase<List<Map.Entry<Key,Value>>,InputStream>
FileDataIngest
into an InputStream using ChunkInputStream
. Mappers used with this
InputFormat must close the InputStream.InputFormatBase.RangeInputSplit, InputFormatBase.RecordReaderBase<K,V>
log
Constructor and Description |
---|
ChunkInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<List<Map.Entry<Key,Value>>,InputStream> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
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
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
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<List<Map.Entry<Key,Value>>,InputStream>
IOException
InterruptedException
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.