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.StoreFuncInterface
getOutputFormat
in class org.apache.pig.StoreFunc
IOException
public void setStoreLocation(String location, org.apache.hadoop.mapreduce.Job job) throws IOException
setStoreLocation
in interface org.apache.pig.StoreFuncInterface
setStoreLocation
in class org.apache.pig.StoreFunc
IOException
public void checkSchema(org.apache.pig.ResourceSchema schema) throws IOException
checkSchema
in interface org.apache.pig.StoreFuncInterface
checkSchema
in class org.apache.pig.StoreFunc
IOException
public void storeStatistics(org.apache.pig.ResourceStatistics stats, String location, org.apache.hadoop.mapreduce.Job job) throws IOException
storeStatistics
in interface org.apache.pig.StoreMetadata
IOException
public void storeSchema(org.apache.pig.ResourceSchema schema, String location, org.apache.hadoop.mapreduce.Job job) throws IOException
storeSchema
in interface org.apache.pig.StoreMetadata
IOException
public void prepareToWrite(org.apache.hadoop.mapreduce.RecordWriter writer) throws IOException
prepareToWrite
in interface org.apache.pig.StoreFuncInterface
prepareToWrite
in class org.apache.pig.StoreFunc
IOException
public void putNext(org.apache.pig.data.Tuple t) throws IOException
putNext
in interface org.apache.pig.StoreFuncInterface
putNext
in class org.apache.pig.StoreFunc
IOException
public void setStoreFuncUDFContextSignature(String signature)
setStoreFuncUDFContextSignature
in interface org.apache.pig.StoreFuncInterface
setStoreFuncUDFContextSignature
in class org.apache.pig.StoreFunc
Copyright © 2015. All rights reserved.