public class RangeInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable
Constructor and Description |
---|
RangeInputSplit() |
RangeInputSplit(Range range,
String[] locations) |
Modifier and Type | Method and Description |
---|---|
Authorizations |
getAuths() |
String |
getColfamRegex() |
String |
getColqualRegex() |
Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> |
getFetchedColumns() |
Instance |
getInstance() |
String |
getInstanceName() |
List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> |
getIterators() |
long |
getLength()
This implementation of length is only an estimate, it does not provide exact values.
|
String[] |
getLocations() |
org.apache.log4j.Level |
getLogLevel() |
Integer |
getMaxVersions() |
List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> |
getOptions() |
byte[] |
getPassword() |
static float |
getProgress(ByteSequence start,
ByteSequence end,
ByteSequence position) |
float |
getProgress(Key currentKey) |
Range |
getRange() |
String |
getRowRegex() |
String |
getTable() |
String |
getUsername() |
String |
getValueRegex() |
String |
getZooKeepers() |
Boolean |
isIsolatedScan() |
Boolean |
isMockInstance() |
Boolean |
isOffline() |
void |
readFields(DataInput in) |
void |
setAuths(Authorizations auths) |
void |
setColfamRegex(String colfamRegex) |
void |
setColqualRegex(String colqualRegex) |
void |
setFetchedColumns(Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> fetchedColumns) |
void |
setInstanceName(String instanceName) |
void |
setIsolatedScan(Boolean isolatedScan) |
void |
setIterators(List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> iterators) |
void |
setLocations(String[] locations) |
void |
setLogLevel(org.apache.log4j.Level level) |
void |
setMaxVersions(Integer maxVersions) |
void |
setMockInstance(Boolean mockInstance) |
void |
setOffline(Boolean offline) |
void |
setOptions(List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> options) |
void |
setPassword(byte[] password) |
void |
setRange(Range range) |
void |
setRowRegex(String rowRegex) |
void |
setTable(String table) |
void |
setUsername(String username) |
void |
setUsesLocalIterators(Boolean localIterators) |
void |
setValueRegex(String valueRegex) |
void |
setZooKeepers(String zooKeepers) |
String |
toString() |
Boolean |
usesLocalIterators() |
void |
write(DataOutput out) |
public Range getRange()
public static float getProgress(ByteSequence start, ByteSequence end, ByteSequence position)
public float getProgress(Key currentKey)
public long getLength() throws IOException
getLength
in class org.apache.hadoop.mapreduce.InputSplit
IOException
public String[] getLocations() throws IOException
getLocations
in class org.apache.hadoop.mapreduce.InputSplit
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public String getTable()
public void setTable(String table)
public Instance getInstance()
public String getInstanceName()
public void setInstanceName(String instanceName)
public String getZooKeepers()
public void setZooKeepers(String zooKeepers)
public String getUsername()
public void setUsername(String username)
public byte[] getPassword()
public void setPassword(byte[] password)
public Boolean isOffline()
public void setOffline(Boolean offline)
public void setLocations(String[] locations)
public String getRowRegex()
public void setRowRegex(String rowRegex)
public String getColfamRegex()
public void setColfamRegex(String colfamRegex)
public String getColqualRegex()
public void setColqualRegex(String colqualRegex)
public String getValueRegex()
public void setValueRegex(String valueRegex)
public Boolean isMockInstance()
public void setMockInstance(Boolean mockInstance)
public Boolean isIsolatedScan()
public void setIsolatedScan(Boolean isolatedScan)
public Integer getMaxVersions()
public void setMaxVersions(Integer maxVersions)
public Authorizations getAuths()
public void setAuths(Authorizations auths)
public void setRange(Range range)
public Boolean usesLocalIterators()
public void setUsesLocalIterators(Boolean localIterators)
public Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> getFetchedColumns()
public void setFetchedColumns(Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> fetchedColumns)
public List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> getIterators()
public void setIterators(List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> iterators)
public List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> getOptions()
public void setOptions(List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> options)
public org.apache.log4j.Level getLogLevel()
public void setLogLevel(org.apache.log4j.Level level)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.