@Test void test_Aggregate_NullList_NotEnoughData() { final DefaultAggregator aggregator = new DefaultAggregator(); CloudEvent cloudEvent = aggregator.aggregate(model, EVALUATE_ALL_EXECUTION_ID, null, configBean); TraceEvent traceEvent = assertValidCloudEventAndGetData(cloudEvent, EVALUATE_ALL_EXECUTION_ID); assertTraceEventWithNotEnoughData(traceEvent); }
@Override public CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean) { return events == null || events.isEmpty() ? buildNotEnoughDataCloudEvent(model, executionId, configBean) : buildDefaultCloudEvent(model, executionId, events, configBean); }
DefaultAggregator implements Aggregator { @Override public CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean) { return events == null || events.isEmpty() ? buildNotEnoughDataCloudEvent(model, executionId, configBean) : buildDefaultCloudEvent(model, executionId, events, configBean); } }
DefaultAggregator implements Aggregator { @Override public CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean) { return events == null || events.isEmpty() ? buildNotEnoughDataCloudEvent(model, executionId, configBean) : buildDefaultCloudEvent(model, executionId, events, configBean); }  }
DefaultAggregator implements Aggregator { @Override public CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean) { return events == null || events.isEmpty() ? buildNotEnoughDataCloudEvent(model, executionId, configBean) : buildDefaultCloudEvent(model, executionId, events, configBean); }  @Override CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean); }
DefaultAggregator implements Aggregator { @Override public CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean) { return events == null || events.isEmpty() ? buildNotEnoughDataCloudEvent(model, executionId, configBean) : buildDefaultCloudEvent(model, executionId, events, configBean); }  @Override CloudEvent aggregate(DMNModel model, String executionId, List<EvaluateEvent> events, ConfigBean configBean);  }