public class KafkaSupervisorReport
extends io.druid.indexing.overlord.supervisor.SupervisorReport
Modifier and Type | Class and Description |
---|---|
static class |
KafkaSupervisorReport.KafkaSupervisorReportPayload |
Constructor and Description |
---|
KafkaSupervisorReport(String id,
org.joda.time.DateTime generationTime,
KafkaSupervisorReport.KafkaSupervisorReportPayload payload) |
KafkaSupervisorReport(String dataSource,
org.joda.time.DateTime generationTime,
String topic,
Integer partitions,
Integer replicas,
Long durationSeconds,
Map<Integer,Long> latestOffsets,
Map<Integer,Long> minimumLag,
Long aggregateLag,
org.joda.time.DateTime offsetsLastUpdated) |
Modifier and Type | Method and Description |
---|---|
void |
addTask(TaskReportData data) |
KafkaSupervisorReport.KafkaSupervisorReportPayload |
getPayload() |
String |
toString() |
public KafkaSupervisorReport(String id, org.joda.time.DateTime generationTime, KafkaSupervisorReport.KafkaSupervisorReportPayload payload)
public KafkaSupervisorReport(String dataSource, org.joda.time.DateTime generationTime, String topic, Integer partitions, Integer replicas, Long durationSeconds, @Nullable Map<Integer,Long> latestOffsets, @Nullable Map<Integer,Long> minimumLag, @Nullable Long aggregateLag, @Nullable org.joda.time.DateTime offsetsLastUpdated)
public KafkaSupervisorReport.KafkaSupervisorReportPayload getPayload()
getPayload
in class io.druid.indexing.overlord.supervisor.SupervisorReport
public void addTask(TaskReportData data)
Copyright © 2022 The Apache Software Foundation. All rights reserved.