protected static class EsInputFormat.ShardInputSplit extends InputSplit implements InputSplit
Constructor and Description |
---|
EsInputFormat.ShardInputSplit() |
EsInputFormat.ShardInputSplit(java.lang.String nodeIp,
int httpPort,
java.lang.String nodeId,
java.lang.String nodeName,
java.lang.String shard,
java.lang.String mapping,
java.lang.String settings) |
Modifier and Type | Method and Description |
---|---|
long |
getLength() |
java.lang.String[] |
getLocations() |
void |
readFields(java.io.DataInput in) |
java.lang.String |
toString() |
void |
write(java.io.DataOutput out) |
public EsInputFormat.ShardInputSplit()
public EsInputFormat.ShardInputSplit(java.lang.String nodeIp, int httpPort, java.lang.String nodeId, java.lang.String nodeName, java.lang.String shard, java.lang.String mapping, java.lang.String settings)
public long getLength()
getLength
in interface InputSplit
getLength
in class InputSplit
public java.lang.String[] getLocations()
getLocations
in interface InputSplit
getLocations
in class InputSplit
public void write(java.io.DataOutput out) throws java.io.IOException
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface Writable
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object