Package oracle.kv.hadoop.table

Class TableInputSplit

  • All Implemented Interfaces:
    Writable
    public class TableInputSplit
extends InputSplit
implements Writable
    Concrete implementation of the InputSplit interface required to perform Hadoop MapReduce. A RecordReader will take instances of this class, where each such instance corresponds to data stored in an Oracle NoSQL Database store, and use those instances to retrieve that data when performing the MapReduce job.
    Since:
    3.1

    • Constructor Detail

      • TableInputSplit

        public TableInputSplit()
        No-arg constructor required by Hadoop semantics.

    • Method Detail

      • getLength

        public long getLength()
        Get the size of the split, so that the input splits can be sorted by size.
        Specified by:
        getLength in class InputSplit
        Returns:
        the number of bytes in the split

      • getLocations

        public java.lang.String[] getLocations()
        Get the list of nodes by name where the data for the split would be local. The locations do not need to be serialized.
        Specified by:
        getLocations in class InputSplit
        Returns:
        a new array of the node nodes.

      • getKVHelperHosts

        public java.lang.String[] getKVHelperHosts()
        Returns a String array with elements of the form, '<hostname:port>'; where each elment specifies the connection information for each of store's helper hosts.

      • getKVStoreName

        public java.lang.String getKVStoreName()
        Returns the name of the store containing the records associated with this split.

      • getTableName

        public java.lang.String getTableName()

      • getPartitionSets

        public java.util.List<java.util.Set<java.lang.Integer>> getPartitionSets()
        Returns a List whose elements are Sets of partitions; whose union is the set of all partitions in the store.

      • setQueryInfo

        public TableInputSplit setQueryInfo​(int newQueryBy,
                                    java.lang.String whereClause)

      • getQueryBy

        public int getQueryBy()

      • getWhereClause

        public java.lang.String getWhereClause()

      • getShardSet

        public java.util.Set<oracle.kv.impl.topo.RepGroupId> getShardSet()

      • getSecurityLogin

        public java.lang.String getSecurityLogin()

      • getSecurityTrust

        public java.lang.String getSecurityTrust()

      • write

        public void write​(java.io.DataOutput out)
           throws java.io.IOException
        Serialize the fields of this object to out.
        Specified by:
        write in interface Writable
        Parameters:
        out - DataOuput to serialize this object into.
        Throws:
        java.io.IOException - if an I/O error occurs

      • readFields

        public void readFields​(java.io.DataInput in)
                throws java.io.IOException
        Deserialize the fields of this object from in.

        For efficiency, implementations should attempt to re-use storage in the existing object where possible.

        Specified by:
        readFields in interface Writable
        Parameters:
        in - DataInput to deseriablize this object from.
        Throws:
        java.io.IOException - if an I/O error occurs

      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object