Uses of Class
org.apache.nifi.processor.util.pattern.RoutingResult

  • Uses of RoutingResult in org.apache.nifi.processor.util.pattern

    Methods in org.apache.nifi.processor.util.pattern with parameters of type RoutingResult
    Modifier and Type
    Method
    Description
    boolean
    PartialFunctions.AdjustFailed.apply(org.apache.nifi.processor.ProcessContext context, RoutingResult result)
     
    void
    PartialFunctions.AdjustRoute.apply(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, RoutingResult result)
     
    List<org.apache.nifi.flowfile.FlowFile>
    PartialFunctions.FetchFlowFiles.apply(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, RoutingResult result)
     
    void
    PartialFunctions.TransferFlowFiles.apply(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, RoutingResult result)
     
    void
    Put.PutFlowFile.apply(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, C connection, org.apache.nifi.flowfile.FlowFile flowFile, RoutingResult result)
     
    List<FFG>
    PutGroup.GroupFlowFiles.apply(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, C connection, List<org.apache.nifi.flowfile.FlowFile> flowFiles, RoutingResult result)
     
    void
    PutGroup.PutFlowFiles.apply(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, C connection, FFG inputFlowFileGroup, RoutingResult result)
     
    static <C> ExceptionHandler.OnError<C,org.apache.nifi.flowfile.FlowFile>
    ExceptionHandler.createOnError(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, RoutingResult routingResult, org.apache.nifi.processor.Relationship relFailure, org.apache.nifi.processor.Relationship relRetry)
    Create a ExceptionHandler.OnError function instance that routes input based on ErrorTypes.Result destination and penalty.
    static <C, I extends PartialFunctions.FlowFileGroup>
    ExceptionHandler.OnError<C,I>
    ExceptionHandler.createOnGroupError(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, RoutingResult routingResult, org.apache.nifi.processor.Relationship relFailure, org.apache.nifi.processor.Relationship relRetry)
    Same as ExceptionHandler.createOnError(ProcessContext, ProcessSession, RoutingResult, Relationship, Relationship) for FlowFileGroup.
    void
    RoutingResult.merge(RoutingResult r)
     
    protected void
    Put.putFlowFiles(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, C connection, List<org.apache.nifi.flowfile.FlowFile> flowFiles, RoutingResult result)
    Put fetched FlowFiles to a data storage.
    protected void
    PutGroup.putFlowFiles(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, FC functionContext, C connection, List<org.apache.nifi.flowfile.FlowFile> flowFiles, RoutingResult result)