public class StreamProcessorDescriptor extends Object implements Descriptor
Modifier and Type | Class and Description |
---|---|
static class |
StreamProcessorDescriptor.ComputationDescriptor |
static class |
StreamProcessorDescriptor.PolicyDescriptor |
static class |
StreamProcessorDescriptor.StreamDescriptor |
Modifier and Type | Field and Description |
---|---|
List<StreamProcessorDescriptor.ComputationDescriptor> |
computations |
String |
config |
static Integer |
DEFAULT_CONCURRENCY |
String |
defaultCodec |
Integer |
defaultConcurrency |
Integer |
defaultPartitions |
protected ComputationPolicy |
defaultPolicy |
Class<? extends StreamProcessorTopology> |
klass |
String |
name |
Map<String,String> |
options |
List<StreamProcessorDescriptor.PolicyDescriptor> |
policies |
List<StreamProcessorDescriptor.StreamDescriptor> |
streams |
UNIQUE_DESCRIPTOR_ID
Constructor and Description |
---|
StreamProcessorDescriptor() |
Modifier and Type | Method and Description |
---|---|
protected ComputationPolicy |
getComputationPolicy(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor) |
ComputationPolicy |
getDefaultPolicy() |
String |
getId()
The descriptor id, descriptors with same id are merged.
|
ComputationPolicy |
getPolicy(String computationName) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
doesRemove, merge
public static final Integer DEFAULT_CONCURRENCY
public Class<? extends StreamProcessorTopology> klass
public Integer defaultConcurrency
public Integer defaultPartitions
public String defaultCodec
public List<StreamProcessorDescriptor.ComputationDescriptor> computations
public List<StreamProcessorDescriptor.StreamDescriptor> streams
public List<StreamProcessorDescriptor.PolicyDescriptor> policies
protected ComputationPolicy defaultPolicy
public StreamProcessorDescriptor()
public ComputationPolicy getPolicy(String computationName)
protected ComputationPolicy getComputationPolicy(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor)
public ComputationPolicy getDefaultPolicy()
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.