Index (nifi-put-pattern 2.6.0 API)

A C D E F G H I L M N O P R S T U V Y
All Classes and Interfaces|All Packages|Serialized Form

A

adjustError - Variable in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Adjust error type based on the context.
adjustError(BiFunction<C, ErrorTypes, ErrorTypes.Result>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Specify a function that adjust ErrorType based on a function context.
adjustFailed - Variable in class org.apache.nifi.processor.util.pattern.Put
adjustFailed(PartialFunctions.AdjustFailed) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function that adjust if the result is failed before we call the onFailed or onCompleted function.
adjustRoute - Variable in class org.apache.nifi.processor.util.pattern.Put
adjustRoute(PartialFunctions.AdjustRoute<FC>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function that adjust routed FlowFiles before transfer it.
andThen(ExceptionHandler.OnError<C, I>) - Method in interface org.apache.nifi.processor.util.pattern.ExceptionHandler.OnError
andThen(PartialFunctions.TransferFlowFiles<FC>) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.TransferFlowFiles
apply(C, I, ErrorTypes.Result, Exception) - Method in interface org.apache.nifi.processor.util.pattern.ExceptionHandler.OnError
apply(I) - Method in interface org.apache.nifi.processor.util.pattern.ExceptionHandler.Procedure
apply(ProcessContext, ProcessSession, FC, C) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.Cleanup
apply(ProcessContext, ProcessSession, FC, C) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.OnCompleted
apply(ProcessContext, ProcessSession, FC, C, FFG, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PutGroup.PutFlowFiles
apply(ProcessContext, ProcessSession, FC, C, Exception) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.OnFailed
apply(ProcessContext, ProcessSession, FC, C, List<FlowFile>, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PutGroup.GroupFlowFiles
apply(ProcessContext, ProcessSession, FC, C, FlowFile, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.Put.PutFlowFile
apply(ProcessContext, ProcessSession, FC, List<FlowFile>) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.InitConnection
apply(ProcessContext, ProcessSession, FC, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.AdjustRoute
apply(ProcessContext, ProcessSession, FC, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.FetchFlowFiles
apply(ProcessContext, ProcessSession, FC, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.TransferFlowFiles
apply(ProcessContext, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.AdjustFailed

C

canRollback() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
cleanup - Variable in class org.apache.nifi.processor.util.pattern.Put
cleanup(PartialFunctions.Cleanup<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function which will be called in a finally block.
contains(Relationship) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult
createAdjustError(ComponentLog) - Static method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure: Create a function to use with ExceptionHandler that adjust error type based on functional context.
createAdjustRoute(Relationship...) - Static method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure: Create an PartialFunctions.AdjustRoute function to use with process pattern such as Put that adjust routed FlowFiles based on context.
createOnError(ProcessContext, ProcessSession, RoutingResult, Relationship, Relationship) - Static method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Create a ExceptionHandler.OnError function instance that routes input based on ErrorTypes.Result destination and penalty.
createOnError(ExceptionHandler.OnError<FCT, I>) - Static method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
createOnGroupError(ProcessContext, ProcessSession, RoutingResult, Relationship, Relationship) - Static method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Same as ExceptionHandler.createOnError(ProcessContext, ProcessSession, RoutingResult, Relationship, Relationship) for FlowFileGroup.
createRollbackOnFailureProperty(String) - Static method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure

D

Defer - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: The input was not ready for being processed.
destination - Variable in enum class org.apache.nifi.processor.util.pattern.ErrorTypes
destination - Variable in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
destination() - Method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes
destination() - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
Destination() - Constructor for enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination
discontinue - Variable in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
discontinue() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
DiscontinuedException - Exception Class in org.apache.nifi.processor.util.pattern: Represents a looping process was discontinued.
DiscontinuedException(String) - Constructor for exception class org.apache.nifi.processor.util.pattern.DiscontinuedException
DiscontinuedException(String, Throwable) - Constructor for exception class org.apache.nifi.processor.util.pattern.DiscontinuedException

E

equals(Object) - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
ErrorTypes - Enum Class in org.apache.nifi.processor.util.pattern: Represents general error types and how it should be treated.
ErrorTypes(ErrorTypes.Destination, ErrorTypes.Penalty) - Constructor for enum class org.apache.nifi.processor.util.pattern.ErrorTypes
ErrorTypes.Destination - Enum Class in org.apache.nifi.processor.util.pattern: Represents the destination of input.
ErrorTypes.Penalty - Enum Class in org.apache.nifi.processor.util.pattern: Indicating yield or penalize the processing when transfer the input.
ErrorTypes.Result - Class in org.apache.nifi.processor.util.pattern: Result represents a result of a procedure.
ExceptionHandler<C> - Class in org.apache.nifi.processor.util.pattern: ExceptionHandler provides a structured Exception handling logic composed by reusable partial functions.
ExceptionHandler() - Constructor for class org.apache.nifi.processor.util.pattern.ExceptionHandler
ExceptionHandler.OnError<C,I> - Interface in org.apache.nifi.processor.util.pattern
ExceptionHandler.Procedure<I> - Interface in org.apache.nifi.processor.util.pattern
execute(C, I, ExceptionHandler.Procedure<I>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Executes specified procedure function with the input.
execute(C, I, ExceptionHandler.Procedure<I>, ExceptionHandler.OnError<C, I>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Executes specified procedure function with the input.
execute(ProcessSession) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.OnTrigger

F

Failure - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination
fetchFlowFiles - Variable in class org.apache.nifi.processor.util.pattern.Put
fetchFlowFiles(PartialFunctions.FetchFlowFiles<FC>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function that fetches incoming FlowFIles.
fetchSingleFlowFile() - Static method in class org.apache.nifi.processor.util.pattern.PartialFunctions

G

getFlowFiles() - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.FlowFileGroup
getProcessedCount() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
getRoutedFlowFiles() - Method in class org.apache.nifi.processor.util.pattern.RoutingResult
groupFetchedFlowFiles(PutGroup.GroupFlowFiles<FC, C, FFG>) - Method in class org.apache.nifi.processor.util.pattern.PutGroup: Specify a function that groups input FlowFiles into FlowFile groups.
groupFlowFiles - Variable in class org.apache.nifi.processor.util.pattern.PutGroup

H

hashCode() - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result

I

initConnection - Variable in class org.apache.nifi.processor.util.pattern.Put
initConnection(PartialFunctions.InitConnection<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify a function that establishes a connection to target data storage.
InvalidInput - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: The input will be sent to the failure route for recovery without penalizing.
isRollbackOnFailure() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
isTransactional() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure

L

logger - Variable in class org.apache.nifi.processor.util.pattern.Put

M

mapException - Variable in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Simply categorise an Exception.
mapException(Function<Exception, ErrorTypes>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Specify a function that maps an Exception to certain ErrorType.
merge(RoutingResult) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult

N

None - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Penalty

O

onCompleted - Variable in class org.apache.nifi.processor.util.pattern.Put
onCompleted(PartialFunctions.OnCompleted<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function which will be called if input FlowFiles were successfully put to a target storage.
onError - Variable in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Do some action to the input based on the final error type.
onError(ExceptionHandler.OnError<C, ?>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler: Specify a default OnError function that will be called if one is not explicitly specified when ExceptionHandler.execute(Object, Object, Procedure) is called.
onFailed - Variable in class org.apache.nifi.processor.util.pattern.Put
onFailed(PartialFunctions.OnFailed<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function which will be called if input FlowFiles failed being put to a target storage.
onTrigger(ProcessContext, ProcessSessionFactory, FCT, ComponentLog, PartialFunctions.OnTrigger) - Static method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
onTrigger(ProcessContext, ProcessSessionFactory, ComponentLog, PartialFunctions.OnTrigger) - Static method in class org.apache.nifi.processor.util.pattern.PartialFunctions: This method is identical to what AbstractProcessor.onTrigger(ProcessContext, ProcessSession) does.
onTrigger(ProcessContext, ProcessSessionFactory, ComponentLog, PartialFunctions.OnTrigger, PartialFunctions.RollbackSession) - Static method in class org.apache.nifi.processor.util.pattern.PartialFunctions
onTrigger(ProcessContext, ProcessSession, FC) - Method in class org.apache.nifi.processor.util.pattern.Put: Processor using this pattern is expected to call this method from its onTrigger.
org.apache.nifi.processor.util.pattern - package org.apache.nifi.processor.util.pattern

P

PartialFunctions - Class in org.apache.nifi.processor.util.pattern: This class contains various partial functions those are reusable among process patterns.
PartialFunctions() - Constructor for class org.apache.nifi.processor.util.pattern.PartialFunctions
PartialFunctions.AdjustFailed - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.AdjustRoute<FC> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.Cleanup<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.FetchFlowFiles<FC> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.FlowFileGroup - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.InitConnection<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.OnCompleted<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.OnFailed<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.OnTrigger - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.RollbackSession - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.TransferFlowFiles<FC> - Interface in org.apache.nifi.processor.util.pattern
penalize(ProcessContext, ProcessSession, FlowFile, ErrorTypes.Penalty) - Static method in class org.apache.nifi.processor.util.pattern.ExceptionHandler
Penalize - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Penalty
penalty - Variable in enum class org.apache.nifi.processor.util.pattern.ErrorTypes
penalty - Variable in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
penalty() - Method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes
penalty() - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
Penalty() - Constructor for enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Penalty
PersistentFailure - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: Procedure setting has to be fixed, otherwise the same error would occur irrelevant to the input.
proceed() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
processedCount - Variable in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
ProcessException - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination
Put<FC,C> - Class in org.apache.nifi.processor.util.pattern: Abstract Put pattern class with a generic onTrigger method structure, composed with various partial functions.
Put() - Constructor for class org.apache.nifi.processor.util.pattern.Put
Put.PutFlowFile<FC,C> - Interface in org.apache.nifi.processor.util.pattern
putFlowFile - Variable in class org.apache.nifi.processor.util.pattern.Put
putFlowFile(Put.PutFlowFile<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify a function that puts an incoming FlowFile to target data storage.
putFlowFile(Put.PutFlowFile<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.PutGroup: PutGroup does not support PutFileFile function for single FlowFile.
putFlowFiles - Variable in class org.apache.nifi.processor.util.pattern.PutGroup
putFlowFiles(ProcessContext, ProcessSession, FC, C, List<FlowFile>, RoutingResult) - Method in class org.apache.nifi.processor.util.pattern.Put: Put fetched FlowFiles to a data storage.
putFlowFiles(ProcessContext, ProcessSession, FC, C, List<FlowFile>, RoutingResult) - Method in class org.apache.nifi.processor.util.pattern.PutGroup
putFlowFiles(PutGroup.PutFlowFiles<FC, C, FFG>) - Method in class org.apache.nifi.processor.util.pattern.PutGroup: Specify a function that puts an input FlowFile group to a target storage using a given connection.
PutGroup<FC,C,FFG> - Class in org.apache.nifi.processor.util.pattern: Extended Put pattern capable of handling FlowFile groups.
PutGroup() - Constructor for class org.apache.nifi.processor.util.pattern.PutGroup
PutGroup.GroupFlowFiles<FC,C,FFG> - Interface in org.apache.nifi.processor.util.pattern
PutGroup.PutFlowFiles<FC,C,FFG> - Interface in org.apache.nifi.processor.util.pattern

R

result() - Method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes
Result(ErrorTypes.Destination, ErrorTypes.Penalty) - Constructor for class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
Retry - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination
rollback(ProcessSession, Throwable) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.RollbackSession
ROLLBACK_ON_FAILURE - Static variable in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
rollbackOnFailure - Variable in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
RollbackOnFailure - Class in org.apache.nifi.processor.util.pattern: RollbackOnFailure can be used as a function context for process patterns such as Put to provide a configurable error handling.
RollbackOnFailure(boolean, boolean) - Constructor for class org.apache.nifi.processor.util.pattern.RollbackOnFailure: Constructor.
routedFlowFiles - Variable in class org.apache.nifi.processor.util.pattern.RoutingResult
routeTo(List<FlowFile>, Relationship) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult
routeTo(FlowFile, Relationship) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult
RoutingResult - Class in org.apache.nifi.processor.util.pattern
RoutingResult() - Constructor for class org.apache.nifi.processor.util.pattern.RoutingResult

S

Self - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination
setLogger(ComponentLog) - Method in class org.apache.nifi.processor.util.pattern.Put
shouldDiscontinue() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure

T

TemporalFailure - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: The procedure is temporarily unavailable, usually due to the external service unavailability.
TemporalInputFailure - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: The input was not processed successfully due to some temporal error related to the specifics of the input.
toString() - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
transactional - Variable in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
transferFlowFiles - Variable in class org.apache.nifi.processor.util.pattern.Put
transferFlowFiles(PartialFunctions.TransferFlowFiles<FC>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify an optional function responsible for transferring routed FlowFiles.
transferRoutedFlowFiles() - Static method in class org.apache.nifi.processor.util.pattern.PartialFunctions

U

UnknownFailure - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: It is unknown whether the error is persistent or temporal, related to the input or not.

V

validateCompositePattern() - Method in class org.apache.nifi.processor.util.pattern.Put
validateCompositePattern() - Method in class org.apache.nifi.processor.util.pattern.PutGroup
valueOf(String) - Static method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Penalty: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Destination: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Penalty: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.nifi.processor.util.pattern.ErrorTypes: Returns an array containing the constants of this enum class, in the order they are declared.

Y

Yield - Enum constant in enum class org.apache.nifi.processor.util.pattern.ErrorTypes.Penalty

A C D E F G H I L M N O P R S T U V Y
All Classes and Interfaces|All Packages|Serialized Form