[
https://issues.apache.org/jira/browse/NIFI-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
endzeit updated NIFI-14055:
---------------------------
Description:
There are several components in NiFi that work against with the
[DistributedMapCacheClient|https://github.com/apache/nifi/blob/3214e9163c59e2f1c9d21b275dda8f1b8c9e8268/nifi-extension-bundles/nifi-standard-services/nifi-distributed-cache-client-service-api/src/main/java/org/apache/nifi/distributed/cache/client/DistributedMapCacheClient.java]
abstraction.
Among other, some mentions notable for this feature proposal are:
-
[DeduplicateRecord|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java]
-
[DetectDuplicate|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java]
-
[FetchDistributedMapCache|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java]
/
[PutDistributedMapCache|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java]
This issue proposes the addition of a new processor to the
nifi-standard-processors bundle, that acts as counterpart for the controlled
deletion of cache entries to the existing FetchDistributedMapCache and
PutDistributedMapCache.
In line with other existing processors with a similar purpose in their
respective processor family, e.g.
[DeleteSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java]
for
[FetchSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchSFTP.java]
/
[PutSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSFTP.java],
the name "DeleteDistributedMapCache" is proposed.
The processors purpose is to delete one or multiple entries from the associated
Distributed Map Cache.
The processor should support determining cache keys both from FlowFile
attributes (with support for NiFi EL) as well as from Record Paths. The
implementation should be compatible with how all of DeduplicateRecord,
DetectDuplicate, FetchDistributedMapCache, and PutDistributedMapCache interact
with the Distributed Map Cache.
was:
There are several components in NiFi that work against with the
[DistributedMapCacheClient|https://github.com/apache/nifi/blob/3214e9163c59e2f1c9d21b275dda8f1b8c9e8268/nifi-extension-bundles/nifi-standard-services/nifi-distributed-cache-client-service-api/src/main/java/org/apache/nifi/distributed/cache/client/DistributedMapCacheClient.java]
abstraction.
Among other, some mentions notable for this feature proposal are:
-
[DeduplicateRecord|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java]
-
[DetectDuplicate|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java]
-
[FetchDistributedMapCache|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java]
/
[PutDistributedMapCache|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java]
This issue proposes the addition of a new processor to the
nifi-standard-processors bundle, that acts as counterpart for the controlled
deletion of cache entries to the existing FetchDistributedMapCache and
PutDistributedMapCache.
In line with other existing processors with a similar purpose in their
respective processor family, e.g.
[DeleteSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java]
for
[FetchSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchSFTP.java]
/
[PutSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSFTP.java],
the name "" is proposed.
> Add processor DeleteDistributedMapCache
> ---------------------------------------
>
> Key: NIFI-14055
> URL: https://issues.apache.org/jira/browse/NIFI-14055
> Project: Apache NiFi
> Issue Type: New Feature
> Reporter: endzeit
> Assignee: endzeit
> Priority: Major
>
> There are several components in NiFi that work against with the
> [DistributedMapCacheClient|https://github.com/apache/nifi/blob/3214e9163c59e2f1c9d21b275dda8f1b8c9e8268/nifi-extension-bundles/nifi-standard-services/nifi-distributed-cache-client-service-api/src/main/java/org/apache/nifi/distributed/cache/client/DistributedMapCacheClient.java]
> abstraction.
> Among other, some mentions notable for this feature proposal are:
> -
> [DeduplicateRecord|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeduplicateRecord.java]
> -
> [DetectDuplicate|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DetectDuplicate.java]
> -
> [FetchDistributedMapCache|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchDistributedMapCache.java]
> /
> [PutDistributedMapCache|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutDistributedMapCache.java]
> This issue proposes the addition of a new processor to the
> nifi-standard-processors bundle, that acts as counterpart for the controlled
> deletion of cache entries to the existing FetchDistributedMapCache and
> PutDistributedMapCache.
> In line with other existing processors with a similar purpose in their
> respective processor family, e.g.
> [DeleteSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java]
> for
> [FetchSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FetchSFTP.java]
> /
> [PutSFTP|https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSFTP.java],
> the name "DeleteDistributedMapCache" is proposed.
> The processors purpose is to delete one or multiple entries from the
> associated Distributed Map Cache.
> The processor should support determining cache keys both from FlowFile
> attributes (with support for NiFi EL) as well as from Record Paths. The
> implementation should be compatible with how all of DeduplicateRecord,
> DetectDuplicate, FetchDistributedMapCache, and PutDistributedMapCache
> interact with the Distributed Map Cache.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
