Skip to content
Snippets Groups Projects
Commit 59d9d755 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Align uc3 to the other impls to use days instead of seconds

parent 75a3a3d3
No related branches found
No related tags found
1 merge request!275Refactor hazelcast jet benchmarks:
......@@ -22,8 +22,8 @@ public class HistoryService {
private static final String KAFKA_OUTPUT_TOPIC_DEFAULT = "output";
// UC3 specific (default)
private static final String WINDOW_SIZE_IN_SECONDS_DEFAULT = "2629800";
private static final String HOPSIZE_IN_SEC_DEFAULT = "86400";
private static final String WINDOW_SIZE_IN_SECONDS_DEFAULT = "30";
private static final String HOPSIZE_IN_SEC_DEFAULT = "1";
// Job name (default)
private static final String JOB_NAME = "uc3-hazelcastjet";
......
......@@ -109,8 +109,8 @@ public class Uc3PipelineBuilder {
// group by new keys
.groupingKey(Entry::getKey)
// Sliding/Hopping Window
.window(WindowDefinition.sliding(TimeUnit.SECONDS.toMillis(windowSizeInSeconds),
TimeUnit.SECONDS.toMillis(hoppingSizeInSeconds)))
.window(WindowDefinition.sliding(TimeUnit.DAYS.toMillis(windowSizeInSeconds),
TimeUnit.DAYS.toMillis(hoppingSizeInSeconds)))
// get average value of group (sensoreId,hourOfDay)
.aggregate(
AggregateOperations.averagingDouble(record -> record.getValue().getValueInW()))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment