hazelcast-all-3.2.5.jar
登录
|
com.hazelcast:hazelcast-all:3.2.5
META-INF
com
hazelcast
queue
nio
core
spring
query
config
partition
mapreduce
aws
security
web
monitor
examples
transaction
wan
util
map
storage
osgi
spi
topic
multimap
cluster
instance
executor
collection
ascii
client
concurrent
logging
jmx
management
hibernate
distributed
region
HazelcastTimestamper.java
RegionCache.java
AbstractHazelcastCacheRegionFactory.java
HazelcastCacheRegionFactory.java
access
CacheEnvironment.java
instance
HazelcastLocalCacheRegionFactory.java
VersionAwareMapMergePolicy.java
local
server.bat
test.bat
hazelcast-download.properties
hazelcast-client-config-3.1.xsd
hazelcast-client-default.xml
hazelcast-default.xml
hazelcast-client-config-3.2.xsd
hazelcast-spring-3.1.xsd
run.sh
server.sh
hazelcast-common-config-3.1.xsd
hazelcast-fullconfig.xml
hazelcast-config-3.1.xsd
hazelcast-runtime.properties
run.bat
client.sh
hazelcast-spring-3.0.xsd
hazelcast-client-config-3.0.xsd
hazelcast-client-full.xml
hazelcast-common-config-3.0.xsd
test.sh
hazelcast-config-3.0.xsd
hazelcast-spring-3.2.xsd
hazelcast-config-3.2.xsd
VersionAwareMapMergePolicy.java
清空
类结构
/* * Copyright (c) 2008-2013, Hazelcast, Inc. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.hazelcast.hibernate; import com.hazelcast.core.
EntryView
; import com.hazelcast.map.merge.
MapMergePolicy
; import com.hazelcast.nio.
ObjectDataInput
; import com.hazelcast.nio.
ObjectDataOutput
; import org.
hibernate
.
cache
.
entry
.
CacheEntry
; import java.io.
IOException
; public class
VersionAwareMapMergePolicy
implements
MapMergePolicy
{ public
Object
merge
(
String
mapName
,
EntryView
mergingEntry
,
EntryView
existingEntry
) { final
Object
existingValue
=
existingEntry
!= null ?
existingEntry
.
getValue
() : null; final
Object
mergingValue
=
mergingEntry
.
getValue
(); if (
existingValue
!= null &&
existingValue
instanceof
CacheEntry
&&
mergingValue
!= null &&
mergingValue
instanceof
CacheEntry
) { final
CacheEntry
existingCacheEntry
= (
CacheEntry
)
existingValue
; final
CacheEntry
mergingCacheEntry
= (
CacheEntry
)
mergingValue
; final
Object
mergingVersionObject
=
mergingCacheEntry
.
getVersion
(); final
Object
existingVersionObject
=
existingCacheEntry
.
getVersion
(); if (
mergingVersionObject
!= null &&
existingVersionObject
!= null &&
mergingVersionObject
instanceof
Comparable
&&
existingVersionObject
instanceof
Comparable
) { final
Comparable
mergingVersion
= (
Comparable
)
mergingVersionObject
; final
Comparable
existingVersion
= (
Comparable
)
existingVersionObject
; if (
mergingVersion
.
compareTo
(
existingVersion
) > 0) { return
mergingValue
; } else { return
existingValue
; } } } return
mergingValue
; } @
Override
public void
writeData
(
ObjectDataOutput
out
) throws
IOException
{ } @
Override
public void
readData
(
ObjectDataInput
in
) throws
IOException
{ } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口