eclipse-sailing-analytics/sailing-analytics
1
0 Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-10-07 21:01:03 +00:00
Code Activity

Removed the dependency from RegestryFunctionsProvider to Activator

Browse Source
This commit is contained in:
Lennart Hensler committed 2014-02-19 17:48:57 +01:00
1 parent 1056624d4f
commit 53b97c3bc1
3 files changed
+11 -9
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/Activator.java
+1 -1
View File
@@ -37,7 +37,7 @@ public class Activator implements BundleActivator {
registerDataMiningClassesWithMarkedMethodsService();
FunctionRegistry functionRegistry = createAndBuildFunctionRegistry();
FunctionProvider functionProvider = new RegistryFunctionsProvider(functionRegistry);
FunctionProvider functionProvider = new RegistryFunctionsProvider(functionRegistry, getExecutor());
dataMiningService = new DataMiningServiceImpl(functionRegistry, functionProvider);
registerDataMiningService();
java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/function/RegistryFunctionsProvider.java
+5 -3
View File
@@ -3,11 +3,11 @@ package com.sap.sailing.datamining.impl.function;
import java.util.Collection;
import java.util.HashSet;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sap.sailing.datamining.builders.FilterByCriteriaBuilder;
import com.sap.sailing.datamining.impl.Activator;
import com.sap.sailing.datamining.impl.PartitioningParallelFilter;
import com.sap.sse.datamining.components.FilterCriteria;
import com.sap.sse.datamining.components.ParallelFilter;
@@ -23,9 +23,11 @@ public class RegistryFunctionsProvider implements FunctionProvider {
private static final Logger LOGGER = Logger.getLogger(RegistryFunctionsProvider.class.getName());
private FunctionRegistry functionRegistry;
private ThreadPoolExecutor executor;
public RegistryFunctionsProvider(FunctionRegistry functionRegistry) {
public RegistryFunctionsProvider(FunctionRegistry functionRegistry, ThreadPoolExecutor executor) {
this.functionRegistry = functionRegistry;
this.executor = executor;
}
@Override
@@ -59,7 +61,7 @@ public class RegistryFunctionsProvider implements FunctionProvider {
private ParallelFilter<Function<?>> createFilterForCriteria(FilterCriteria<Function<?>> filterCriteria) {
WorkerBuilder<FiltrationWorker<Function<?>>> workerBuilder = new FilterByCriteriaBuilder<Function<?>>(filterCriteria);
return new PartitioningParallelFilter<>(workerBuilder, Activator.getExecutor());
return new PartitioningParallelFilter<>(workerBuilder, executor);
}
@Override