org.apache.nifi.cluster.coordination.http.endpoints

Class CurrentUserEndpointMerger

java.lang.Object

org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint<CurrentUserEntity>

org.apache.nifi.cluster.coordination.http.endpoints.CurrentUserEndpointMerger

All Implemented Interfaces:

EndpointResponseMerger

public class CurrentUserEndpointMerger
extends AbstractSingleEntityEndpoint<CurrentUserEntity>

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.regex.Pattern	CURRENT_USER_URI_PATTERN

Constructor Summary

Constructors

Constructor and Description
CurrentUserEndpointMerger()

Method Summary

Modifier and Type	Method and Description
boolean	canHandle(java.net.URI uri, java.lang.String method) Indicates whether or not this EndpointResponseMapper can handle mapping responses for the given URI and HTTP Method
protected java.lang.Class<CurrentUserEntity>	getEntityClass()
protected void	mergeResponses(CurrentUserEntity clientEntity, java.util.Map<NodeIdentifier,CurrentUserEntity> entityMap, java.util.Set<NodeResponse> successfulResponses, java.util.Set<NodeResponse> problematicResponses) Merges the responses from all nodes in the given map into the single given entity

Methods inherited from class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint

merge

Methods inherited from class java.lang.Object

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

Field Detail

CURRENT_USER_URI_PATTERN

public static final java.util.regex.Pattern CURRENT_USER_URI_PATTERN

Constructor Detail

CurrentUserEndpointMerger

public CurrentUserEndpointMerger()

Method Detail

canHandle

public boolean canHandle(java.net.URI uri,
                         java.lang.String method)

Description copied from interface: EndpointResponseMerger

Indicates whether or not this EndpointResponseMapper can handle mapping responses for the given URI and HTTP Method

Parameters:

uri - the URI of the endpoint

method - the HTTP Method used to interact with the endpoint

Returns:

true if the EndpointResponseMapper can handle mapping responses for the endpoint described by the given URI and HTTP Method

getEntityClass

protected java.lang.Class<CurrentUserEntity> getEntityClass()

Specified by:

getEntityClass in class AbstractSingleEntityEndpoint<CurrentUserEntity>

Returns:

the class that represents the type of Entity that is expected by this response mapper

mergeResponses

protected void mergeResponses(CurrentUserEntity clientEntity,
                              java.util.Map<NodeIdentifier,CurrentUserEntity> entityMap,
                              java.util.Set<NodeResponse> successfulResponses,
                              java.util.Set<NodeResponse> problematicResponses)

Description copied from class: AbstractSingleEntityEndpoint

Merges the responses from all nodes in the given map into the single given entity

Specified by:

mergeResponses in class AbstractSingleEntityEndpoint<CurrentUserEntity>

Parameters:

clientEntity - the Entity to merge responses into

entityMap - the responses from all nodes

successfulResponses - the responses from nodes that completed the request successfully

problematicResponses - the responses from nodes that did not complete the request successfully