private static final class MapReduceManagerImpl.IntermediateKeyFilter<T> extends java.lang.Object implements org.infinispan.persistence.spi.AdvancedCacheLoader.KeyFilter<MapReduceManagerImpl.IntermediateCompositeKey<T>>
Modifier and Type | Field and Description |
---|---|
private java.lang.String |
taskId |
Constructor and Description |
---|
MapReduceManagerImpl.IntermediateKeyFilter(java.lang.String taskId) |
Modifier and Type | Method and Description |
---|---|
boolean |
shouldLoadKey(MapReduceManagerImpl.IntermediateCompositeKey<T> key) |
public MapReduceManagerImpl.IntermediateKeyFilter(java.lang.String taskId)
public boolean shouldLoadKey(MapReduceManagerImpl.IntermediateCompositeKey<T> key)
shouldLoadKey
in interface org.infinispan.persistence.spi.AdvancedCacheLoader.KeyFilter<MapReduceManagerImpl.IntermediateCompositeKey<T>>