org.apache.nifi.registry.flow.diff

Class StandardFlowComparator

java.lang.Object

org.apache.nifi.registry.flow.diff.StandardFlowComparator

All Implemented Interfaces:

FlowComparator

public class StandardFlowComparator
extends Object
implements FlowComparator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static interface	StandardFlowComparator.ComponentComparator<T extends VersionedComponent>

Field Summary

Fields

Modifier and Type	Field and Description
private static String	DEFAULT_LOAD_BALANCE_COMPRESSION
private static String	DEFAULT_LOAD_BALANCE_STRATEGY
private static String	DEFAULT_PARTITIONING_ATTRIBUTE
private DifferenceDescriptor	differenceDescriptor
private Set<String>	externallyAccessibleServiceIds
private ComparableDataFlow	flowA
private ComparableDataFlow	flowB

Constructor Summary

Constructors

Constructor and Description
StandardFlowComparator(ComparableDataFlow flowA, ComparableDataFlow flowB, Set<String> externallyAccessibleServiceIds, DifferenceDescriptor differenceDescriptor)

Method Summary

Modifier and Type	Method and Description
private <T extends VersionedComponent> void	addIfDifferent(Set<FlowDifference> differences, DifferenceType type, T componentA, T componentB, Function<T,Object> transform)
private <T extends VersionedComponent> void	addIfDifferent(Set<FlowDifference> differences, DifferenceType type, T componentA, T componentB, Function<T,Object> transform, boolean differentiateNullAndEmptyString)
private <T extends VersionedComponent> Map<String,T>	byId(Set<T> components)
FlowComparison	compare()
private void	compare(VersionedConnection connectionA, VersionedConnection connectionB, Set<FlowDifference> differences)
private void	compare(VersionedControllerService serviceA, VersionedControllerService serviceB, Set<FlowDifference> differences)
private void	compare(VersionedFunnel funnelA, VersionedFunnel funnelB, Set<FlowDifference> differences)
private void	compare(VersionedLabel labelA, VersionedLabel labelB, Set<FlowDifference> differences)
private void	compare(VersionedPort portA, VersionedPort portB, Set<FlowDifference> differences)
private Set<FlowDifference>	compare(VersionedProcessGroup groupA, VersionedProcessGroup groupB)
private void	compare(VersionedProcessGroup groupA, VersionedProcessGroup groupB, Set<FlowDifference> differences, boolean compareNamePos)
private void	compare(VersionedProcessor processorA, VersionedProcessor processorB, Set<FlowDifference> differences)
private void	compare(VersionedRemoteGroupPort portA, VersionedRemoteGroupPort portB, Set<FlowDifference> differences)
private void	compare(VersionedRemoteProcessGroup rpgA, VersionedRemoteProcessGroup rpgB, Set<FlowDifference> differences)
private <T extends VersionedComponent> Set<FlowDifference>	compareComponents(Set<T> componentsA, Set<T> componentsB, StandardFlowComparator.ComponentComparator<T> comparator)
private boolean	compareComponents(VersionedComponent componentA, VersionedComponent componentB, Set<FlowDifference> differences)
private boolean	compareComponents(VersionedComponent componentA, VersionedComponent componentB, Set<FlowDifference> differences, boolean compareName, boolean comparePos, boolean compareComments)
Set<FlowDifference>	compareControllerServices(VersionedControllerService serviceA, VersionedControllerService serviceB) Compares to versions of a Controller Service and returns the differences between them
private void	compareProperties(VersionedComponent componentA, VersionedComponent componentB, Map<String,String> propertiesA, Map<String,String> propertiesB, Map<String,VersionedPropertyDescriptor> descriptorsA, Map<String,VersionedPropertyDescriptor> descriptorsB, Set<FlowDifference> differences)
private FlowDifference	difference(DifferenceType type, VersionedComponent componentA, VersionedComponent componentB, Object valueA, Object valueB)
private FlowDifference	difference(DifferenceType type, VersionedComponent componentA, VersionedComponent componentB, String fieldName, Object valueA, Object valueB)
private boolean	isEmpty(Collection<?> collection)
private boolean	isEmptyString(Object potentialString)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LOAD_BALANCE_STRATEGY

private static final String DEFAULT_LOAD_BALANCE_STRATEGY

See Also:

Constant Field Values

DEFAULT_PARTITIONING_ATTRIBUTE

private static final String DEFAULT_PARTITIONING_ATTRIBUTE

See Also:

Constant Field Values

DEFAULT_LOAD_BALANCE_COMPRESSION

private static final String DEFAULT_LOAD_BALANCE_COMPRESSION

See Also:

Constant Field Values

flowA

private final ComparableDataFlow flowA

flowB

private final ComparableDataFlow flowB

externallyAccessibleServiceIds

private final Set<String> externallyAccessibleServiceIds

differenceDescriptor

private final DifferenceDescriptor differenceDescriptor

Constructor Detail

StandardFlowComparator

public StandardFlowComparator(ComparableDataFlow flowA,
                              ComparableDataFlow flowB,
                              Set<String> externallyAccessibleServiceIds,
                              DifferenceDescriptor differenceDescriptor)

Method Detail

compare

public FlowComparison compare()

Specified by:

compare in interface FlowComparator

compare

private Set<FlowDifference> compare(VersionedProcessGroup groupA,
                                    VersionedProcessGroup groupB)

compareComponents

private <T extends VersionedComponent> Set<FlowDifference> compareComponents(Set<T> componentsA,
                                                                             Set<T> componentsB,
                                                                             StandardFlowComparator.ComponentComparator<T> comparator)

compareComponents

private boolean compareComponents(VersionedComponent componentA,
                                  VersionedComponent componentB,
                                  Set<FlowDifference> differences)

compareComponents

private boolean compareComponents(VersionedComponent componentA,
                                  VersionedComponent componentB,
                                  Set<FlowDifference> differences,
                                  boolean compareName,
                                  boolean comparePos,
                                  boolean compareComments)

compare

private void compare(VersionedProcessor processorA,
                     VersionedProcessor processorB,
                     Set<FlowDifference> differences)

compareControllerServices

public Set<FlowDifference> compareControllerServices(VersionedControllerService serviceA,
                                                     VersionedControllerService serviceB)

Description copied from interface: FlowComparator

Compares to versions of a Controller Service and returns the differences between them

Specified by:

compareControllerServices in interface FlowComparator

Parameters:

serviceA - the first Controller Service

serviceB - the second Controller Service

Returns:

the differences between them

compare

private void compare(VersionedControllerService serviceA,
                     VersionedControllerService serviceB,
                     Set<FlowDifference> differences)

compareProperties

private void compareProperties(VersionedComponent componentA,
                               VersionedComponent componentB,
                               Map<String,String> propertiesA,
                               Map<String,String> propertiesB,
                               Map<String,VersionedPropertyDescriptor> descriptorsA,
                               Map<String,VersionedPropertyDescriptor> descriptorsB,
                               Set<FlowDifference> differences)

compare

private void compare(VersionedFunnel funnelA,
                     VersionedFunnel funnelB,
                     Set<FlowDifference> differences)

compare

private void compare(VersionedLabel labelA,
                     VersionedLabel labelB,
                     Set<FlowDifference> differences)

compare

private void compare(VersionedPort portA,
                     VersionedPort portB,
                     Set<FlowDifference> differences)

compare

private void compare(VersionedRemoteProcessGroup rpgA,
                     VersionedRemoteProcessGroup rpgB,
                     Set<FlowDifference> differences)

compare

private void compare(VersionedRemoteGroupPort portA,
                     VersionedRemoteGroupPort portB,
                     Set<FlowDifference> differences)

compare

private void compare(VersionedProcessGroup groupA,
                     VersionedProcessGroup groupB,
                     Set<FlowDifference> differences,
                     boolean compareNamePos)

compare

private void compare(VersionedConnection connectionA,
                     VersionedConnection connectionB,
                     Set<FlowDifference> differences)

byId

private <T extends VersionedComponent> Map<String,T> byId(Set<T> components)

addIfDifferent

private <T extends VersionedComponent> void addIfDifferent(Set<FlowDifference> differences,
                                                           DifferenceType type,
                                                           T componentA,
                                                           T componentB,
                                                           Function<T,Object> transform)

addIfDifferent

private <T extends VersionedComponent> void addIfDifferent(Set<FlowDifference> differences,
                                                           DifferenceType type,
                                                           T componentA,
                                                           T componentB,
                                                           Function<T,Object> transform,
                                                           boolean differentiateNullAndEmptyString)

isEmpty

private boolean isEmpty(Collection<?> collection)

isEmptyString

private boolean isEmptyString(Object potentialString)

difference

private FlowDifference difference(DifferenceType type,
                                  VersionedComponent componentA,
                                  VersionedComponent componentB,
                                  Object valueA,
                                  Object valueB)

difference

private FlowDifference difference(DifferenceType type,
                                  VersionedComponent componentA,
                                  VersionedComponent componentB,
                                  String fieldName,
                                  Object valueA,
                                  Object valueB)