public class StreamProcessorDescriptor extends Object
Modifier and Type | Class and Description |
---|---|
static class |
StreamProcessorDescriptor.ComputationDescriptor |
static class |
StreamProcessorDescriptor.StreamDescriptor |
Modifier and Type | Field and Description |
---|---|
List<StreamProcessorDescriptor.ComputationDescriptor> |
computations |
String |
config |
static Integer |
DEFAULT_CONCURRENCY |
Integer |
defaultConcurrency |
Integer |
defaultPartitions |
Class<? extends StreamProcessorTopology> |
klass |
String |
name |
Map<String,String> |
options |
List<StreamProcessorDescriptor.StreamDescriptor> |
streams |
Constructor and Description |
---|
StreamProcessorDescriptor() |
Modifier and Type | Method and Description |
---|---|
String |
getName() |
Settings |
getSettings() |
Topology |
getTopology() |
public static final Integer DEFAULT_CONCURRENCY
public Class<? extends StreamProcessorTopology> klass
public Integer defaultConcurrency
public Integer defaultPartitions
public List<StreamProcessorDescriptor.ComputationDescriptor> computations
public List<StreamProcessorDescriptor.StreamDescriptor> streams
public StreamProcessorDescriptor()
public Settings getSettings()
public Topology getTopology()
Copyright © 2018 Nuxeo. All rights reserved.