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.InputSplitgetLength in class org.apache.hadoop.mapreduce.InputSplitpublic String[] getLocations() throws IOException
getLocations in interface org.apache.hadoop.mapred.InputSplitgetLocations in class org.apache.hadoop.mapreduce.InputSplitIOExceptionpublic String getCollectionName()
public void readFields(DataInput in) throws IOException
readFields in interface org.apache.hadoop.io.WritableIOExceptionpublic void write(DataOutput out) throws IOException
write in interface org.apache.hadoop.io.WritableIOExceptionpublic Iterator<com.microsoft.azure.documentdb.Document> getDocumentIterator() throws IOException
IOException - if a read operation fails on documentdbCopyright © 2015. All rights reserved.