org.apache.storm.windowing.persistence

Class SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V>

java.lang.Object

org.apache.storm.windowing.persistence.SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V>

All Implemented Interfaces:

WindowPartitionCache.Builder<K,V>

Enclosing class:

SimpleWindowPartitionCache<K,V>

public static class SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V>
extends Object
implements WindowPartitionCache.Builder<K,V>

Constructor Summary

Constructors

Constructor and Description
SimpleWindowPartitionCacheBuilder()

Method Summary

Modifier and Type	Method and Description
SimpleWindowPartitionCache<K,V>	build(WindowPartitionCache.CacheLoader<K,V> loader) Build the cache.
SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V>	maximumSize(long size) The maximum cache size.
SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V>	removalListener(WindowPartitionCache.RemovalListener<K,V> listener) The WindowPartitionCache.RemovalListener to be invoked when entries are evicted.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleWindowPartitionCacheBuilder

public SimpleWindowPartitionCacheBuilder()

Method Detail

maximumSize

public SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V> maximumSize(long size)

Description copied from interface: WindowPartitionCache.Builder

The maximum cache size. After this limit, entries are evicted from the cache.

Specified by:

maximumSize in interface WindowPartitionCache.Builder<K,V>

Parameters:

size - the size

Returns:

the Builder

removalListener

public SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V> removalListener(WindowPartitionCache.RemovalListener<K,V> listener)

Description copied from interface: WindowPartitionCache.Builder

The WindowPartitionCache.RemovalListener to be invoked when entries are evicted.

Specified by:

removalListener in interface WindowPartitionCache.Builder<K,V>

Parameters:

listener - the listener

Returns:

the builder

build

public SimpleWindowPartitionCache<K,V> build(WindowPartitionCache.CacheLoader<K,V> loader)

Description copied from interface: WindowPartitionCache.Builder

Build the cache.

Specified by:

build in interface WindowPartitionCache.Builder<K,V>

Parameters:

loader - the WindowPartitionCache.CacheLoader

Returns:

the WindowPartitionCache