Class KafkaPartitionScanSpec
java.lang.Object
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec
-
Constructor Summary
ConstructorDescriptionKafkaPartitionScanSpec
(String topicName, int partitionId, long startOffset, long endOffset) -
Method Summary
Modifier and TypeMethodDescriptionclone()
boolean
long
int
long
int
hashCode()
void
mergeScanSpec
(String functionName, KafkaPartitionScanSpec scanSpec) toString()
-
Constructor Details
-
KafkaPartitionScanSpec
-
-
Method Details
-
getTopicName
-
getPartitionId
public int getPartitionId() -
getStartOffset
public long getStartOffset() -
getEndOffset
public long getEndOffset() -
mergeScanSpec
-
equals
-
hashCode
public int hashCode() -
toString
-
clone
-