blob: 6e50e4b4787158414ae0161d6e57d961ca462175 [file] [log] [blame]
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.gora.query;
import java.io.IOException;
import org.apache.gora.persistency.Persistent;
import org.apache.gora.store.DataStore;
import org.apache.hadoop.conf.Configurable;
import org.apache.hadoop.io.Writable;
/**
* A query to a data store to retrieve objects. Queries are constructed by
* the DataStore implementation via {@link DataStore#newQuery()}.
*/
public interface Query<K, T extends Persistent> extends Writable, Configurable {
/**
* Sets the dataStore of this query. Under normal operation, this call
* is not necessary and it is potentially dangerous. So use this
* method only if you know what you are doing.
* @param dataStore the dataStore of the query
*/
void setDataStore(DataStore<K,T> dataStore);
/**
* Returns the DataStore, that this Query is associated with.
* @return the DataStore of the Query
*/
DataStore<K,T> getDataStore();
/**
* Executes the Query on the DataStore and returns the results.
* @return the {@link Result} for the query.
*/
Result<K,T> execute() throws IOException;
// /**
// * Compiles the query for performance and error checking. This
// * method is an optional optimization for DataStore implementations.
// */
// void compile();
//
// /**
// * Sets the query string
// * @param queryString the query in String
// */
// void setQueryString(String queryString);
//
// /**
// * Returns the query string
// * @return the query as String
// */
// String getQueryString();
/* Dimension : fields */
void setFields(String... fieldNames);
String[] getFields();
/* Dimension : key */
void setKey(K key);
/**
*
* @param startKey
* an inclusive start key
*/
void setStartKey(K startKey);
/**
*
* @param endKey
* an inclusive end key
*/
void setEndKey(K endKey);
/**
* Set the range of keys over which the query will execute.
*
* @param startKey
* an inclusive start key
* @param endKey
* an inclusive end key
*/
void setKeyRange(K startKey, K endKey);
K getKey();
K getStartKey();
K getEndKey();
/* Dimension : time */
void setTimestamp(long timestamp);
void setStartTime(long startTime);
void setEndTime(long endTime);
void setTimeRange(long startTime, long endTime);
long getTimestamp();
long getStartTime();
long getEndTime();
/**
* Sets the maximum number of results to return.
*/
void setLimit(long limit);
/**
* Returns the maximum number of results
* @return the limit if it is set, otherwise a negative number
*/
long getLimit();
}