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

Class CompositePollStrategy

java.lang.Object

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

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

All Implemented Interfaces:

PollStrategy

public class CompositePollStrategy
extends AbstractPollStrategy

A PollStrategy implementation which takes a queue of many poll strategies. It will drain each poll strategies in the order they are provided before moving on to the next one.

Field Summary

Fields inherited from class com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy

keepPollingWhenEmpty

Constructor Summary

Constructors

Constructor	Description
CompositePollStrategy(java.util.Queue<AbstractPollStrategy> pollStrategies)

Method Summary

Modifier and Type	Method	Description
protected PubSubTopicPartitionOffset	getNextPoll(java.util.Map<PubSubTopicPartition,java.lang.Long> offsets)

Methods inherited from class com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy

incrementOffset, poll

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositePollStrategy

public CompositePollStrategy(java.util.Queue<AbstractPollStrategy> pollStrategies)

Method Detail

getNextPoll

@Nullable
protected PubSubTopicPartitionOffset getNextPoll(java.util.Map<PubSubTopicPartition,java.lang.Long> offsets)

Specified by:

getNextPoll in class AbstractPollStrategy