Package 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 Details

  • Method Details

    • 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

      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()