Package com.linkedin.venice.unit.kafka.consumer.poll

Class AbstractPollStrategy

java.lang.Object

com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy

All Implemented Interfaces:

PollStrategy

Direct Known Subclasses:

ArbitraryOrderingPollStrategy, BlockingObserverPollStrategy, CompositePollStrategy, DuplicatingPollStrategy, FilteringPollStrategy, RandomPollStrategy

public abstract class AbstractPollStrategy
extends Object
implements PollStrategy

A base class which encapsulates the common plumbing needed by all PollStrategy implementations.

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	keepPollingWhenEmpty

Constructor Summary

Constructors

Constructor	Description
AbstractPollStrategy(boolean keepPollingWhenEmpty)
AbstractPollStrategy(boolean keepPollingWhenEmpty, int maxMessagePerPoll)

Method Summary

Modifier and Type	Method	Description
protected abstract PubSubTopicPartitionOffset	getNextPoll(Map<PubSubTopicPartition,Long> offsets)
protected void	incrementOffset(Map<PubSubTopicPartition,Long> offsets, PubSubTopicPartition topicPartition, long offset)
Map<PubSubTopicPartition,List<PubSubMessage<KafkaKey,KafkaMessageEnvelope,Long>>>	poll(InMemoryKafkaBroker broker, Map<PubSubTopicPartition,Long> offsets, long timeout)

Methods inherited from class java.lang.Object

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

Field Details

keepPollingWhenEmpty

protected final boolean keepPollingWhenEmpty

Constructor Details

AbstractPollStrategy

public AbstractPollStrategy(boolean keepPollingWhenEmpty)

AbstractPollStrategy

public AbstractPollStrategy(boolean keepPollingWhenEmpty,
 int maxMessagePerPoll)

Method Details

getNextPoll

protected abstract PubSubTopicPartitionOffset getNextPoll(Map<PubSubTopicPartition,Long> offsets)

poll

public Map<PubSubTopicPartition,List<PubSubMessage<KafkaKey,KafkaMessageEnvelope,Long>>> poll(InMemoryKafkaBroker broker,
 Map<PubSubTopicPartition,Long> offsets,
 long timeout)

Specified by:

poll in interface PollStrategy

incrementOffset

protected void incrementOffset(Map<PubSubTopicPartition,Long> offsets,
 PubSubTopicPartition topicPartition,
 long offset)