public class AccumuloRowInputFormat extends InputFormatBase<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
InputFormatBase.RecordReaderBase<K,V>, InputFormatBase.RegexType
log
Constructor and Description |
---|
AccumuloRowInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
addIterator, addIterator, deserializeFetchedColumns, disableAutoAdjustRanges, disableAutoAdjustRanges, fetchColumns, fetchColumns, getAuthorizations, getAuthorizations, getAutoAdjustRanges, getAutoAdjustRanges, getConfiguration, getFetchedColumns, getFetchedColumns, getInstance, getInstance, getIteratorOptions, getIteratorOptions, getIterators, getIterators, getLogLevel, getLogLevel, getMaxVersions, getMaxVersions, getPassword, getPassword, getRanges, getRanges, getRegex, getSplits, getTablename, getTablename, getTabletLocator, getTabletLocator, getUsername, getUsername, isIsolated, isIsolated, isOfflineScan, serializeColumns, setInputInfo, setInputInfo, setIsolated, setIsolated, setIterator, setIteratorOption, setLocalIterators, setLocalIterators, setLogLevel, setLogLevel, setMaxVersions, setMaxVersions, setMockInstance, setMockInstance, setRanges, setRanges, setRegex, setScanOffline, setZooKeeperInstance, setZooKeeperInstance, usesLocalIterators, usesLocalIterators, validateOptions, validateOptions
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
IOException
InterruptedException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.