org.apache.nifi.distributed.cache.server.map

Class DistributedMapCacheServer

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.controller.AbstractControllerService

org.apache.nifi.distributed.cache.server.DistributedCacheServer

org.apache.nifi.distributed.cache.server.map.DistributedMapCacheServer

All Implemented Interfaces:

ConfigurableComponent, ControllerService

@Tags(value={"distributed","cluster","map","cache","server","key/value"})
 @CapabilityDescription(value="Provides a map (key/value) cache that can be accessed over a socket. Interaction with this service is typically accomplished via a DistributedMapCacheClient service.")
 @SeeAlso(classNames={"org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService","org.apache.nifi.ssl.StandardSSLContextService"})
public class DistributedMapCacheServer
extends DistributedCacheServer

Field Summary

Fields inherited from class org.apache.nifi.distributed.cache.server.DistributedCacheServer

EVICTION_POLICY, EVICTION_STRATEGY_FIFO, EVICTION_STRATEGY_LFU, EVICTION_STRATEGY_LRU, MAX_CACHE_ENTRIES, PERSISTENCE_PATH, PORT, SSL_CONTEXT_SERVICE

Constructor Summary

Constructors

Constructor and Description
DistributedMapCacheServer()

Method Summary

Modifier and Type	Method and Description
protected CacheServer	createCacheServer(ConfigurationContext context)
protected MapCacheServer	createMapCacheServer(int port, int maxSize, javax.net.ssl.SSLContext sslContext, EvictionPolicy evictionPolicy, java.io.File persistenceDir)

Methods inherited from class org.apache.nifi.distributed.cache.server.DistributedCacheServer

finalize, getPort, getSupportedPropertyDescriptors, shutdownServer, startServer

Methods inherited from class org.apache.nifi.controller.AbstractControllerService

abstractClearConfigContext, abstractStoreConfigContext, disabled, enabled, getConfigurationContext, getControllerServiceLookup, getIdentifier, getLogger, getProperty, getStateManager, init, initialize, isEnabled

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, hashCode, onPropertyModified, toString, validate

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Constructor Detail

DistributedMapCacheServer

public DistributedMapCacheServer()

Method Detail

createCacheServer

protected CacheServer createCacheServer(ConfigurationContext context)

Specified by:

createCacheServer in class DistributedCacheServer

createMapCacheServer

protected MapCacheServer createMapCacheServer(int port,
                                              int maxSize,
                                              javax.net.ssl.SSLContext sslContext,
                                              EvictionPolicy evictionPolicy,
                                              java.io.File persistenceDir)
                                       throws java.io.IOException

Throws:

java.io.IOException