case classMaxWaitingFutures(get: Int) extends Product with Serializable
MaxWaitingFutures is the maximum number of key-value pairs that the
SinkBolt in Storm will process before starting to force the
futures. For example, setting MaxWaitingFutures(100) means that if
a key-value pair is added to the OnlineStore and the (n - 100)th
write has not completed, Storm will block before moving on to the
next key-value pair.
TODO (https://github.com/twitter/summingbird/issues/83): look into
removing this due to the possibility of deadlock with the sink's
cache.
MaxWaitingFutures is the maximum number of key-value pairs that the SinkBolt in Storm will process before starting to force the futures. For example, setting MaxWaitingFutures(100) means that if a key-value pair is added to the OnlineStore and the (n - 100)th write has not completed, Storm will block before moving on to the next key-value pair.
TODO (https://github.com/twitter/summingbird/issues/83): look into removing this due to the possibility of deadlock with the sink's cache.