Package org.apache.nifi.processors.standard

Class EnforceOrder.OrderingContext

java.lang.Object
org.apache.nifi.processors.standard.EnforceOrder.OrderingContext
Enclosing class:
EnforceOrder
private class EnforceOrder.OrderingContext extends Object

  • Field Details

    • logger

      private final org.apache.nifi.logging.ComponentLog logger

    • processSession

      private final org.apache.nifi.processor.ProcessSession processSession

    • processContext

      private final org.apache.nifi.processor.ProcessContext processContext

    • orderAttribute

      private final String orderAttribute

    • waitTimeoutMillis

      private final Long waitTimeoutMillis

    • getOrder

      private final Function<org.apache.nifi.flowfile.FlowFile,Integer> getOrder

    • groupStates

      private final Map<String,String> groupStates

    • now

      private final long now

    • groupIdentifierProperty

      private final org.apache.nifi.components.PropertyValue groupIdentifierProperty

    • initOrderProperty

      private final org.apache.nifi.components.PropertyValue initOrderProperty

    • maxOrderProperty

      private final org.apache.nifi.components.PropertyValue maxOrderProperty

    • flowFileGroups

      private final Map<String,List<org.apache.nifi.flowfile.FlowFile>> flowFileGroups

    • flowFile

      private org.apache.nifi.flowfile.FlowFile flowFile

    • groupId

      private String groupId

    • order

      private Integer order

  • Constructor Details

    • OrderingContext

      private OrderingContext(org.apache.nifi.processor.ProcessContext processContext, org.apache.nifi.processor.ProcessSession processSession)

  • Method Details

    • setFlowFile

      private void setFlowFile(org.apache.nifi.flowfile.FlowFile flowFile)

    • computeGroupId

      private boolean computeGroupId()

    • computeOrder

      private boolean computeOrder()

    • computeMaxOrder

      private boolean computeMaxOrder()

    • computeInitialOrder

      private boolean computeInitialOrder()

    • markFlowFileValid

      private void markFlowFileValid()

    • transferFlowFiles

      private void transferFlowFiles()

    • transferResult

      private void transferResult(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.Relationship result, String detail, Integer expectedOrder)

    • transferToFailure

      private void transferToFailure(org.apache.nifi.flowfile.FlowFile flowFile, String message)

    • transferToFailure

      private void transferToFailure(org.apache.nifi.flowfile.FlowFile flowFile, String message, Throwable cause)

    • cleanupInactiveStates

      private void cleanupInactiveStates()