import com.hazelcast.map.proxy.MapProxyImpl; //导入依赖的package包/类
@Override
public MapReduceTask<KeyIn, ValueIn, KeyOut, ValueOut> build( IMap<KeyIn, ValueIn> map )
{
    try
    {
        MapProxyImpl<KeyIn, ValueIn> proxy = (MapProxyImpl<KeyIn, ValueIn>) map;
        NodeEngine nodeEngine = hazelcastInstance.node.nodeEngine;
        return new IMapNodeMapReduceTaskImpl<KeyIn, ValueIn, KeyOut, ValueOut>( proxy.getName(), nodeEngine,
                                                                                hazelcastInstance );
    }
    catch ( Throwable t )
    {
        ExceptionUtil.rethrow( t );
    }
    return null;
}
 

import com.hazelcast.map.proxy.MapProxyImpl; //导入依赖的package包/类
EvictingMapInterceptor(IMap<String, CachedValue> map, FileSystem fileSystem) {
    this.fileSystem = fileSystem;
    this.mapProxy = (MapProxyImpl) map;
    this.mapService = (MapService) mapProxy.getService();
    this.nodeEngine = mapService.getNodeEngine();
    this.partitionService = nodeEngine.getPartitionService();
    this.serializationService = nodeEngine.getSerializationService();
}