public static class StreamProcessorDescriptor.PolicyDescriptor extends Object implements Descriptor
Modifier and Type | Field and Description |
---|---|
Integer |
batchCapacity |
Duration |
batchThreshold |
Boolean |
continueOnFailure |
static Integer |
DEFAULT_BATCH_CAPACITY |
static Duration |
DEFAULT_BATCH_THRESHOLD |
static Duration |
DEFAULT_DELAY |
static Duration |
DEFAULT_MAX_DELAY |
static int |
DEFAULT_MAX_RETRIES |
Duration |
delay |
Class<? extends StreamComputationPolicy> |
klass |
Duration |
maxDelay |
Integer |
maxRetries |
String |
name |
UNIQUE_DESCRIPTOR_ID
Constructor and Description |
---|
PolicyDescriptor() |
Modifier and Type | Method and Description |
---|---|
String |
getId()
The descriptor id, descriptors with same id are merged.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
doesRemove, merge
public static final int DEFAULT_MAX_RETRIES
public static final Duration DEFAULT_DELAY
public static final Duration DEFAULT_MAX_DELAY
public static final Integer DEFAULT_BATCH_CAPACITY
public static final Duration DEFAULT_BATCH_THRESHOLD
public Integer maxRetries
public Boolean continueOnFailure
public Class<? extends StreamComputationPolicy> klass
public Integer batchCapacity
public Duration batchThreshold
public PolicyDescriptor()
public String getId()
Descriptor
To forbid multiple descriptors use UNIQUE_DESCRIPTOR_ID.
To forbid merge use a unique value, non-overriden toString()
for exemple.
getId
in interface Descriptor
Copyright © 2019 Nuxeo. All rights reserved.