Instance Constructors

1.  new TransactionFlatStreamsConfig(maxIdsPerIdPage: Int = 20000, maxPagesPerIdPagesBuffer: Int = 1, maxWorkingMemoryInBytesForIdPages: Int = 100 * 1024 * 1024, maxPayloadsPerPayloadsPage: Int = 1000, maxParallelIdCreateQueries: Int = 4, maxParallelIdConsumingQueries: Int = 4, maxParallelIdAssignQueries: Int = 4, maxParallelIdUnassignQueries: Int = 4, maxParallelPayloadCreateQueries: Int = 2, maxParallelPayloadConsumingQueries: Int = 2, maxParallelPayloadAssignQueries: Int = 2, maxParallelPayloadUnassignQueries: Int = 2, maxParallelPayloadQueries: Int = 2, transactionsProcessingParallelism: Int = 8)
   maxIdsPerIdPage

   Number of event ids to retrieve in a single query (a page of event ids).

   maxPagesPerIdPagesBuffer

   Number of id pages to store in a buffer. There is a buffer for each decomposed filtering constraint.

   maxWorkingMemoryInBytesForIdPages

   Memory for storing id pages across all id pages buffers. Per single stream.

   maxPayloadsPerPayloadsPage

   Number of event payloads to retrieve in a single query (a page of event payloads).

   maxParallelIdCreateQueries

   Number of parallel queries that fetch ids of create events. Per single stream.

   maxParallelIdConsumingQueries

   Number of parallel queries that fetch ids of consuming events. Per single stream.

   maxParallelIdAssignQueries

   Number of parallel queries that fetch ids of assign events. Per single stream.

   maxParallelIdUnassignQueries

   Number of parallel queries that fetch ids of unassign events. Per single stream.

   maxParallelPayloadCreateQueries

   Number of parallel queries that fetch payloads of create events. Per single stream.

   maxParallelPayloadConsumingQueries

   Number of parallel queries that fetch payloads of consuming events. Per single stream.

   maxParallelPayloadAssignQueries

   Number of parallel queries that fetch payloads of assign events. Per single stream.

   maxParallelPayloadUnassignQueries

   Number of parallel queries that fetch payloads of unassign events. Per single stream.

   maxParallelPayloadQueries

   Upper bound on the number of parallel queries that fetch payloads. Per single stream.

   transactionsProcessingParallelism

   Number of transactions to process in parallel. Per single stream.