public class AccumulatorInfo extends Object implements Portable
Accumulator
.
This metadata is used in communications between: node <--> node and client <--> node.
QueryCacheConfig
Constructor and Description |
---|
AccumulatorInfo() |
Modifier and Type | Method and Description |
---|---|
int |
getBatchSize() |
int |
getBufferSize() |
String |
getCacheId() |
int |
getClassId()
Returns class identifier for this portable class.
|
long |
getDelaySeconds() |
int |
getFactoryId()
Returns PortableFactory ID for this portable class
|
String |
getMapName() |
Predicate |
getPredicate() |
boolean |
isCoalesce() |
boolean |
isIncludeValue() |
boolean |
isPopulate() |
boolean |
isPublishable() |
void |
readPortable(PortableReader reader)
Read portable fields using PortableReader
|
void |
setPublishable(boolean publishable) |
static AccumulatorInfo |
toAccumulatorInfo(QueryCacheConfig config,
String mapName,
String cacheId,
Predicate predicate) |
static AccumulatorInfo |
toAccumulatorInfo(String mapName,
String cacheId,
Predicate predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean includeValue,
boolean populate,
boolean coalesce) |
String |
toString() |
void |
writePortable(PortableWriter writer)
Serialize this portable object using PortableWriter
|
public static AccumulatorInfo toAccumulatorInfo(QueryCacheConfig config, String mapName, String cacheId, Predicate predicate)
public static AccumulatorInfo toAccumulatorInfo(String mapName, String cacheId, Predicate predicate, int batchSize, int bufferSize, long delaySeconds, boolean includeValue, boolean populate, boolean coalesce)
public int getBatchSize()
public int getBufferSize()
public long getDelaySeconds()
public boolean isIncludeValue()
public String getMapName()
public String getCacheId()
public Predicate getPredicate()
public boolean isPublishable()
public boolean isPopulate()
public void setPublishable(boolean publishable)
public boolean isCoalesce()
public int getFactoryId()
Portable
getFactoryId
in interface Portable
public int getClassId()
Portable
getClassId
in interface Portable
public void writePortable(PortableWriter writer) throws IOException
Portable
writePortable
in interface Portable
writer
- PortableWriterIOException
public void readPortable(PortableReader reader) throws IOException
Portable
readPortable
in interface Portable
reader
- PortableReaderIOException
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.