org.apache.accumulo.core.client.mapreduce

Class RangeInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.accumulo.core.client.mapreduce.RangeInputSplit

All Implemented Interfaces:

org.apache.hadoop.io.Writable

Direct Known Subclasses:

InputFormatBase.RangeInputSplit, RangeInputSplit

public class RangeInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable

The Class RangeInputSplit. Encapsulates an Accumulo range for use in Map Reduce jobs.

Constructor Summary

Constructors

Modifier	Constructor and Description
	RangeInputSplit()
	RangeInputSplit(RangeInputSplit split)
protected	RangeInputSplit(String table, String tableId, Range range, String[] locations)

Method Summary

Modifier and Type	Method and Description
Authorizations	getAuths()
Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>>	getFetchedColumns()
Instance	getInstance() Deprecated. since 1.7.0, use getInstance(ClientConfiguration) instead.
Instance	getInstance(ClientConfiguration base)
String	getInstanceName()
List<IteratorSetting>	getIterators()
long	getLength() This implementation of length is only an estimate, it does not provide exact values.
String[]	getLocations()
org.apache.log4j.Level	getLogLevel()
String	getPrincipal()
static float	getProgress(ByteSequence start, ByteSequence end, ByteSequence position)
float	getProgress(Key currentKey)
Range	getRange()
SamplerConfiguration	getSamplerConfiguration()
String	getTable() Deprecated. since 1.6.1, use getTableName() instead.
String	getTableId()
String	getTableName()
AuthenticationToken	getToken()
String	getZooKeepers()
Boolean	isIsolatedScan()
Boolean	isMockInstance() Deprecated. since 1.8.0; use MiniAccumuloCluster or a standard mock framework
Boolean	isOffline()
void	readFields(DataInput in)
void	setAuths(Authorizations auths)
void	setFetchedColumns(Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> fetchedColumns)
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<IteratorSetting> iterators)
void	setLocations(String[] locations)
void	setLogLevel(org.apache.log4j.Level level)
void	setMockInstance(Boolean mockInstance) Deprecated. since 1.8.0; use MiniAccumuloCluster or a standard mock framework
void	setOffline(Boolean offline)
void	setPrincipal(String principal)
void	setRange(Range range)
void	setSamplerConfiguration(SamplerConfiguration samplerConfiguration)
void	setTable(String table) Deprecated. since 1.6.1, use setTableName() instead.
void	setTableId(String tableId)
void	setTableName(String table)
void	setToken(AuthenticationToken token)
void	setToken(String tokenFile)
void	setUsesLocalIterators(Boolean localIterators)
void	setZooKeepers(String zooKeepers)
String	toString()
Boolean	usesLocalIterators()
void	write(DataOutput out)

Methods inherited from class org.apache.hadoop.mapreduce.InputSplit

getLocationInfo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RangeInputSplit

public RangeInputSplit()

RangeInputSplit

public RangeInputSplit(RangeInputSplit split)
                throws IOException

Throws:

IOException

RangeInputSplit

protected RangeInputSplit(String table,
                          String tableId,
                          Range range,
                          String[] locations)

Method Detail

getRange

public Range getRange()

getProgress

public static float getProgress(ByteSequence start,
                                ByteSequence end,
                                ByteSequence position)

getProgress

public float getProgress(Key currentKey)

getLength

public long getLength()
               throws IOException

This implementation of length is only an estimate, it does not provide exact values. Do not have your code rely on this return value.

Specified by:

getLength in class org.apache.hadoop.mapreduce.InputSplit

Throws:

IOException

getLocations

public String[] getLocations()
                      throws IOException

Specified by:

getLocations in class org.apache.hadoop.mapreduce.InputSplit

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

getTable

@Deprecated
public String getTable()

Deprecated. since 1.6.1, use getTableName() instead.

Use getTableName()

getTableName

public String getTableName()

setTable

@Deprecated
public void setTable(String table)

Deprecated. since 1.6.1, use setTableName() instead.

Use setTableName(java.lang.String)

setTableName

public void setTableName(String table)

setTableId

public void setTableId(String tableId)

getTableId

public String getTableId()

getInstance

@Deprecated
public Instance getInstance()

Deprecated. since 1.7.0, use getInstance(ClientConfiguration) instead.

See Also:

getInstance(ClientConfiguration)

getInstance

public Instance getInstance(ClientConfiguration base)

getInstanceName

public String getInstanceName()

setInstanceName

public void setInstanceName(String instanceName)

getZooKeepers

public String getZooKeepers()

setZooKeepers

public void setZooKeepers(String zooKeepers)

getPrincipal

public String getPrincipal()

setPrincipal

public void setPrincipal(String principal)

getToken

public AuthenticationToken getToken()

setToken

public void setToken(AuthenticationToken token)

setToken

public void setToken(String tokenFile)

isOffline

public Boolean isOffline()

setOffline

public void setOffline(Boolean offline)

setLocations

public void setLocations(String[] locations)

isMockInstance

@Deprecated
public Boolean isMockInstance()

Deprecated. since 1.8.0; use MiniAccumuloCluster or a standard mock framework

setMockInstance

@Deprecated
public void setMockInstance(Boolean mockInstance)

Deprecated. since 1.8.0; use MiniAccumuloCluster or a standard mock framework

isIsolatedScan

public Boolean isIsolatedScan()

setIsolatedScan

public void setIsolatedScan(Boolean isolatedScan)

getAuths

public Authorizations getAuths()

setAuths

public void setAuths(Authorizations auths)

setRange

public void setRange(Range range)

usesLocalIterators

public Boolean usesLocalIterators()

setUsesLocalIterators

public void setUsesLocalIterators(Boolean localIterators)

getFetchedColumns

public Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> getFetchedColumns()

setFetchedColumns

public void setFetchedColumns(Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> fetchedColumns)

setFetchedColumns

public void setFetchedColumns(Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> fetchedColumns)

getIterators

public List<IteratorSetting> getIterators()

setIterators

public void setIterators(List<IteratorSetting> iterators)

getLogLevel

public org.apache.log4j.Level getLogLevel()

setLogLevel

public void setLogLevel(org.apache.log4j.Level level)

toString

public String toString()

Overrides:

toString in class Object

setSamplerConfiguration

public void setSamplerConfiguration(SamplerConfiguration samplerConfiguration)

getSamplerConfiguration

public SamplerConfiguration getSamplerConfiguration()