public class KafkaPartitionScanSpec extends Object
Constructor and Description |
---|
KafkaPartitionScanSpec(String topicName,
int partitionId,
long startOffset,
long endOffset) |
Modifier and Type | Method and Description |
---|---|
KafkaPartitionScanSpec |
clone() |
boolean |
equals(Object obj) |
long |
getEndOffset() |
int |
getPartitionId() |
long |
getStartOffset() |
String |
getTopicName() |
void |
mergeScanSpec(String functionName,
KafkaPartitionScanSpec scanSpec) |
String |
toString() |
public KafkaPartitionScanSpec(String topicName, int partitionId, long startOffset, long endOffset)
public String getTopicName()
public int getPartitionId()
public long getStartOffset()
public long getEndOffset()
public void mergeScanSpec(String functionName, KafkaPartitionScanSpec scanSpec)
public KafkaPartitionScanSpec clone()
Copyright © 2021 The Apache Software Foundation. All rights reserved.