com.hazelcast.map.impl.recordstore

Class RamStoreHDImpl

java.lang.Object

com.hazelcast.map.impl.recordstore.RamStoreHDImpl

All Implemented Interfaces:

com.hazelcast.spi.hotrestart.RamStore

public class RamStoreHDImpl
extends Object
implements com.hazelcast.spi.hotrestart.RamStore

RamStore implementation for maps configured with in-memory-format: InMemoryFormat.NATIVE

Constructor Summary

Constructors

Constructor and Description
RamStoreHDImpl(EnterpriseRecordStore recordStore, com.hazelcast.memory.HazelcastMemoryManager memoryManager)

Method Summary

Modifier and Type	Method and Description
void	accept(com.hazelcast.spi.hotrestart.KeyHandle kh, byte[] valueBytes)
boolean	copyEntry(com.hazelcast.spi.hotrestart.KeyHandle keyHandle, int expectedSize, com.hazelcast.spi.hotrestart.RecordDataSink sink)
void	removeNullEntries(com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle keyHandles)
com.hazelcast.spi.hotrestart.KeyHandle	toKeyHandle(byte[] key)

Methods inherited from class java.lang.Object

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

Constructor Detail

RamStoreHDImpl

public RamStoreHDImpl(EnterpriseRecordStore recordStore,
                      com.hazelcast.memory.HazelcastMemoryManager memoryManager)

Method Detail

copyEntry

public boolean copyEntry(com.hazelcast.spi.hotrestart.KeyHandle keyHandle,
                         int expectedSize,
                         com.hazelcast.spi.hotrestart.RecordDataSink sink)
                  throws com.hazelcast.spi.hotrestart.HotRestartException

Specified by:

copyEntry in interface com.hazelcast.spi.hotrestart.RamStore

Throws:

com.hazelcast.spi.hotrestart.HotRestartException

toKeyHandle

public com.hazelcast.spi.hotrestart.KeyHandle toKeyHandle(byte[] key)

Specified by:

toKeyHandle in interface com.hazelcast.spi.hotrestart.RamStore

removeNullEntries

public void removeNullEntries(com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle keyHandles)

Specified by:

removeNullEntries in interface com.hazelcast.spi.hotrestart.RamStore

accept

public void accept(com.hazelcast.spi.hotrestart.KeyHandle kh,
                   byte[] valueBytes)

Specified by:

accept in interface com.hazelcast.spi.hotrestart.RamStore