Package org.apache.nifi.processors.standard

Class DeduplicateRecord.DistributedMapCacheClientWrapper

java.lang.Object

org.apache.nifi.processors.standard.DeduplicateRecord.FilterWrapper

org.apache.nifi.processors.standard.DeduplicateRecord.DistributedMapCacheClientWrapper

Enclosing class:

DeduplicateRecord

private static class DeduplicateRecord.DistributedMapCacheClientWrapper
extends DeduplicateRecord.FilterWrapper

Field Summary

Fields

Modifier and Type	Field	Description
private final DistributedMapCacheClient	client
private final boolean	putCacheIdentifier

Constructor Summary

Constructors

Constructor	Description
DistributedMapCacheClientWrapper(DistributedMapCacheClient client, boolean putCacheIdentifier)

Method Summary

Modifier and Type	Method	Description
boolean	contains(String value)
void	put(String value)

Methods inherited from class java.lang.Object

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

Field Details

client

private final DistributedMapCacheClient client

putCacheIdentifier

private final boolean putCacheIdentifier

Constructor Details

DistributedMapCacheClientWrapper

public DistributedMapCacheClientWrapper(DistributedMapCacheClient client,
 boolean putCacheIdentifier)

Method Details

contains

public boolean contains(String value)

Specified by:

contains in class DeduplicateRecord.FilterWrapper

put

public void put(String value)

Specified by:

put in class DeduplicateRecord.FilterWrapper