Skip to content

Commit 8c32928

Browse files
committed
add default constructor
1 parent c575d0f commit 8c32928

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuator.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,11 @@ public AbstractThrottledPunctuator(
4141
this.meterRegistry = meterRegistry;
4242
}
4343

44+
public AbstractThrottledPunctuator(
45+
Clock clock, ThrottledPunctuatorConfig config, KeyValueStore<Long, List<T>> eventStore) {
46+
this(clock, config, eventStore, null);
47+
}
48+
4449
public void scheduleTask(long scheduleMs, T event) {
4550
long windowMs = normalize(scheduleMs);
4651
List<T> events = Optional.ofNullable(eventStore.get(windowMs)).orElse(new ArrayList<>());

kafka-streams-framework/src/test/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuatorTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,7 +194,7 @@ public TestPunctuator(
194194
Clock clock,
195195
ThrottledPunctuatorConfig config,
196196
KeyValueStore<Long, List<String>> objectStore) {
197-
super(clock, config, objectStore, null);
197+
super(clock, config, objectStore);
198198
}
199199

200200
void setReturnResult(String object, TaskResult result) {

0 commit comments

Comments
 (0)