public class ScanClientImpl extends RemoteClientImpl implements ScanPersistence
client, embeddedSerializer, index, nio, seqno, serializer, store, timeout, type, url, urlArrays
Constructor and Description |
---|
ScanClientImpl() |
ScanClientImpl(String url,
Serializer serializer,
String store) |
ScanClientImpl(String url,
Serializer serializer,
String store,
int queueSize) |
ScanClientImpl(String url,
Serializer serializer,
String store,
int queueSize,
boolean nio) |
ScanClientImpl(String url,
Serializer serializer,
String store,
int queueSize,
boolean nio,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
closeCursor(CursorPara cursorPara)
close cursor on server side
|
protected void |
getTCPClient() |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
multiGets(List<voldemort.store.cachestore.Key> keys)
batch get
|
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
multiPuts(List<voldemort.store.cachestore.voldeimpl.KeyValue> list)
perform batch put
|
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
multiRemoves(List<voldemort.store.cachestore.Key> keys) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
multiSelectQuery(List<voldemort.store.cachestore.Key> keys,
String queryStr) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
multiUpdateQuery(List<voldemort.store.cachestore.Key> keys,
String queryStr) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
multiValueUpdateQuery(List<voldemort.store.cachestore.voldeimpl.KeyValue> keyValues,
String queryStr) |
CursorPara |
nextCursor(CursorPara cursorPara)
Table scan of key set to return List
|
CursorPara |
openKeyCursor(short batchSize)
Table scan of key set to return List
|
CursorPara |
openKeyCursor(short batchSize,
String queryStr) |
CursorPara |
openKeyValueCursor(short batchSize)
Table scan of key set to return List
|
CursorPara |
openKeyValueCursor(short batchSize,
String queryStr) |
CursorPara |
openQueryCursor(short batchSize,
String queryStr) |
CursorPara |
openScanCursor(short batchSize,
voldemort.store.cachestore.Key from,
voldemort.store.cachestore.Key to)
Table scan of key set to return List
|
CursorPara |
openScanCursor(short batchSize,
voldemort.store.cachestore.Key from,
voldemort.store.cachestore.Key to,
String queryStr) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
scan(voldemort.store.cachestore.Key from) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
scan(voldemort.store.cachestore.Key from,
voldemort.store.cachestore.Key to) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
scan(voldemort.store.cachestore.Key from,
voldemort.store.cachestore.Key to,
String queryStr) |
backup, close, createRequest, get, get4Php, getClient, getKeyIterator, getKeyList, getSeqNo, getSeqNoBlock, getSeqNoBlockInt, getSeqNoInt, getStore, init, insert, invoke, pack, put, put, put4Php, put4Value, query, query4Json, remove, selectQuery, sendPayload, sendRequest, setClient, setType, size, toString, updateQuery
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
get, insert, put
backup, close, getKeyIterator, pack, put, remove, size
public ScanClientImpl()
public ScanClientImpl(String url, Serializer serializer, String store)
public ScanClientImpl(String url, Serializer serializer, String store, int queueSize)
public ScanClientImpl(String url, Serializer serializer, String store, int queueSize, boolean nio)
public ScanClientImpl(String url, Serializer serializer, String store, int queueSize, boolean nio, long timeout)
protected void getTCPClient()
getTCPClient
in class RemoteClientImpl
public List<voldemort.store.cachestore.voldeimpl.KeyValue> scan(voldemort.store.cachestore.Key from, voldemort.store.cachestore.Key to)
scan
in interface ScanPersistence
from
- to
- public List<voldemort.store.cachestore.voldeimpl.KeyValue> scan(voldemort.store.cachestore.Key from, voldemort.store.cachestore.Key to, String queryStr)
public List<voldemort.store.cachestore.voldeimpl.KeyValue> scan(voldemort.store.cachestore.Key from)
scan
in interface ScanPersistence
from
- public List<voldemort.store.cachestore.voldeimpl.KeyValue> multiRemoves(List<voldemort.store.cachestore.Key> keys)
keys
- public List<voldemort.store.cachestore.voldeimpl.KeyValue> multiGets(List<voldemort.store.cachestore.Key> keys)
multiGets
in interface ScanPersistence
keys
- Listpublic List<voldemort.store.cachestore.voldeimpl.KeyValue> multiSelectQuery(List<voldemort.store.cachestore.Key> keys, String queryStr)
public List<voldemort.store.cachestore.voldeimpl.KeyValue> multiUpdateQuery(List<voldemort.store.cachestore.Key> keys, String queryStr)
public List<voldemort.store.cachestore.voldeimpl.KeyValue> multiValueUpdateQuery(List<voldemort.store.cachestore.voldeimpl.KeyValue> keyValues, String queryStr)
public List<voldemort.store.cachestore.voldeimpl.KeyValue> multiPuts(List<voldemort.store.cachestore.voldeimpl.KeyValue> list)
multiPuts
in interface ScanPersistence
list
- of KeyValuepublic CursorPara openKeyCursor(short batchSize)
batchSize
- public CursorPara openKeyCursor(short batchSize, String queryStr)
public CursorPara openKeyValueCursor(short batchSize)
batchSize
- public CursorPara openKeyValueCursor(short batchSize, String queryStr)
public CursorPara openScanCursor(short batchSize, voldemort.store.cachestore.Key from, voldemort.store.cachestore.Key to)
batchSize
- public CursorPara openScanCursor(short batchSize, voldemort.store.cachestore.Key from, voldemort.store.cachestore.Key to, String queryStr)
public CursorPara openQueryCursor(short batchSize, String queryStr)
public void closeCursor(CursorPara cursorPara)
cursorPara
- public CursorPara nextCursor(CursorPara cursorPara)
Copyright © 2016. All rights reserved.