public static enum Querier.Mode extends Enum<Querier.Mode>
PARTITION
, it is assumed there are multiple queriers running in parallel and consuming parts of the
data for the query. Use this if you are distributing the Querier.consume(BulletRecord)
calls across multiple
machines. This fixes the semantics of the Querier.reset()
and the Querier.isClosed()
methods to keep the
correct windowing semantics.
If you are not distributing the data or recreating the querier instance in your parallelized step, you can
leave this at the default of ALL
.Modifier and Type | Method and Description |
---|---|
static Querier.Mode |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Querier.Mode[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final Querier.Mode PARTITION
public static final Querier.Mode ALL
public static Querier.Mode[] values()
for (Querier.Mode c : Querier.Mode.values()) System.out.println(c);
public static Querier.Mode valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullCopyright © 2021. All rights reserved.