Package org.apache.drill.exec.store.kafka

Class KafkaGroupScan.PartitionScanWork

java.lang.Object

org.apache.drill.exec.store.kafka.KafkaGroupScan.PartitionScanWork

All Implemented Interfaces:

Comparable<CompleteWork>, CompleteWork

Enclosing class:

KafkaGroupScan

public static class KafkaGroupScan.PartitionScanWork
extends Object
implements CompleteWork

Field Summary

Fields inherited from interface org.apache.drill.exec.store.schedule.CompleteWork

logger

Constructor Summary

Constructors

Constructor	Description
PartitionScanWork(EndpointByteMap byteMap, KafkaPartitionScanSpec partitionScanSpec)

Method Summary

Modifier and Type	Method	Description
int	compareTo(CompleteWork o)
EndpointByteMap	getByteMap()
KafkaPartitionScanSpec	getPartitionScanSpec()
long	getTotalBytes()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionScanWork

public PartitionScanWork(EndpointByteMap byteMap,
 KafkaPartitionScanSpec partitionScanSpec)

Method Details

compareTo

public int compareTo(CompleteWork o)

Specified by:

compareTo in interface Comparable<CompleteWork>

getTotalBytes

public long getTotalBytes()

Specified by:

getTotalBytes in interface CompleteWork

getByteMap

public EndpointByteMap getByteMap()

Specified by:

getByteMap in interface CompleteWork

getPartitionScanSpec

public KafkaPartitionScanSpec getPartitionScanSpec()