diff --git a/component/src/main/java/io/siddhi/extension/execution/reorder/utils/WindowCoverage.java b/component/src/main/java/io/siddhi/extension/execution/reorder/utils/WindowCoverage.java index 1632ce6..adb398b 100644 --- a/component/src/main/java/io/siddhi/extension/execution/reorder/utils/WindowCoverage.java +++ b/component/src/main/java/io/siddhi/extension/execution/reorder/utils/WindowCoverage.java @@ -1,3 +1,21 @@ +/* + * Copyright (c) 2019, WSO2 Inc. (http://www.wso2.org) All Rights Reserved. + * + * WSO2 Inc. licenses this file to you under the Apache License, + * Version 2.0 (the "License"); you may not use this file except + * in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + package io.siddhi.extension.execution.reorder.utils; import org.apache.log4j.Logger; @@ -30,7 +48,6 @@ public WindowCoverage(double errorThreshold) { * @param criticalValue critical value for algorithm * @return windowCoverageThreshold */ - public double calculateWindowCoverageThreshold(double criticalValue, List listOfData) { double mean = calculateMean(listOfData); double variance = calculateVariance(listOfData, mean); @@ -95,7 +112,6 @@ private double calculateVariance(List listOfData, double meanValue) { * @param windowSize Size of window * @return runtimeWindowCoverage */ - public double calculateRuntimeWindowCoverage(List eventTimestamps, long windowSize) { // long start = System.currentTimeMillis(); double runtimeWindowCoverage = -1; diff --git a/component/src/test/java/io/siddhi/extension/execution/reorder/AlphaKSlackExtensionTestCase.java b/component/src/test/java/io/siddhi/extension/execution/reorder/AlphaKSlackExtensionTestCase.java index f909123..80423d3 100644 --- a/component/src/test/java/io/siddhi/extension/execution/reorder/AlphaKSlackExtensionTestCase.java +++ b/component/src/test/java/io/siddhi/extension/execution/reorder/AlphaKSlackExtensionTestCase.java @@ -224,7 +224,6 @@ public void receive(io.siddhi.core.event.Event[] events) { inputHandler.send(new Object[]{34L, 51.0}); inputHandler.send(new Object[]{32L, 27.0}); - SiddhiTestHelper.waitForEvents(waitTime, 33, count, timeout); executionPlanRuntime.shutdown(); }