Package org.apache.druid.java.util.common.guava

Class ParallelMergeCombiningSequence.CancellationGizmo

java.lang.Object

org.apache.druid.java.util.common.guava.ParallelMergeCombiningSequence.CancellationGizmo

Enclosing class:

ParallelMergeCombiningSequence<T>

public static class ParallelMergeCombiningSequence.CancellationGizmo
extends Object

Token used to stop internal parallel processing across all tasks in the merge pool. Allows any RecursiveAction signal the others and the output sequence that something bad happened and processing should cancel, such as a timeout, error, or connection loss.

Constructor Summary

Constructors

Constructor	Description
CancellationGizmo()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

CancellationGizmo

public CancellationGizmo()