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

Class ConnectionEndpointMerger

java.lang.Object

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

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

All Implemented Interfaces:

EndpointResponseMerger

public class ConnectionEndpointMerger
extends AbstractSingleEntityEndpoint<ConnectionEntity>
implements EndpointResponseMerger

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.regex.Pattern	CONNECTION_URI_PATTERN
static java.util.regex.Pattern	CONNECTIONS_URI_PATTERN

Constructor Summary

Constructors

Constructor and Description
ConnectionEndpointMerger()

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<ConnectionEntity>	getEntityClass()
protected void	mergeResponses(ConnectionEntity clientEntity, java.util.Map<NodeIdentifier,ConnectionEntity> 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

Methods inherited from interface org.apache.nifi.cluster.coordination.http.EndpointResponseMerger

merge

Field Detail

CONNECTIONS_URI_PATTERN

public static final java.util.regex.Pattern CONNECTIONS_URI_PATTERN

CONNECTION_URI_PATTERN

public static final java.util.regex.Pattern CONNECTION_URI_PATTERN

Constructor Detail

ConnectionEndpointMerger

public ConnectionEndpointMerger()

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

Specified by:

canHandle in interface EndpointResponseMerger

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<ConnectionEntity> getEntityClass()

Specified by:

getEntityClass in class AbstractSingleEntityEndpoint<ConnectionEntity>

Returns:

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

mergeResponses

protected void mergeResponses(ConnectionEntity clientEntity,
                              java.util.Map<NodeIdentifier,ConnectionEntity> 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<ConnectionEntity>

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