Skip to content

Configuration Parameters

An operator has several parameters that can be set via the OperatorConfig object returned at the instantiation of an operator via the manager:

OperatorConfig* operatorConfig = cloudControl->createOperator("myOperator", 0);
operatorConfig->setParameter((char*)SOMEPARAMTERKEY, (char*)"parameterValue");

Or via setting the parameters in the json file if the simple static manager is used:

"myOperator" : 
   "someParameterkey" : "paramterValue"


  • LIBRARYPATH - libraryPath
    Default value: "./"
    Path to operator library.

  • PARAMETERS - parameters
    Default value: `"parameter" ` Parameter to parameterize an operator, i.e., the value is passed to the operator's init() method.

  • TIMERINTERVAL - timerInterval
    Default value: "-1"
    Time interval for the generate() method of the operator in µs.

  • LOGGING - logging (still experimental)
    Default value: "0"

  • 0 = without event logging
  • 1 = with event logging

  • LAYERTYPE - layerType
    Default value: "noorder" (execution of events as they arrive on downstream operators)

  • deterministic (for an execution of events according to the timestamps)
  • experimental: noordernoduplicates, virtualsynchrony, virtualsynchronydelay, virtualsynchronydelayagree

Operator Partitioning

(see Partitioner interface)

  • SLICES - slices
    Default value: 2
    Number of partitions/slices an operator has.

  • PARTITIONERLIBRARY - partitionerLibrary
    Default value: KeyRangePartitioner
    Path to partitioner library. If no path is specified, the internal KeyRangePartitioner will be used by default.

  • ROUTINGKEYRANGESIZE - routingKeyRangeSize
    Default value: 1000
    If the KeyRangePartitioner is used.

Stateful Operators

(see "stateful operators")

  • STATEACCESSBUCKETS - stateAccessBuckets
    Default value: 10
    Number of buckets for the state. If the value is "-1", the operator has no state (stateless operator).

  • LOCKTYPE - lockType
    Default value: "spinLock"
    Locktype for the state access. Alternatives: "mutexLock", "rwLock" and "noLock"

Event Processing

  • PROCESSINGBATCHSIZE - processingBatchSize
    Default value: "10"
    How many events are processed per batch / cycle prior handing off to another thread.

  • PROCESSINGPRIORITY - processingPriority
    Default value: "0"
    Operators priority (0 = highest priority, 1 = is lower).

  • PROCESSINGTASKSGENERATOR -processingTasksGenerator
    Default value: "8"
    How many concurrent generating() calls / how many threads may concurrently call generate().

  • PROCESSINGTASKSPROCESSOR - processingTasksProcessor
    Default value: "8"
    How many concurrent process() calls / how many threads may concurrently call process().

Sending & Tuning

  • BUFFERBATCHTYPE - bufferBatchType
    Default value: "0"
    0 = BufferBatchDelegated - if the process cannot send an event because another one has acquired the lock, it puts the event in a list for pending ones.
    else BufferBatchDirect - if the process cannot send an event because another one has acquired the lock, it waits till it is its turn.

  • SENDINGBATCHSIZE - sendingBatchSize
    Default value: "1"
    Size of the list with events in bytes. If exceeded, the list is being sent.
    If you use a high value, the throughput increases, however, latency too.

  • BUFFERBATCHDELEGATEDPSIZE - bufferBatchDelegatedQueueSize
    Default value: "10"

  • BUFFERBATCHDELEGATEDQSIZE - bufferBatchDelegatedProcessingSize
    Default value: "10"

  • CHECKPOINTEPOCHLEN - checkPointEpochLength
    Default value: "-1"
    Determines the length between two checkpoints (time-stamp based).