public class NoSQLInputSplit
extends InputSplit
Constructor and Description |
---|
NoSQLInputSplit()
Creates a new instance
|
NoSQLInputSplit(java.util.List<java.util.Set<java.lang.Integer>> partitionSets, java.lang.String[] kHosts, java.lang.String[] locations)
Creates a new instance
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object obj) |
java.lang.String[] |
getKvHosts()
Gets the KV hosts locations
|
long |
getLength() |
java.lang.String[] |
getLocations() |
java.util.List<java.util.Set<java.lang.Integer>> |
getPartitionSets()
Gets the partitions in this split
|
int |
hashCode() |
void |
readFields(java.io.DataInput in) |
void |
setkHosts(java.lang.String[] kHosts)
Sets the KV hosts locations
|
void |
setLocations(java.lang.String[] locations) |
void |
setPartitionSets(java.util.List<java.util.Set<java.lang.Integer>> partitionSets)
Sets the partitions in this split
|
java.lang.String |
toString() |
void |
write(java.io.DataOutput out) |
public NoSQLInputSplit()
public NoSQLInputSplit(java.util.List<java.util.Set<java.lang.Integer>> partitionSets, java.lang.String[] kHosts, java.lang.String[] locations)
partitionSets
-kHosts
-locations
-public boolean equals(java.lang.Object obj)
public java.lang.String[] getKvHosts()
public long getLength() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public java.lang.String[] getLocations() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public java.util.List<java.util.Set<java.lang.Integer>> getPartitionSets()
public int hashCode()
public void readFields(java.io.DataInput in) throws java.io.IOException
java.io.IOException
public void setkHosts(java.lang.String[] kHosts)
kHosts
-public void setLocations(java.lang.String[] locations)
public void setPartitionSets(java.util.List<java.util.Set<java.lang.Integer>> partitionSets)
partitionSets
-public java.lang.String toString()
public void write(java.io.DataOutput out) throws java.io.IOException
java.io.IOException
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.