protected static class EsInputFormat.EsInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.mapred.InputSplit
| Constructor and Description |
|---|
EsInputSplit() |
EsInputSplit(org.elasticsearch.hadoop.rest.PartitionDefinition partition) |
| Modifier and Type | Method and Description |
|---|---|
long |
getLength() |
java.lang.String[] |
getLocations() |
org.elasticsearch.hadoop.rest.PartitionDefinition |
getPartition() |
void |
readFields(java.io.DataInput in) |
void |
write(java.io.DataOutput out) |
public EsInputSplit()
public EsInputSplit(org.elasticsearch.hadoop.rest.PartitionDefinition partition)
public long getLength()
getLength in interface org.apache.hadoop.mapred.InputSplitgetLength in class org.apache.hadoop.mapreduce.InputSplitpublic java.lang.String[] getLocations()
getLocations in interface org.apache.hadoop.mapred.InputSplitgetLocations in class org.apache.hadoop.mapreduce.InputSplitpublic void write(java.io.DataOutput out)
throws java.io.IOException
write in interface org.apache.hadoop.io.Writablejava.io.IOExceptionpublic void readFields(java.io.DataInput in)
throws java.io.IOException
readFields in interface org.apache.hadoop.io.Writablejava.io.IOExceptionpublic org.elasticsearch.hadoop.rest.PartitionDefinition getPartition()