com.hazelcast.map.impl.query

Class Query

java.lang.Object

com.hazelcast.map.impl.query.Query

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable

public class Query
extends Object
implements IdentifiedDataSerializable

Object representing a Query together with all possible co-variants: like a predicate, iterationType, etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Query.QueryBuilder

Constructor Summary

Constructors

Constructor and Description
Query()
Query(String mapName, Predicate predicate, IterationType iterationType, Aggregator aggregator, Projection projection)

Method Summary

Modifier and Type	Method and Description
Result	createResult(SerializationService serializationService, long limit)
Aggregator	getAggregator()
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
int	getId() Returns type identifier for this class.
IterationType	getIterationType()
String	getMapName()
Predicate	getPredicate()
Projection	getProjection()
Class<? extends Result>	getResultType()
boolean	isAggregationQuery()
boolean	isProjectionQuery()
static Query.QueryBuilder	of()
static Query.QueryBuilder	of(Query query)
void	readData(ObjectDataInput in) Reads fields from the input stream
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Query

public Query()

Query

public Query(String mapName,
             Predicate predicate,
             IterationType iterationType,
             Aggregator aggregator,
             Projection projection)

Method Detail

getMapName

public String getMapName()

getPredicate

public Predicate getPredicate()

getIterationType

public IterationType getIterationType()

getAggregator

public Aggregator getAggregator()

getResultType

public Class<? extends Result> getResultType()

isAggregationQuery

public boolean isAggregationQuery()

getProjection

public Projection getProjection()

isProjectionQuery

public boolean isProjectionQuery()

createResult

public Result createResult(SerializationService serializationService,
                           long limit)

of

public static Query.QueryBuilder of()

of

public static Query.QueryBuilder of(Query query)

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID

getId

public int getId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getId in interface IdentifiedDataSerializable

Returns:

type ID

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.