Class AccumuloTablet

  • All Implemented Interfaces:
    Serializable, org.apache.spark.Partition, scala.Serializable

    public class AccumuloTablet
    extends Object
    implements org.apache.spark.Partition
    An AccumuloTablet maintains information related to a particular tablet, including the start and end of that tablet and the set of files that data for the tablet is stored. It also includes a partition number to identify which partition this tablet is in.
    See Also:
    Serialized Form
    • Constructor Detail

      • AccumuloTablet

        public AccumuloTablet​(int rddId,
                              int index,
                              String start,
                              String end)
    • Method Detail

      • addRFile

        public void addRFile​(String rFile)
      • index

        public int index()
        Specified by:
        index in interface org.apache.spark.Partition
      • getStartRow

        public org.apache.hadoop.io.Text getStartRow()
      • getEndRow

        public org.apache.hadoop.io.Text getEndRow()
      • equals

        public boolean equals​(Object obj)
        Specified by:
        equals in interface org.apache.spark.Partition
        Overrides:
        equals in class Object
      • hashCode

        public int hashCode()
        Specified by:
        hashCode in interface org.apache.spark.Partition
        Overrides:
        hashCode in class Object