K
- type of the key of the IMapV
- type of the value of the IMappublic class MapKeyValueSource<K,V> extends KeyValueSource<K,V> implements IdentifiedDataSerializable, PartitionIdAware
KeyValueSource
implementation is used in
KeyValueSource.fromMap(com.hazelcast.core.IMap)
to generate a default
implementation based on a Hazelcast IMap
.Constructor and Description |
---|
MapKeyValueSource(String mapName) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Map.Entry<K,V> |
element()
Returns the current index element
Calls to this method won't change state.
|
int |
getFactoryId()
Returns DataSerializableFactory factory id for this class.
|
int |
getId()
Returns type identifier for this class.
|
String |
getMapName() |
boolean |
hasNext()
Called to request if at least one more key-value pair is available from this
data source.
|
K |
key()
Returns the current index key for
KeyPredicate analysis. |
boolean |
open(NodeEngine nodeEngine)
This method is called before accessing the key-value pairs of this KeyValueSource.
|
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
boolean |
reset()
This method resets all internal state to be a new instance.
|
void |
setPartitionId(int partitionId)
Sets the partition id to the implementing instance it is executed against
|
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
fromList, fromMap, fromMultiMap, fromSet, getAllKeys, getAllKeys0, isAllKeysSupported
public MapKeyValueSource(String mapName)
public String getMapName()
public boolean open(NodeEngine nodeEngine)
KeyValueSource
open
in class KeyValueSource<K,V>
nodeEngine
- nodeEngine of this cluster nodepublic void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public boolean hasNext()
KeyValueSource
hasNext
in class KeyValueSource<K,V>
public K key()
KeyValueSource
KeyPredicate
analysis. This is called
to prevent a possible deserialization of unneeded values because the key is not
interesting for the running mapreduce algorithm.
Calls to this method won't change state.key
in class KeyValueSource<K,V>
KeyPredicate
analysispublic Map.Entry<K,V> element()
KeyValueSource
element
in class KeyValueSource<K,V>
public boolean reset()
KeyValueSource
PartitionIdAware
.KeyValueSource.open(com.hazelcast.spi.NodeEngine)
and Closeable.close()
is called multiple times with the other methods between open(...) and close().reset
in class KeyValueSource<K,V>
public void setPartitionId(int partitionId)
PartitionIdAware
setPartitionId
in interface PartitionIdAware
partitionId
- current partitionIdpublic void writeData(ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
out
- outputIOException
public void readData(ObjectDataInput in) throws IOException
DataSerializable
readData
in interface DataSerializable
in
- inputIOException
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
getId
in interface IdentifiedDataSerializable
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.