public static void configure ( FluoConfiguration fluoConfig , Options opts ) { org . apache . fluo . recipes . core . combine . CombineQueue . FluentOptions cqopts = CombineQueue . configure ( opts . mapId ) . keyType ( opts . keyType ) . valueType ( opts . valueType ) . buckets ( opts . numBuckets ) ; if ( opts . bucketsPerTablet != null ) { cqopts . bucketsPerTablet ( opts . bucketsPerTablet ) ; } if ( opts . bufferSize != null ) { cqopts . bufferSize ( opts . bufferSize ) ; } cqopts . save ( fluoConfig ) ; opts . save ( fluoConfig . getAppConfiguration ( ) ) ; fluoConfig . addObserver ( new org . apache . fluo . api . config . ObserverSpecification ( CollisionFreeMapObserver . class . getName ( ) , ImmutableMap . of ( "mapId" , opts . mapId ) ) ) ; }
This method configures a collision free map for use . It must be called before initializing Fluo .