Buffers URLs to be processed into separate queues; used by spouts.
Abstract class for URLBuffer interface, meant to simplify the code of the implementations and provide some default methods
Determines the priority of the buffers based on the number of URLs acked in a configurable period of time.
Checks how long the last N URLs took to work out whether a queue should release a URL.
Simple implementation of a URLBuffer which rotates on the queues without applying any priority.
Copyright © 2020 DigitalPebble Ltd. All rights reserved.