public class KafkaSupervisorSpec extends Object
Constructor and Description |
---|
KafkaSupervisorSpec(io.druid.segment.indexing.DataSchema dataSchema,
KafkaSupervisorTuningConfig tuningConfig,
KafkaSupervisorIOConfig ioConfig,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
Map<String,Object> |
getContext() |
io.druid.segment.indexing.DataSchema |
getDataSchema() |
KafkaSupervisorIOConfig |
getIoConfig() |
KafkaSupervisorTuningConfig |
getTuningConfig() |
int |
hashCode() |
String |
toString() |
public KafkaSupervisorSpec(io.druid.segment.indexing.DataSchema dataSchema, KafkaSupervisorTuningConfig tuningConfig, KafkaSupervisorIOConfig ioConfig, Map<String,Object> context)
public io.druid.segment.indexing.DataSchema getDataSchema()
public KafkaSupervisorTuningConfig getTuningConfig()
public KafkaSupervisorIOConfig getIoConfig()
Copyright © 2022 The Apache Software Foundation. All rights reserved.