             [onyx.state.serializers.windowing-key-decoder :as dec]
             [onyx.state.serializers.checkpoint :as cp]
             [onyx.compression.nippy :refer [statedb-compress statedb-decompress]])
-  (:import [org.fusesource.lmdbjni Database Env Transaction Entry]
+  (:import [org.fusesource.lmdbjni Database Env Transaction Entry Constants]
            [org.agrona MutableDirectBuffer]
            [org.agrona.concurrent UnsafeBuffer]))
 

        path (str (System/getProperty "java.io.tmpdir") "/onyx/" (java.util.UUID/randomUUID) "/")
        _ (.mkdirs (java.io.File. path))
        env (doto (Env. path)
              (.setMapSize max-size))
        db (.openDatabase env db-name)]
    (->StateBackend db name env 

  ;; Not implemented yet.
  nil)


(defmethod db/create-db 
  :lmdb
  [peer-config 
