Skip navigation links
A B C D E F G I J M N O P R S T V W 

A

accept(Class<?>) - Method in class com.mapr.db.mapreduce.DBDocumentSerialization
Allows clients to test whether this serialization supports the given class.
accept(Class<?>) - Method in class com.mapr.db.mapreduce.DocumentSerialization
Allows clients to test whether this serialization supports the given class.
accept(Class<?>) - Method in class com.mapr.db.mapreduce.ValueSerialization
 

B

BulkLoadOutputFormat - Class in com.mapr.db.mapreduce
This class defines the OutputFormat to be used when Ojai documents have to be imported into MapR Document-DB using Bulkload mode.
BulkLoadOutputFormat() - Constructor for class com.mapr.db.mapreduce.BulkLoadOutputFormat
 
BulkLoadRecordWriter - Class in com.mapr.db.mapreduce
Receives a document from Map/Reduce phase and writes to a JSON table using bulkload mode.
BulkLoadRecordWriter(Configuration, Path) - Constructor for class com.mapr.db.mapreduce.BulkLoadRecordWriter
 

C

checkOutputSpecs(JobContext) - Method in class com.mapr.db.mapreduce.BulkLoadOutputFormat
 
checkOutputSpecs(JobContext) - Method in class com.mapr.db.mapreduce.TableMutationOutputFormat
Checks if the output target exists.
checkOutputSpecs(JobContext) - Method in class com.mapr.db.mapreduce.TableOutputFormat
Checks if the output target exists.
close(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.BulkLoadRecordWriter
 
close(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableMutationRecordWriter
Closes the writer, in this case flush table commits.
close() - Method in class com.mapr.db.mapreduce.TableRecordReader
Closes the split.
close() - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
Close current split.
close(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableRecordWriter
Closes the writer, in this case flush table commits.
com.mapr.db.mapreduce - package com.mapr.db.mapreduce
 
cond - Variable in class com.mapr.db.mapreduce.TableInputFormat
 
COND_OBJ - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 
configureMutationOutputFormat(Job, String) - Static method in class com.mapr.db.mapreduce.MapRDBMapReduceUtil
Utility function to set up TableMutationOutputFormat if user wants to send DocumentMutation to update existing documents in a MapRDB table.
configurePartitioner(Job, String) - Static method in class com.mapr.db.mapreduce.MapRDBMapReduceUtil
Utility function that is used to set up custom partitioner for MapR-DB destination tables.
configureTableInputFormat(Job, String) - Static method in class com.mapr.db.mapreduce.MapRDBMapReduceUtil
This function is called to configure table input format to read data from MapR-DB table into a MapReduce application.
configureTableOutputFormat(Job, String) - Static method in class com.mapr.db.mapreduce.MapRDBMapReduceUtil
This function is invoked to configure the table output format for MapReduce application.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableInputFormat
Creates a record reader for a given split.

D

DBDocumentSerialization - Class in com.mapr.db.mapreduce
Converts a JSON document from MapR-DB format to binary SequenceFile format.
DBDocumentSerialization() - Constructor for class com.mapr.db.mapreduce.DBDocumentSerialization
 
DEFAULT_PATH - Static variable in class com.mapr.db.mapreduce.TotalOrderPartitioner
 
DocumentSerialization - Class in com.mapr.db.mapreduce
Converts a JSON document from MapR-DB format to binary format.
DocumentSerialization() - Constructor for class com.mapr.db.mapreduce.DocumentSerialization
 

E

EXCLUDE_EMBEDDEDFAMILY - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 

F

FIELD_PATH - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 

G

GET_DELETES - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 
getConf() - Method in class com.mapr.db.mapreduce.BulkLoadOutputFormat
Returns current configuration object.
getConf() - Method in class com.mapr.db.mapreduce.TableInputFormat
Returns the current configuration.
getConf() - Method in class com.mapr.db.mapreduce.TableMutationOutputFormat
Returns the current configuration.
getConf() - Method in class com.mapr.db.mapreduce.TableOutputFormat
Returns the current configuration.
getConf() - Method in class com.mapr.db.mapreduce.TablePartitioner
Returns the current configuration.
getConf() - Method in class com.mapr.db.mapreduce.TotalOrderPartitioner
 
getCurrentKey() - Method in class com.mapr.db.mapreduce.TableRecordReader
Returns the current key.
getCurrentKey() - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
Returns current key.
getCurrentValue() - Method in class com.mapr.db.mapreduce.TableRecordReader
Returns the current value.
getCurrentValue() - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
Returns current value as Document.
getDeserializer(Class<Document>) - Method in class com.mapr.db.mapreduce.DBDocumentSerialization
Returns a deserializer of the document.
getDeserializer(Class<Document>) - Method in class com.mapr.db.mapreduce.DocumentSerialization
Returns a deserializer of the document.
getDeserializer(Class<Value>) - Method in class com.mapr.db.mapreduce.ValueSerialization
 
getOutputCommitter(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.BulkLoadOutputFormat
Return the outputCommitter object.
getOutputCommitter(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableMutationOutputFormat
Returns the output committer.
getOutputCommitter(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableOutputFormat
Returns the output committer.
getPartition(ByteBufWritableComparable, Document, int) - Method in class com.mapr.db.mapreduce.TablePartitioner
Gets the partition number for a given key (hence record) given the total number of partitions i.e.
getPartition(K, V, int) - Method in class com.mapr.db.mapreduce.TotalOrderPartitioner
 
getPartitionFile(Configuration) - Static method in class com.mapr.db.mapreduce.TotalOrderPartitioner
Get the path to the SequenceFile storing the sorted partition keyset.
getPartitionSplitPoints(String) - Static method in class com.mapr.db.mapreduce.BulkLoadOutputFormat
Returns a list of keys which indicate the starting of each input partition.
getProgress() - Method in class com.mapr.db.mapreduce.TableRecordReader
The current progress of the record reader through its data.
getRecordWriter(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.BulkLoadOutputFormat
Returns a bulkload RecordWriter object which can write a row to a table.
getRecordWriter(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableMutationOutputFormat
Creates a new DocumentMutation record writer.
getRecordWriter(TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableOutputFormat
Creates a new record writer.
getSerializer(Class<Document>) - Method in class com.mapr.db.mapreduce.DBDocumentSerialization
Returns a serializer of document.
getSerializer(Class<Document>) - Method in class com.mapr.db.mapreduce.DocumentSerialization
Returns a serializer of document.
getSerializer(Class<Value>) - Method in class com.mapr.db.mapreduce.ValueSerialization
 
getSplits(JobContext) - Method in class com.mapr.db.mapreduce.TableInputFormat
Set up the splits which will be served as inputs to map tasks.

I

ID_FIELD - Static variable in class com.mapr.db.mapreduce.TableOutputFormat
 
initialize(InputSplit, TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableRecordReader
Initializes the reader.
initialize(InputSplit, TaskAttemptContext) - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
Initialize reader/iterator.
INPUT_TABLE - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 

J

jTable - Variable in class com.mapr.db.mapreduce.TableInputFormat
 

M

MapRDBMapReduceUtil - Class in com.mapr.db.mapreduce
Utility routines to set up M/R specific job details for Map/Reduce steps.
MapRDBMapReduceUtil() - Constructor for class com.mapr.db.mapreduce.MapRDBMapReduceUtil
 
MAX_TRIE_DEPTH - Static variable in class com.mapr.db.mapreduce.TotalOrderPartitioner
 

N

NATURAL_ORDER - Static variable in class com.mapr.db.mapreduce.TotalOrderPartitioner
 
nextKeyValue() - Method in class com.mapr.db.mapreduce.TableRecordReader
Positions the record reader to the next record.
nextKeyValue() - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
Positions reader/iterator to the next row.

O

OUTPUT_TABLE - Static variable in class com.mapr.db.mapreduce.BulkLoadOutputFormat
 
OUTPUT_TABLE - Static variable in class com.mapr.db.mapreduce.TableMutationOutputFormat
Job parameter that specifies the output table.
OUTPUT_TABLE - Static variable in class com.mapr.db.mapreduce.TableOutputFormat
Job parameter that specifies the output table.
OUTPUT_TABLE - Static variable in class com.mapr.db.mapreduce.TableRecordWriter
Job parameter that specifies the output table.

P

PARTITIONER_PATH - Static variable in class com.mapr.db.mapreduce.TotalOrderPartitioner
 

R

READ_ALL_CFS - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 

S

setCondition(QueryCondition) - Method in class com.mapr.db.mapreduce.TableRecordReader
 
setCondition(QueryCondition) - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
 
setConf(Configuration) - Method in class com.mapr.db.mapreduce.BulkLoadOutputFormat
Sets parameters in current configuration.
setConf(Configuration) - Method in class com.mapr.db.mapreduce.TableInputFormat
This function is used to set parameters in the configuration.
setConf(Configuration) - Method in class com.mapr.db.mapreduce.TableMutationOutputFormat
This function is used to set parameters in the configuration.
setConf(Configuration) - Method in class com.mapr.db.mapreduce.TableOutputFormat
This function is used to set parameters in the configuration.
setConf(Configuration) - Method in class com.mapr.db.mapreduce.TablePartitioner
Sets the configuration.
setConf(Configuration) - Method in class com.mapr.db.mapreduce.TotalOrderPartitioner
Read in the partition file and build indexing data structures.
setFieldPath(String) - Method in class com.mapr.db.mapreduce.TableRecordReader
 
setFieldPath(String) - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
 
setMapOutputKeyValueClass(Job) - Static method in class com.mapr.db.mapreduce.MapRDBMapReduceUtil
Function to be used to set Map Output Key class if an intermediate stage (Map/Reduce) will emit value (as key) and Document (as value).
setOutputKeyValueClass(Job) - Static method in class com.mapr.db.mapreduce.MapRDBMapReduceUtil
Function to be used to set Output Key class if an intermediate stage (Map/Reduce) will emit value (as key) and Document (as value).
setPartitionFile(Configuration, Path) - Static method in class com.mapr.db.mapreduce.TotalOrderPartitioner
Set the path to the SequenceFile storing the sorted partition keyset.
setTable(Table) - Method in class com.mapr.db.mapreduce.TableRecordReader
 
setTable(Table) - Method in class com.mapr.db.mapreduce.TableRecordReaderImpl
Sets table name.
START_ROW - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 
STOP_ROW - Static variable in class com.mapr.db.mapreduce.TableInputFormat
 

T

TableInputFormat - Class in com.mapr.db.mapreduce
This class is used to read JSON table data from MapR-DB in Map/Reduce program.
TableInputFormat() - Constructor for class com.mapr.db.mapreduce.TableInputFormat
 
TableMutationOutputFormat - Class in com.mapr.db.mapreduce
Writes DocumentMutation from Map/Reduce phase to JSON tables.
TableMutationOutputFormat() - Constructor for class com.mapr.db.mapreduce.TableMutationOutputFormat
 
TableMutationRecordWriter - Class in com.mapr.db.mapreduce
Receives a Record Mutation from Map/Reduce phase and writes to a JSON table.
TableMutationRecordWriter(Table) - Constructor for class com.mapr.db.mapreduce.TableMutationRecordWriter
 
TableOutputFormat - Class in com.mapr.db.mapreduce
Writes Map/Reduce output to JSON tables.
TableOutputFormat() - Constructor for class com.mapr.db.mapreduce.TableOutputFormat
 
TablePartitioner - Class in com.mapr.db.mapreduce
TablePartitioner controls the partitioning of key space of a JSON table for intermediate map-out functions.
TablePartitioner() - Constructor for class com.mapr.db.mapreduce.TablePartitioner
 
TableRecordReader - Class in com.mapr.db.mapreduce
Top level wrapper class which iterates over rows in a JSON table and returns (Key, Value) pairs, where value is a document.
TableRecordReader() - Constructor for class com.mapr.db.mapreduce.TableRecordReader
 
TableRecordReaderImpl - Class in com.mapr.db.mapreduce
Iterates over MapR-DB JSON table data.
TableRecordReaderImpl() - Constructor for class com.mapr.db.mapreduce.TableRecordReaderImpl
 
TableRecordWriter - Class in com.mapr.db.mapreduce
Receives a document from Map/Reduce phase and writes to a JSON table.
TableRecordWriter(Table) - Constructor for class com.mapr.db.mapreduce.TableRecordWriter
 
TotalOrderPartitioner<K,V> - Class in com.mapr.db.mapreduce
Partitioner effecting a total order by reading split points from an externally generated source.
TotalOrderPartitioner() - Constructor for class com.mapr.db.mapreduce.TotalOrderPartitioner
 

V

ValueSerialization - Class in com.mapr.db.mapreduce
 
ValueSerialization() - Constructor for class com.mapr.db.mapreduce.ValueSerialization
 

W

write(Value, DocumentMutation) - Method in class com.mapr.db.mapreduce.BulkLoadRecordWriter
Writes a record mutation to the table.
write(Value, Document) - Method in class com.mapr.db.mapreduce.BulkLoadRecordWriter
Writes a document to the table.
write(Value, DocumentMutation) - Method in class com.mapr.db.mapreduce.TableMutationRecordWriter
Updates a row given by the key in the table with DocumentMutation.
write(Value, Document) - Method in class com.mapr.db.mapreduce.TableRecordWriter
Writes a key/value pair into the table.
A B C D E F G I J M N O P R S T V W 
Skip navigation links