Skip to content

Commit

Permalink
Merge pull request #40 from mohanvive/master
Browse files Browse the repository at this point in the history
Resolve merge conflicts
  • Loading branch information
pcnfernando authored Jun 17, 2019
2 parents 63caebe + e45cb39 commit 93033d6
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 3 deletions.
Original file line number Diff line number Diff line change
@@ -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;
Expand Down Expand Up @@ -30,7 +48,6 @@ public WindowCoverage(double errorThreshold) {
* @param criticalValue critical value for algorithm
* @return windowCoverageThreshold
*/

public double calculateWindowCoverageThreshold(double criticalValue, List<Double> listOfData) {
double mean = calculateMean(listOfData);
double variance = calculateVariance(listOfData, mean);
Expand Down Expand Up @@ -95,7 +112,6 @@ private double calculateVariance(List<Double> listOfData, double meanValue) {
* @param windowSize Size of window
* @return runtimeWindowCoverage
*/

public double calculateRuntimeWindowCoverage(List<Long> eventTimestamps, long windowSize) {
// long start = System.currentTimeMillis();
double runtimeWindowCoverage = -1;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}
Expand Down

0 comments on commit 93033d6

Please sign in to comment.