defaultRheakvStore-part1.java

public class DefaultRheaKVStore implements RheaKVStore {

    private static final Logger LOG = LoggerFactory
            .getLogger(DefaultRheaKVStore.class);

    static {
        ExtSerializerSupports.init();
    }

    private final StateListenerContainer<Long> stateListenerContainer = new StateListenerContainer<>();
    private StoreEngine storeEngine;
    private PlacementDriverClient pdClient;
    private RheaKVRpcService rheaKVRpcService;
    private RheaKVStoreOptions opts;
    private int failoverRetries;
    private long futureTimeoutMillis;
    private boolean onlyLeaderRead;
    private Dispatcher kvDispatcher;
    private BatchingOptions batchingOpts;
    private GetBatching getBatching;
    private GetBatching getBatchingOnlySafe;
    private PutBatching putBatching;

    private volatile boolean started;