org.apache.drill.exec.store.kafka

Class KafkaPartitionScanSpec

java.lang.Object

org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec

public class KafkaPartitionScanSpec
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaPartitionScanSpec(String topicName, int partitionId, long startOffset, long endOffset)

Method Summary

Modifier and Type	Method and Description
KafkaPartitionScanSpec	clone()
boolean	equals(Object obj)
long	getEndOffset()
int	getPartitionId()
long	getStartOffset()
String	getTopicName()
int	hashCode()
void	mergeScanSpec(String functionName, KafkaPartitionScanSpec scanSpec)
String	toString()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaPartitionScanSpec

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

Method Detail

getTopicName

public String getTopicName()

getPartitionId

public int getPartitionId()

getStartOffset

public long getStartOffset()

getEndOffset

public long getEndOffset()

mergeScanSpec

public void mergeScanSpec(String functionName,
                          KafkaPartitionScanSpec scanSpec)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

clone

public KafkaPartitionScanSpec clone()

Overrides:

clone in class Object