public class DocumentDBStorage
extends org.apache.pig.StoreFunc
implements org.apache.pig.StoreMetadata
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.pig.ResourceSchema |
schema |
| Constructor and Description |
|---|
DocumentDBStorage(String masterkey,
String dbName,
String outputCollections) |
DocumentDBStorage(String masterkey,
String dbName,
String outputCollections,
String rangeindexed,
String upsert) |
| Modifier and Type | Method and Description |
|---|---|
void |
checkSchema(org.apache.pig.ResourceSchema schema) |
org.apache.hadoop.mapreduce.OutputFormat |
getOutputFormat()
Returns an instance of DocumentDBOutputFormat.
|
void |
prepareToWrite(org.apache.hadoop.mapreduce.RecordWriter writer) |
void |
putNext(org.apache.pig.data.Tuple t)
Sends a document to DocumentDBRecordWrites by converting a pig tuple to DocumentDBWritable.
|
void |
setStoreFuncUDFContextSignature(String signature) |
void |
setStoreLocation(String location,
org.apache.hadoop.mapreduce.Job job)
Sets the DocumentDB connector output configuration properties.
|
void |
storeSchema(org.apache.pig.ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job) |
void |
storeStatistics(org.apache.pig.ResourceStatistics stats,
String location,
org.apache.hadoop.mapreduce.Job job) |
public DocumentDBStorage(String masterkey, String dbName, String outputCollections)
public org.apache.hadoop.mapreduce.OutputFormat getOutputFormat()
throws IOException
getOutputFormat in interface org.apache.pig.StoreFuncInterfacegetOutputFormat in class org.apache.pig.StoreFuncIOExceptionpublic void setStoreLocation(String location, org.apache.hadoop.mapreduce.Job job) throws IOException
setStoreLocation in interface org.apache.pig.StoreFuncInterfacesetStoreLocation in class org.apache.pig.StoreFuncIOExceptionpublic void checkSchema(org.apache.pig.ResourceSchema schema)
throws IOException
checkSchema in interface org.apache.pig.StoreFuncInterfacecheckSchema in class org.apache.pig.StoreFuncIOExceptionpublic void storeStatistics(org.apache.pig.ResourceStatistics stats,
String location,
org.apache.hadoop.mapreduce.Job job)
throws IOException
storeStatistics in interface org.apache.pig.StoreMetadataIOExceptionpublic void storeSchema(org.apache.pig.ResourceSchema schema,
String location,
org.apache.hadoop.mapreduce.Job job)
throws IOException
storeSchema in interface org.apache.pig.StoreMetadataIOExceptionpublic void prepareToWrite(org.apache.hadoop.mapreduce.RecordWriter writer)
throws IOException
prepareToWrite in interface org.apache.pig.StoreFuncInterfaceprepareToWrite in class org.apache.pig.StoreFuncIOExceptionpublic void putNext(org.apache.pig.data.Tuple t)
throws IOException
putNext in interface org.apache.pig.StoreFuncInterfaceputNext in class org.apache.pig.StoreFuncIOExceptionpublic void setStoreFuncUDFContextSignature(String signature)
setStoreFuncUDFContextSignature in interface org.apache.pig.StoreFuncInterfacesetStoreFuncUDFContextSignature in class org.apache.pig.StoreFuncCopyright © 2015. All rights reserved.