@ Override public MapDataStore getMapDataStore ( String mapName , int partitionId ) { return MapDataStores . createWriteBehindStore ( mapStoreContext , partitionId , writeBehindProcessor ) ; }
todo get this via constructor function .