Index (MapR-DB Map-Reduce Library)

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