org.nuxeo.runtime.stream

Class StreamProcessorDescriptor

java.lang.Object

org.nuxeo.runtime.stream.StreamProcessorDescriptor

All Implemented Interfaces:

Descriptor

public class StreamProcessorDescriptor
extends Object
implements Descriptor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamProcessorDescriptor.ComputationDescriptor
static class	StreamProcessorDescriptor.PolicyDescriptor
static class	StreamProcessorDescriptor.StreamDescriptor

Field Summary

Fields

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

Fields inherited from interface org.nuxeo.runtime.model.Descriptor

UNIQUE_DESCRIPTOR_ID

Constructor Summary

Constructors

Constructor and Description
StreamProcessorDescriptor()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.runtime.model.Descriptor

doesRemove, merge

Field Detail

DEFAULT_CONCURRENCY

public static final Integer DEFAULT_CONCURRENCY

name

public String name

config

public String config

klass

public Class<? extends StreamProcessorTopology> klass

defaultConcurrency

public Integer defaultConcurrency

defaultPartitions

public Integer defaultPartitions

defaultCodec

public String defaultCodec

options

public Map<String,String> options

computations

public List<StreamProcessorDescriptor.ComputationDescriptor> computations

streams

public List<StreamProcessorDescriptor.StreamDescriptor> streams

policies

public List<StreamProcessorDescriptor.PolicyDescriptor> policies

defaultPolicy

protected ComputationPolicy defaultPolicy

Constructor Detail

StreamProcessorDescriptor

public StreamProcessorDescriptor()

Method Detail

getPolicy

public ComputationPolicy getPolicy(String computationName)

getComputationPolicy

protected ComputationPolicy getComputationPolicy(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor)

getDefaultPolicy

public ComputationPolicy getDefaultPolicy()

getId

public String getId()

Description copied from interface: Descriptor

The descriptor id, descriptors with same id are merged.

To forbid multiple descriptors use UNIQUE_DESCRIPTOR_ID.

To forbid merge use a unique value, non-overriden toString() for exemple.

Specified by:

getId in interface Descriptor