Package org.apache.nifi.processors.standard.merge

Class RecordBinThresholds

java.lang.Object
org.apache.nifi.processors.standard.merge.RecordBinThresholds
public class RecordBinThresholds extends Object

  • Field Details

    • minRecords

      private final int minRecords

    • maxRecords

      private final int maxRecords

    • minBytes

      private final long minBytes

    • maxBytes

      private final long maxBytes

    • maxBinMillis

      private final long maxBinMillis

    • maxBinAge

      private final String maxBinAge

    • fragmentCountAttribute

      private final Optional<String> fragmentCountAttribute

    • fragmentCount

      private Integer fragmentCount

  • Constructor Details

    • RecordBinThresholds

      public RecordBinThresholds(int minRecords, int maxRecords, long minBytes, long maxBytes, long maxBinMillis, String maxBinAge, String fragmentCountAttribute)

  • Method Details

    • getMinRecords

      public int getMinRecords()

    • getMaxRecords

      public int getMaxRecords()

    • getMinBytes

      public long getMinBytes()

    • getMaxBytes

      public long getMaxBytes()

    • getMaxBinMillis

      public long getMaxBinMillis()

    • getMaxBinAge

      public String getMaxBinAge()

    • getFragmentCountAttribute

      public Optional<String> getFragmentCountAttribute()

    • getFragmentCount

      public Integer getFragmentCount()

    • setFragmentCount

      public void setFragmentCount(Integer fragmentCount)