public class DocumentDBLoader
extends org.apache.pig.LoadFunc
| Constructor and Description |
|---|
DocumentDBLoader(String masterkey,
String dbName,
String inputCollections) |
DocumentDBLoader(String masterkey,
String dbName,
String inputCollections,
String query) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.mapreduce.InputFormat |
getInputFormat()
Returns an instance of DocumentDBInputFormat
|
org.apache.pig.data.Tuple |
getNext()
Converts a DocumentDBWritable to a pig Tuple.
|
void |
prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit split) |
String |
relativeToAbsolutePath(String location,
org.apache.hadoop.fs.Path currentDir) |
void |
setLocation(String location,
org.apache.hadoop.mapreduce.Job job)
Sets the DocumentDB connector input configuration properties.
|
void |
setUDFContextSignature(String signature) |
public org.apache.hadoop.mapreduce.InputFormat getInputFormat()
throws IOException
getInputFormat in class org.apache.pig.LoadFuncIOExceptionpublic org.apache.pig.data.Tuple getNext()
throws IOException
getNext in class org.apache.pig.LoadFuncIOExceptionpublic void prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit split)
throws IOException
prepareToRead in class org.apache.pig.LoadFuncIOExceptionpublic void setLocation(String location, org.apache.hadoop.mapreduce.Job job) throws IOException
setLocation in class org.apache.pig.LoadFuncIOExceptionpublic String relativeToAbsolutePath(String location, org.apache.hadoop.fs.Path currentDir)
relativeToAbsolutePath in class org.apache.pig.LoadFuncpublic void setUDFContextSignature(String signature)
setUDFContextSignature in class org.apache.pig.LoadFuncCopyright © 2015. All rights reserved.