org.apache.gora.mongodb.query

Class MongoDBQuery<K,T extends PersistentBase>

java.lang.Object

org.apache.gora.query.impl.QueryBase<K,T>

org.apache.gora.mongodb.query.MongoDBQuery<K,T>

All Implemented Interfaces:

Query<K,T>, org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable

public class MongoDBQuery<K,T extends PersistentBase>
extends QueryBase<K,T>

MongoDB specific implementation of the Query interface.

Author:

Fabien Poulard

Field Summary

Fields inherited from class org.apache.gora.query.impl.QueryBase

dataStore, endKey, endTime, fields, filter, limit, localFilterEnabled, queryString, startKey, startTime

Constructor Summary

Constructors

Constructor and Description
MongoDBQuery()
MongoDBQuery(DataStore<K,T> dataStore)

Method Summary

Methods

Modifier and Type	Method and Description
static com.mongodb.DBObject	toDBQuery(Query<?,?> query) Compute the query itself.
static com.mongodb.DBObject	toProjection(String[] fields, MongoMapping mapping) Compute the projection of the query, that is the fields that will be retrieved from the database.

Methods inherited from class org.apache.gora.query.impl.QueryBase

equals, execute, getConf, getDataStore, getEndKey, getEndTime, getFields, getFilter, getKey, getLimit, getStartKey, getStartTime, getTimestamp, hashCode, isLocalFilterEnabled, readFields, setConf, setDataStore, setEndKey, setEndTime, setFields, setFilter, setKey, setKeyRange, setLimit, setLocalFilterEnabled, setStartKey, setStartTime, setTimeRange, setTimestamp, toString, write

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

MongoDBQuery

public MongoDBQuery()

MongoDBQuery

public MongoDBQuery(DataStore<K,T> dataStore)

Method Detail

toDBQuery

public static com.mongodb.DBObject toDBQuery(Query<?,?> query)

Compute the query itself. Only make use of the keys for querying.

Returns:

a DBObject corresponding to the query

toProjection

public static com.mongodb.DBObject toProjection(String[] fields,
                                MongoMapping mapping)

Compute the projection of the query, that is the fields that will be retrieved from the database.

Returns:

a DBObject corresponding to the list of field to be retrieved with the associated boolean