Package org.apache.nifi.processors.standard

Class DistributeLoad.OverflowStrategy

java.lang.Object

org.apache.nifi.processors.standard.DistributeLoad.OverflowStrategy

All Implemented Interfaces:

DistributeLoad.DistributionStrategy

Enclosing class:

DistributeLoad

private class DistributeLoad.OverflowStrategy
extends Object
implements DistributeLoad.DistributionStrategy

Constructor Summary

Constructors

Modifier	Constructor	Description
private	OverflowStrategy()

Method Summary

Modifier and Type	Method	Description
org.apache.nifi.processor.Relationship	mapToRelationship(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.flowfile.FlowFile flowFile)
boolean	requiresAllDestinationsAvailable()

Methods inherited from class java.lang.Object

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

Constructor Details

OverflowStrategy

private OverflowStrategy()

Method Details

mapToRelationship

public org.apache.nifi.processor.Relationship mapToRelationship(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.flowfile.FlowFile flowFile)

Specified by:

mapToRelationship in interface DistributeLoad.DistributionStrategy

Parameters:

context - context

flowFile - flowFile

Returns:

a mapping of FlowFile to Relationship or null if the needed relationships are not available to accept files

requiresAllDestinationsAvailable

public boolean requiresAllDestinationsAvailable()

Specified by:

requiresAllDestinationsAvailable in interface DistributeLoad.DistributionStrategy