Package step.client.collections.remote

Class RemoteCollection<T>

java.lang.Object

step.client.collections.remote.RemoteCollection<T>

All Implemented Interfaces:

step.core.collections.Collection<T>

public class RemoteCollection<T>
extends Object
implements step.core.collections.Collection<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected AbstractRemoteClient	client
protected final Class<T>	entityClass
protected final String	path

Constructor Summary

Constructors

Constructor	Description
RemoteCollection(AbstractRemoteClient client, String collection, Class<T> entityClass)

Method Summary

Modifier and Type	Method	Description
long	count(step.core.collections.Filter filter, Integer limit)
void	createOrUpdateCompoundIndex(String... fields)
void	createOrUpdateCompoundIndex(Map<String,Integer> map)
void	createOrUpdateIndex(String field)
void	createOrUpdateIndex(String field, int order)
List<String>	distinct(String columnName, step.core.collections.Filter filter)
void	drop()
long	estimatedCount()
Stream<T>	find(step.core.collections.Filter filter, step.core.collections.SearchOrder order, Integer skip, Integer limit, int maxTime)
Stream<T>	findLazy(step.core.collections.Filter filter, step.core.collections.SearchOrder order, Integer skip, Integer limit, int maxTime)
Stream<T>	findReduced(step.core.collections.Filter filter, step.core.collections.SearchOrder order, Integer skip, Integer limit, int maxTime, List<String> reduceFields)
Class<T>	getEntityClass()
protected UnsupportedOperationException	notImplemented()
void	remove(step.core.collections.Filter filter)
void	rename(String newName)
void	save(Iterable<T> entities)
T	save(T entity)

Methods inherited from class java.lang.Object

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

Field Details

path

protected final String path

entityClass

protected final Class<T> entityClass

client

protected AbstractRemoteClient client

Constructor Details

RemoteCollection

public RemoteCollection(AbstractRemoteClient client,
 String collection,
 Class<T> entityClass)

Method Details

find

public Stream<T> find(step.core.collections.Filter filter,
 step.core.collections.SearchOrder order,
 Integer skip,
 Integer limit,
 int maxTime)

Specified by:

find in interface step.core.collections.Collection<T>

findLazy

public Stream<T> findLazy(step.core.collections.Filter filter,
 step.core.collections.SearchOrder order,
 Integer skip,
 Integer limit,
 int maxTime)

Specified by:

findLazy in interface step.core.collections.Collection<T>

distinct

public List<String> distinct(String columnName,
 step.core.collections.Filter filter)

Specified by:

distinct in interface step.core.collections.Collection<T>

findReduced

public Stream<T> findReduced(step.core.collections.Filter filter,
 step.core.collections.SearchOrder order,
 Integer skip,
 Integer limit,
 int maxTime,
 List<String> reduceFields)

Specified by:

findReduced in interface step.core.collections.Collection<T>

remove

public void remove(step.core.collections.Filter filter)

Specified by:

remove in interface step.core.collections.Collection<T>

save

public T save(T entity)

Specified by:

save in interface step.core.collections.Collection<T>

save

public void save(Iterable<T> entities)

Specified by:

save in interface step.core.collections.Collection<T>

createOrUpdateIndex

public void createOrUpdateIndex(String field)

Specified by:

createOrUpdateIndex in interface step.core.collections.Collection<T>

createOrUpdateIndex

public void createOrUpdateIndex(String field,
 int order)

Specified by:

createOrUpdateIndex in interface step.core.collections.Collection<T>

createOrUpdateCompoundIndex

public void createOrUpdateCompoundIndex(String... fields)

Specified by:

createOrUpdateCompoundIndex in interface step.core.collections.Collection<T>

createOrUpdateCompoundIndex

public void createOrUpdateCompoundIndex(Map<String,Integer> map)

Specified by:

createOrUpdateCompoundIndex in interface step.core.collections.Collection<T>

rename

public void rename(String newName)

Specified by:

rename in interface step.core.collections.Collection<T>

drop

public void drop()

Specified by:

drop in interface step.core.collections.Collection<T>

getEntityClass

public Class<T> getEntityClass()

Specified by:

getEntityClass in interface step.core.collections.Collection<T>

notImplemented

protected UnsupportedOperationException notImplemented()

count

public long count(step.core.collections.Filter filter,
 Integer limit)

Specified by:

count in interface step.core.collections.Collection<T>

estimatedCount

public long estimatedCount()

Specified by:

estimatedCount in interface step.core.collections.Collection<T>