|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
TableOperations.attachIterator(String, IteratorSetting)
TableOperationsHelper.attachIterator(String, IteratorSetting)
TableOperations.attachIterator(String tableName, IteratorSetting setting)
TableOperationsHelper.attachIterator(String, IteratorSetting)
InputFormatBase.addIterator(Configuration,IteratorSetting)
instead
AgeOffFilter
Combiner
Combiner
TermSource
BytesWritable
.
LruBlockCache
.AccumuloOutputFormat.canCreateTables(Configuration)
instead
FileDataIngest
into an InputStream using ChunkInputStream
.ColumnAgeOffFilter
ColumnQualifierFilter
ColumnVisibility.ColumnVisibility(byte[])
PartialKey
.
MySequenceFile.Reader
returned.
IntersectingIterator.setColumnFamilies(IteratorSetting, Text[], boolean[])
.
boolean
array
Text
array
Text
array
BatchDeleter.setRanges(java.util.Collection)
.
Filter
with negate flag set to trueInputFormatBase.disableAutoAdjustRanges(Configuration)
instead
IntersectingIterator.setColumnFamilies(IteratorSetting, Text[], boolean[])
.
booleans
denoted which columns are NOT'ed
IntersectingIterator.setColumnFamilies(IteratorSetting, Text[], boolean[])
.
Text
array of all the columns to intersect on
Text
array of all of the terms to intersect on.
ColumnVisibility.equals(ColumnVisibility)
Constants.MAPFILE_EXTENSION
IndexedDocIterator
InputFormatBase.fetchColumns(Configuration,Collection)
instead
Filter
Filter
TableOperations.flush(String, Text, Text, boolean)
TableOperationsImpl.flush(String, Text, Text, boolean)
InputFormatBase.getAuthorizations(Configuration)
instead
InputFormatBase.getAutoAdjustRanges(Configuration)
instead
SequenceFileOutputFormat.getOutputCompressionType(org.apache.hadoop.mapred.JobConf)
to get
MySequenceFile.CompressionType
for job-outputs.
AccumuloOutputFormat.getDefaultTableName(Configuration)
instead
InputFormatBase.getFetchedColumns(Configuration)
instead
QueryUtil.FORWARD_PREFIX
for the index table.
AccumuloFileOutputFormat.getInstance(Configuration conf)
no other configurations are used by OutputFormat
AccumuloOutputFormat.getInstance(Configuration)
instead
InputFormatBase.getInstance(Configuration)
instead
Instance
based on the configuration.
InputFormatBase.getIteratorOptions(Configuration)
instead
InputFormatBase.getIterators(Configuration)
instead
AccumuloOutputFormat.getLogLevel(Configuration)
instead
InputFormatBase.getLogLevel(Configuration)
instead
AccumuloOutputFormat.getMaxLatency(Configuration)
instead
AccumuloOutputFormat.getMaxMutationBufferSize(Configuration)
instead
InputFormatBase.getMaxVersions(Configuration)
instead
VersioningIterator
from this configuration.
AccumuloOutputFormat.getMaxWriteThreads(Configuration)
instead
AccumuloOutputFormat.getPassword(Configuration)
instead
InputFormatBase.getPassword(Configuration)
instead
InputFormatBase.getRanges(Configuration)
instead
RegExFilter
and InputFormatBase.addIterator(Configuration, IteratorSetting)
QueryUtil.REVERSE_PREFIX
with the path reversed for the index table.
AccumuloOutputFormat.getSimulationMode(Configuration)
instead
Key.getLength()
.
InputFormatBase.getTablename(Configuration)
instead
InputFormatBase.getTabletLocator(Configuration)
instead
TabletLocator
based on the configuration.
QueryUtil.DIR_COLF
or a decoded string version of the colf.
AccumuloOutputFormat.getUsername(Configuration)
instead
InputFormatBase.getUsername(Configuration)
instead
GrepIterator
AccumuloFileOutputFormat.handleBlockSize(Configuration)
instead
TableOperations.importDirectory(String, String, String, boolean)
TableOperationsImpl.importDirectory(String, String, String, boolean)
RegExFilter
and InputFormatBase.addIterator(Configuration, IteratorSetting)
IntersectingIterator
InputFormatBase.isIsolated(Configuration)
instead
Long.MAX_VALUE
, and delete marker
false.
Long.MAX_VALUE
, and delete
marker false.
Long.MAX_VALUE
, and
delete marker false.
Long.MAX_VALUE
, and delete marker false.
Long.MAX_VALUE
, and delete marker false.
Key.Key(Text)
.
Key.Key(Text,Text)
.
Key.Key(Text,Text,Text)
.
Key.Key(Text,Text,Text,Text)
.
Key.Key(Text,Text,Text,long)
.
Key.Key(Text,Text,Text,Text,long)
.
Key.Key(Text,Text,Text,ColumnVisibility,long)
.
LargeRowFilter
Normalizer
which performs the following steps:
Unicode canonical decomposition (Normalizer.Form.NFD
)
Removal of diacritical marks
Unicode canonical composition (Normalizer.Form.NFC
)
lower casing in the English local
io.file.buffer.size
specified in the given Configuration
.
LineRecordReader
which does not discard lines longer than "mapred.linerecordreader.maxlength".SummingCombiner
with
LongCombiner.Type.FIXEDLEN
HeapSize
, memory-bound using an LRU eviction algorithm, and concurrent: backed by a
ConcurrentHashMap
and with a non-blocking eviction thread giving constant-time LruBlockCache.cacheBlock(java.lang.String, byte[], boolean)
and LruBlockCache.getBlock(java.lang.String)
operations.BatchScanner
.
BatchWriter
.
BatchWriter
.
SegmentDescriptor
BatchDeleter
for a MockAccumulo
instance.BatchDeleter
for the specified instance on the specified table where the writer uses the specified Authorizations
.
RFile
RFile
MySequenceFile
.RawComparator
.
key
and val
.
key
, skipping its value.
key
and val
.
MySequenceFile.Reader.nextRaw(DataOutputBuffer,MySequenceFile.ValueBytes)
.
ReqVisFilter
ReqVisFilter
SummingArrayCombiner
with
SummingArrayCombiner.Type.VARLEN
SummingCombiner
with
LongCombiner.Type.VARLEN
FSDataInputStream
returned.
RFileOperations.openWriter(java.lang.String, org.apache.hadoop.fs.FileSystem, org.apache.hadoop.conf.Configuration, org.apache.accumulo.core.conf.AccumuloConfiguration)
.
Index
) using the IntersectingIterator
.RawComparator
.RegExFilter
RegExFilter
Index
and writes out to another table.RowDeletingIterator
scan -r <row> -c <columnfamily>[:<columnqualifier>]
instead.scan -r <row>
instead.AccumuloFileOutputFormat.setBlockSize(Configuration,int)
instead
ScannerOptions.addScanIterator(IteratorSetting)
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
and
RegExFilter
ScannerOptions.addScanIterator(IteratorSetting)
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
and
RegExFilter
MySequenceFile.CompressionType
while creating the MySequenceFile
to
specify the MySequenceFile.CompressionType
for job-outputs.
AccumuloFileOutputFormat.setFileType(Configuration,String)
instead
InputFormatBase.setInputInfo(Configuration,String,byte[],String,Authorizations)
instead
InputFormatBase.setIsolated(Configuration,boolean)
instead
IsolatedScanner
in this configuration object.
InputFormatBase.addIterator(Configuration, IteratorSetting)
InputFormatBase.addIterator(Configuration, IteratorSetting)
InputFormatBase.setLocalIterators(Configuration,boolean)
instead
ClientSideIteratorScanner
in this Configuration object.
AccumuloOutputFormat.setLogLevel(Configuration,Level)
instead
InputFormatBase.setLogLevel(Configuration,Level)
instead
AccumuloOutputFormat.setMaxLatency(Configuration,int)
instead
AccumuloOutputFormat.setMaxMutationBufferSize(Configuration,long)
instead
InputFormatBase.setMaxVersions(Configuration,int)
instead
AccumuloOutputFormat.setMaxWriteThreads(Configuration,int)
instead
AccumuloOutputFormat.setMockInstance(Configuration,String)
instead
InputFormatBase.setMockInstance(Configuration,String)
instead
MockInstance
for this configuration object.
FirstEntryInRowIterator.setNumScansBeforeSeek(IteratorSetting, int)
AccumuloOutputFormat.setOutputInfo(Configuration,String,byte[],boolean,String)
instead
InputFormatBase.setRanges(Configuration,Collection)
instead
InputFormatBase.addIterator(Configuration, IteratorSetting)
ScannerOptions.addScanIterator(IteratorSetting)
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
and
RegExFilter
// Use the more flexible addScanIterator method: ScanIterator cfg = new ScanIterator("regex", RegexIterator.class); RegexIterator.setRegexs(cfg, row, null, null, null, false); scanner.addScanIterator(priority, cfg);
ScannerOptions.updateScanIteratorOption(String, String, String)
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
.
ScannerOptions.addScanIterator(IteratorSetting)
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
.
AccumuloOutputFormat.setSimulationMode(Configuration)
instead
InputFormatBase.RecordReaderBase.setupIterators(Configuration,Scanner)
instead
InputFormatBase.RecordReaderBase.setupMaxVersions(Configuration,Scanner)
instead
VersioningIterator
at priority 0 for this scanner.
ScannerOptions.addScanIterator(IteratorSetting)
RegExFilter
instead.
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
and
RegExFilter
ScannerOptions.addScanIterator(IteratorSetting)
ScannerBase.addScanIterator(org.apache.accumulo.core.client.IteratorSetting)
and
RegExFilter
AccumuloFileOutputFormat.setZooKeeperInstance(Configuration conf, String instanceName, String zooKeepers)
AccumuloOutputFormat.setZooKeeperInstance(Configuration,String,String)
instead
InputFormatBase.setZooKeeperInstance(Configuration,String,String)
instead
ZooKeeperInstance
for this configuration object.
MaxCombiner
with
LongCombiner.Type.STRING
MinCombiner
with
LongCombiner.Type.STRING
SummingCombiner
with
LongCombiner.Type.STRING
Text
Text
Text
InputFormatBase.usesLocalIterators(Configuration)
instead
InputFormatBase.validateOptions(Configuration)
instead
InputFormat
.
ibw
.
VersioningIterator
(VIS1)|(VIS2)|...|(VISN)
.VisibilityFilter
WholeRowIterator
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |