Class KafkaPartitionScanSpec

java.lang.Object
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec

public class KafkaPartitionScanSpec extends Object
  • Constructor Details

    • KafkaPartitionScanSpec

      public KafkaPartitionScanSpec(String topicName, int partitionId, long startOffset, long endOffset)
  • Method Details