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 |
String |
defaultCodec |
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 |
---|---|
Codec<Record> |
getDefaultCodec(CodecService codecService) |
String |
getName() |
Settings |
getSettings(CodecService codecService) |
Topology |
getTopology() |
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 StreamProcessorDescriptor()
public Settings getSettings(CodecService codecService)
public Codec<Record> getDefaultCodec(CodecService codecService)
public Topology getTopology()
Copyright © 2018 Nuxeo. All rights reserved.