Skip navigation links
A B C D E G H I N O P Q R S T U W 

A

abortTask(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputCommitter
 
addIdIfMissing(Document) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
If no id is provided, replace it with an auto generated guid id.

B

BackoffExponentialRetryPolicy - Class in com.microsoft.azure.documentdb.hadoop
 
BackoffExponentialRetryPolicy() - Constructor for class com.microsoft.azure.documentdb.hadoop.BackoffExponentialRetryPolicy
 

C

checkOutputSpecs(JobContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputFormat
Validates the required properties needed to write to documentdb.
checkOutputSpecs(FileSystem, JobConf) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBOutputFormat
Validates the required properties needed to write to documentdb.
checkSchema(ResourceSchema) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
close() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader
 
close(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordWriter
Writes the last batch of documents that are being cached.
close() - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader
 
close(Reporter) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordWriter
Writes the last batch of documents that are being cached.
com.microsoft.azure.documentdb.hadoop - package com.microsoft.azure.documentdb.hadoop
 
com.microsoft.azure.documentdb.hive - package com.microsoft.azure.documentdb.hive
 
com.microsoft.azure.documentdb.mapred.hadoop - package com.microsoft.azure.documentdb.mapred.hadoop
 
com.microsoft.azure.documentdb.pig - package com.microsoft.azure.documentdb.pig
 
commitTask(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputCommitter
 
compare(WritableComparable, WritableComparable) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritableComparator
 
compareTo(Object) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
 
ConfigurationUtil - Class in com.microsoft.azure.documentdb.hadoop
Provides the configuration properties needed for running a hadoop job on documentdb.
ConfigurationUtil() - Constructor for class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
 
configureInputJobProperties(TableDesc, Map<String, String>) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
Set all DocumentDB input configuration properties to the jobProperties map.
configureJobConf(TableDesc, JobConf) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
configureOutputJobProperties(TableDesc, Map<String, String>) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
Set all DocumentDB output configuration properties to the jobProperties map.
configureTableJobProperties(TableDesc, Map<String, String>) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
Sets all the configuration properties for the connector in the properties map.
copyDocumentDBProperties(Properties, Map<String, String>) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Copies the configuration properties for the connector to a map.
CreateBulkImportStoredProcedure(DocumentClient, String) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
Gets the bulk import stored procedure that will be used for writing documents ( if the sproc already exists, use it, otherwise create a new one.
createKey() - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader
createRecordReader(InputSplit, TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputFormat
Creates an instance of DocumentDBRecordReader
createValue() - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader

D

DB_HOST - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
The link for the documentdb endpoint
DB_KEY - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
The masterkey used for the documentdb account.
DB_NAME - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
The database Id used in the Map Reduce job.
deserialize(Writable) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
Returns a JSONObject instance by deserializing a DocumentDBWritable.
DocumentDBConnectorUtil - Class in com.microsoft.azure.documentdb.hadoop
Utils used by the connector for DocumentDBCrud
DocumentDBConnectorUtil() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
 
DocumentDBInputFormat - Class in com.microsoft.azure.documentdb.hadoop
An input format that can read data from Azure DocumentDB.
DocumentDBInputFormat() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBInputFormat
 
DocumentDBInputFormat - Class in com.microsoft.azure.documentdb.mapred.hadoop
An input format that can read data from Azure DocumentDB.
DocumentDBInputFormat() - Constructor for class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBInputFormat
 
DocumentDBInputSplit - Class in com.microsoft.azure.documentdb.hadoop
An input split that represents one collection from documentdb.
DocumentDBInputSplit() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
DocumentDBInputSplit(String, String, String, String, String) - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
DocumentDBLoader - Class in com.microsoft.azure.documentdb.pig
A Pig data loader from DocumentDB.
DocumentDBLoader(String, String, String) - Constructor for class com.microsoft.azure.documentdb.pig.DocumentDBLoader
 
DocumentDBLoader(String, String, String, String) - Constructor for class com.microsoft.azure.documentdb.pig.DocumentDBLoader
 
DocumentDBOutputCommitter - Class in com.microsoft.azure.documentdb.hadoop
 
DocumentDBOutputCommitter() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputCommitter
 
DocumentDBOutputFormat - Class in com.microsoft.azure.documentdb.hadoop
An output format that is used to write data to documentdb.
DocumentDBOutputFormat() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputFormat
 
DocumentDBOutputFormat - Class in com.microsoft.azure.documentdb.mapred.hadoop
An output format that is used to write data to documentdb.
DocumentDBOutputFormat() - Constructor for class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBOutputFormat
 
DocumentDBRecordReader - Class in com.microsoft.azure.documentdb.hadoop
Reads documents from documendb using a DocumentDBIterable instance.
DocumentDBRecordReader(DocumentDBInputSplit) - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader
 
DocumentDBRecordReader - Class in com.microsoft.azure.documentdb.mapred.hadoop
Reads documents from documendb using a DocumentDBIterable instance.
DocumentDBRecordReader(WrapperSplit) - Constructor for class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader
A record reader using the old mapred.* API that reads documents from DocumentDB.
DocumentDBRecordWriter - Class in com.microsoft.azure.documentdb.hadoop
Writes data to DocumentDB in document batches using a stored procedure.
DocumentDBRecordWriter(Configuration, String, String, String, String[], String[], boolean) - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordWriter
 
DocumentDBRecordWriter - Class in com.microsoft.azure.documentdb.mapred.hadoop
Writes data to DocumentDB in document batches using a stored procedure.
DocumentDBRecordWriter(JobConf, String, String, String, String[], String[], boolean) - Constructor for class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordWriter
 
DocumentDBSerDe - Class in com.microsoft.azure.documentdb.hive
A wrapper for openx JsonSerde to work with DocumentDBWritable.
DocumentDBSerDe() - Constructor for class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
 
DocumentDBStorage - Class in com.microsoft.azure.documentdb.pig
An implementation of Pig StoreFunc for documentdb.
DocumentDBStorage(String, String, String) - Constructor for class com.microsoft.azure.documentdb.pig.DocumentDBStorage
 
DocumentDBStorage(String, String, String, String, String) - Constructor for class com.microsoft.azure.documentdb.pig.DocumentDBStorage
 
DocumentDBStorageHandler - Class in com.microsoft.azure.documentdb.hive
This defines DocumentDB Hive storages handles which returns the InputFormat, OutputFormat, Serde ..etc.
DocumentDBStorageHandler() - Constructor for class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
 
DocumentDBWritable - Class in com.microsoft.azure.documentdb.hadoop
 
DocumentDBWritable() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
 
DocumentDBWritable(Document) - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
 
DocumentDBWritableComparator - Class in com.microsoft.azure.documentdb.hadoop
 
DocumentDBWritableComparator() - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBWritableComparator
 
DocumentDBWritableComparator(Class<? extends WritableComparable>) - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBWritableComparator
 
DocumentDBWritableComparator(Class<? extends WritableComparable>, boolean) - Constructor for class com.microsoft.azure.documentdb.hadoop.DocumentDBWritableComparator
 

E

errorOccured(Exception) - Method in class com.microsoft.azure.documentdb.hadoop.BackoffExponentialRetryPolicy
Report that an error has occured and sleeps if the error is retriable
executeWriteStoredProcedure(DocumentClient, String, StoredProcedure, List<Document>, boolean) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
Executes the bulk import stored procedure for a list of documents.

G

getAuthorizationProvider() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
getCollectionName() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
getCurrentAttempt() - Method in class com.microsoft.azure.documentdb.hadoop.BackoffExponentialRetryPolicy
 
getCurrentKey() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader
getCurrentValue() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader
GetDatabase(DocumentClient, String) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
 
getDBEndpoint(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.endpoint from the Configuration object.
getDBKey(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.key from the Configuration object.
getDBName(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.db from the Configuration object.
getDoc() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
 
GetDocumentCollection(DocumentClient, String, String) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
 
getDocumentIterator() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
getInputCollectionNames(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.inputCollections from the Configuration object.
getInputFormat() - Method in class com.microsoft.azure.documentdb.pig.DocumentDBLoader
Returns an instance of DocumentDBInputFormat
getInputFormatClass() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
Returns the DocumentDBInputFormat class.
getLength() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
getLocations() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
getMetaHook() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
No metahook used.
getNext() - Method in class com.microsoft.azure.documentdb.pig.DocumentDBLoader
Converts a DocumentDBWritable to a pig Tuple.
getObjectInspector() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
Returns JsonSerde object inspector.
getOrCreateOutputCollection(DocumentClient, String, String, String[]) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
Gets an output collection with the passed name ( if the collection already exists return it, otherwise create new one
getOutputCollectionNames(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.outputCollections from the Configuration object.
getOutputCommitter(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputFormat
getOutputFormat() - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
Returns an instance of DocumentDBOutputFormat.
getOutputFormatClass() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
Returns the DocumentDBOutputFormat class.
getPos() - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader
getProgress() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader
 
getProgress() - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader
getQuery(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.query from the Configuration object.
getRangeIndex(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.rangeIndex from the Configuration object.
getRecordReader(InputSplit, JobConf, Reporter) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBInputFormat
Creates an instance of DocumentDBRecordReader
getRecordWriter(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputFormat
Creates an instance of DocumentDBRecordWriter.
getRecordWriter(FileSystem, JobConf, String, Progressable) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBOutputFormat
Creates an instance of DocumentDBRecordWriter.
getSerDeClass() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBStorageHandler
Returns the DocumentDBSerde class.
getSerDeStats() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
Returns JsonSerde stats.
getSerializedClass() - Method in class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
Returns the class name to serialize to which is DocumentDBWritable.
getSplits(JobContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputFormat
Gets a list of DocumentDBInputSplit and validates all the required properties to read from documentdb.
getSplits(Configuration, String, String, String, String[], String) - Static method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
Gets the list of DocumentDBInputSplit used.
getSplits(JobConf, int) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBInputFormat
Gets an array of DocumentDBInputSplit and validates all the required properties to read from documentdb.
getUpsert(Configuration) - Static method in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Gets the DocumentDB.upsert from the Configuration object.
getWrappedSplit() - Method in class com.microsoft.azure.documentdb.mapred.hadoop.WrapperSplit
Returns the wrapped DocumentDBInputSplit instance.

H

hashCode() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable

I

initialize(InputSplit, TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader
initialize(Configuration, Properties) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
Calls JsonSerde.initialize
INPUT_COLLECTION_NAMES - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Comma separated input collections Ids used in the map reduce job.

N

needsTaskCommit(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputCommitter
 
next(LongWritable, DocumentDBWritable) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordReader
nextKeyValue() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordReader

O

OUTPUT_COLLECTION_NAMES - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Comma separated outp collections Ids used in the map reduce job.
OUTPUT_RANGE_INDEXED - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
Comma separated Property paths to range index in the output collections.

P

prepareToRead(RecordReader, PigSplit) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBLoader
prepareToWrite(RecordWriter) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
putNext(Tuple) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
Sends a document to DocumentDBRecordWrites by converting a pig tuple to DocumentDBWritable.

Q

QUERY - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
the documentdb query pushed down to the input collections when reading.

R

readFields(DataInput) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
readFields(DataInput) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
readFields(DataInput) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.WrapperSplit
relativeToAbsolutePath(String, Path) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBLoader

S

schema - Variable in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
 
serialize(Object, ObjectInspector) - Method in class com.microsoft.azure.documentdb.hive.DocumentDBSerDe
Serializes a JsonObject to a DocumentDWritable.
setDoc(Document) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
 
setLocation(String, Job) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBLoader
Sets the DocumentDB connector input configuration properties.
setStoreFuncUDFContextSignature(String) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
setStoreLocation(String, Job) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
Sets the DocumentDB connector output configuration properties.
setUDFContextSignature(String) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBLoader
setupJob(JobContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputCommitter
 
setupTask(TaskAttemptContext) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBOutputCommitter
 
shouldRetry() - Method in class com.microsoft.azure.documentdb.hadoop.BackoffExponentialRetryPolicy
 
storeSchema(ResourceSchema, String, Job) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage
storeStatistics(ResourceStatistics, String, Job) - Method in class com.microsoft.azure.documentdb.pig.DocumentDBStorage

T

toString() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
toString() - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable

U

UPSERT - Static variable in class com.microsoft.azure.documentdb.hadoop.ConfigurationUtil
An upsert option, true by default.
UserAgentSuffix - Static variable in class com.microsoft.azure.documentdb.hadoop.DocumentDBConnectorUtil
 

W

WrapperSplit - Class in com.microsoft.azure.documentdb.mapred.hadoop
A split in the old mapred.* API that represents a split from Documentdb.
WrapperSplit() - Constructor for class com.microsoft.azure.documentdb.mapred.hadoop.WrapperSplit
A parameter-less constructor for deserialization.
WrapperSplit(DocumentDBInputSplit, Path, JobConf) - Constructor for class com.microsoft.azure.documentdb.mapred.hadoop.WrapperSplit
Create a split to wrap a given documentdb split.
write(DataOutput) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBInputSplit
 
write(Writable, DocumentDBWritable) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBRecordWriter
Writes data to DocumentDB if the cached documents reach the maximum cache size.
write(DataOutput) - Method in class com.microsoft.azure.documentdb.hadoop.DocumentDBWritable
write(Writable, DocumentDBWritable) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.DocumentDBRecordWriter
Writes data to DocumentDB if the cached documents reach the maximum cache size.
write(DataOutput) - Method in class com.microsoft.azure.documentdb.mapred.hadoop.WrapperSplit
A B C D E G H I N O P Q R S T U W 
Skip navigation links

Copyright © 2015. All rights reserved.