public class DocumentDBInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit
Constructor and Description |
---|
DocumentDBInputSplit() |
DocumentDBInputSplit(String host,
String key,
String dbName,
String collName,
String query) |
Modifier and Type | Method and Description |
---|---|
String |
getCollectionName() |
Iterator<com.microsoft.azure.documentdb.Document> |
getDocumentIterator() |
long |
getLength() |
String[] |
getLocations() |
static List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.conf.Configuration conf,
String dbHost,
String dbKey,
String dbName,
String[] collNames,
String query)
Gets the list of DocumentDBInputSplit used.
|
void |
readFields(DataInput in) |
String |
toString() |
void |
write(DataOutput out) |
public static List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.conf.Configuration conf, String dbHost, String dbKey, String dbName, String[] collNames, String query)
public long getLength()
getLength
in interface org.apache.hadoop.mapred.InputSplit
getLength
in class org.apache.hadoop.mapreduce.InputSplit
public String[] getLocations() throws IOException
getLocations
in interface org.apache.hadoop.mapred.InputSplit
getLocations
in class org.apache.hadoop.mapreduce.InputSplit
IOException
public String getCollectionName()
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public Iterator<com.microsoft.azure.documentdb.Document> getDocumentIterator() throws IOException
IOException
- if a read operation fails on documentdbCopyright © 2015. All rights reserved.