org.apache.flink.connector.kafka.source.split

Class KafkaPartitionSplit

java.lang.Object

org.apache.flink.connector.kafka.source.split.KafkaPartitionSplit

All Implemented Interfaces:

SourceSplit

Direct Known Subclasses:

KafkaPartitionSplitState

@Internal
public class KafkaPartitionSplit
extends Object
implements SourceSplit

A SourceSplit for a Kafka partition.

Field Summary

Fields

Modifier and Type	Field and Description
static long	COMMITTED_OFFSET
static long	EARLIEST_OFFSET
static long	LATEST_OFFSET
static long	NO_STOPPING_OFFSET
static Set<Long>	VALID_STARTING_OFFSET_MARKERS
static Set<Long>	VALID_STOPPING_OFFSET_MARKERS

Constructor Summary

Constructors

Constructor and Description
KafkaPartitionSplit(org.apache.kafka.common.TopicPartition tp, long startingOffset)
KafkaPartitionSplit(org.apache.kafka.common.TopicPartition tp, long startingOffset, long stoppingOffset)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	getPartition()
long	getStartingOffset()
Optional<Long>	getStoppingOffset()
String	getTopic()
org.apache.kafka.common.TopicPartition	getTopicPartition()
int	hashCode()
String	splitId() Get the split id of this source split.
static String	toSplitId(org.apache.kafka.common.TopicPartition tp)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

NO_STOPPING_OFFSET

public static final long NO_STOPPING_OFFSET

See Also:

Constant Field Values

LATEST_OFFSET

public static final long LATEST_OFFSET

See Also:

Constant Field Values

EARLIEST_OFFSET

public static final long EARLIEST_OFFSET

See Also:

Constant Field Values

COMMITTED_OFFSET

public static final long COMMITTED_OFFSET

See Also:

Constant Field Values

VALID_STARTING_OFFSET_MARKERS

public static final Set<Long> VALID_STARTING_OFFSET_MARKERS

VALID_STOPPING_OFFSET_MARKERS

public static final Set<Long> VALID_STOPPING_OFFSET_MARKERS

Constructor Detail

KafkaPartitionSplit

public KafkaPartitionSplit(org.apache.kafka.common.TopicPartition tp,
                           long startingOffset)

KafkaPartitionSplit

public KafkaPartitionSplit(org.apache.kafka.common.TopicPartition tp,
                           long startingOffset,
                           long stoppingOffset)

Method Detail

getTopic

public String getTopic()

getPartition

public int getPartition()

getTopicPartition

public org.apache.kafka.common.TopicPartition getTopicPartition()

getStartingOffset

public long getStartingOffset()

getStoppingOffset

public Optional<Long> getStoppingOffset()

splitId

public String splitId()

Description copied from interface: SourceSplit

Get the split id of this source split.

Specified by:

splitId in interface SourceSplit

Returns:

id of this source split.

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toSplitId

public static String toSplitId(org.apache.kafka.common.TopicPartition tp)