Package 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	Description
static class	StreamProcessorDescriptor.ComputationDescriptor
static class	StreamProcessorDescriptor.FilterDescriptor
static class	StreamProcessorDescriptor.PolicyDescriptor
static class	StreamProcessorDescriptor.StreamDescriptor

Field Summary

Fields

Modifier and Type	Field	Description
List<StreamProcessorDescriptor.ComputationDescriptor>	computations
String	config
static final Integer	DEFAULT_CONCURRENCY
String	defaultCodec
Integer	defaultConcurrency
boolean	defaultExternal
Integer	defaultPartitions
protected ComputationPolicy	defaultPolicy
protected boolean	isEnabled
Class<? extends StreamProcessorTopology>	klass
String	name
Map<String,String>	options
List<StreamProcessorDescriptor.PolicyDescriptor>	policies
static String	RECOVERY_SKIP_FIRST_FAILURES_OPTION
protected boolean	start
List<StreamProcessorDescriptor.StreamDescriptor>	streams

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

UNIQUE_DESCRIPTOR_ID

Constructor Summary

Constructors

Constructor	Description
StreamProcessorDescriptor()

Method Summary

Modifier and Type	Method	Description
protected ComputationPolicy	getComputationPolicy(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor)
ComputationPolicy	getDefaultPolicy()
String	getId()	The descriptor id, descriptors with same id are merged.
ComputationPolicy	getPolicy(String computationName)
boolean	isEnabled()
boolean	isStart()
void	setEnabled(boolean isEnabled)
void	setStart(boolean start)

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 Details

RECOVERY_SKIP_FIRST_FAILURES_OPTION

public static String RECOVERY_SKIP_FIRST_FAILURES_OPTION

isEnabled

protected boolean isEnabled

start

protected boolean start

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

defaultExternal

public boolean defaultExternal

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 Details

StreamProcessorDescriptor

public StreamProcessorDescriptor()

Method Details

getPolicy

public ComputationPolicy getPolicy(String computationName)

getComputationPolicy

protected ComputationPolicy getComputationPolicy(StreamProcessorDescriptor.PolicyDescriptor policyDescriptor)

getDefaultPolicy

public ComputationPolicy getDefaultPolicy()

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean isEnabled)

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

isStart

public boolean isStart()

setStart

public void setStart(boolean start)