Package org.apache.druid.indexer.report

Class IngestionStatsAndErrors

java.lang.Object
org.apache.druid.indexer.report.IngestionStatsAndErrors
public class IngestionStatsAndErrors extends Object

  • Constructor Details

    • IngestionStatsAndErrors

      public IngestionStatsAndErrors(IngestionState ingestionState, Map<String,Object> unparseableEvents, Map<String,Object> rowStats, @Nullable String errorMsg, boolean segmentAvailabilityConfirmed, long segmentAvailabilityWaitTimeMs, Map<String,Long> recordsProcessed, @Nullable Long segmentsRead, @Nullable Long segmentsPublished)

  • Method Details

    • getIngestionState

      public IngestionState getIngestionState()

    • getUnparseableEvents

      public Map<String,Object> getUnparseableEvents()

    • getRowStats

      public Map<String,Object> getRowStats()

    • getErrorMsg

      @Nullable public String getErrorMsg()

    • isSegmentAvailabilityConfirmed

      public boolean isSegmentAvailabilityConfirmed()

    • getSegmentAvailabilityWaitTimeMs

      public long getSegmentAvailabilityWaitTimeMs()

    • getRecordsProcessed

      @Nullable public Map<String,Long> getRecordsProcessed()

    • getSegmentsRead

      @Nullable public Long getSegmentsRead()

    • getSegmentsPublished

      @Nullable public Long getSegmentsPublished()

    • getPayloadFromTaskReports

      public static IngestionStatsAndErrors getPayloadFromTaskReports(Map<String,TaskReport> taskReports)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object