File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
krescent-core/src/main/kotlin/dev/helight/krescent/source/impl Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,9 @@ import java.util.*
1717 * into a single continuous flow of events. Events are streamed in order of their timestamps across
1818 * the provided sources.
1919 *
20+ * Fetch operations are performed in lazy batches, fetching a maximum of [batchSize] events from each source
21+ * at a time. Streaming operations use a k-way merge with a minimum age threshold for newly received events.
22+ *
2023 * @param sources A map of string keys to their corresponding [StreamingEventSource] instances. Each source
2124 * represents an independent stream of events to be merged.
2225 * @param minAge The minimum age (in milliseconds) of events to be considered safe for streaming. Events
You can’t perform that action at this time.
0 commit comments