Free cookie consent management tool by TermsFeed Policy Generator

Ignore:
Timestamp:
01/14/09 17:29:48 (15 years ago)
Author:
gkronber
Message:

worked on RDF backend. Implemented query support to load datasets. Queries for dispatcher and results still missing. (#419)

Location:
branches/CEDMA-Refactoring-Ticket419/HeuristicLab.CEDMA.Server
Files:
2 edited

Legend:

Unmodified
Added
Removed

  • branches/CEDMA-Refactoring-Ticket419/HeuristicLab.CEDMA.Server/Dispatcher.cs

    r1116 r1129  
    5151
    5252    private void FillDispatchQueue() {
    53       Dictionary<Entity, Dictionary<int, int>> numberOfModelsOfTargetVariableOfDataSet = new Dictionary<Entity, Dictionary<int, int>>();
    54       var datasetStatements = store.Select(new Statement(Ontology.AnyEntity, Ontology.PredicateInstanceOf, Ontology.TypeDataSet));
    55       foreach (Statement datasetStatement in datasetStatements) {
    56         numberOfModelsOfTargetVariableOfDataSet.Add(datasetStatement.Subject, new Dictionary<int, int>());
    57         var modelStatements = store.Select(new Statement(datasetStatement.Subject, Ontology.PredicateHasModel, Ontology.AnyEntity));
    58         foreach (Statement modelStatement in modelStatements) {
    59           var modelAttributeStatements = store.Select(new Statement((Entity)modelStatement.Property, Ontology.PredicateModelAttribute, Ontology.AnyEntity));
    60           foreach (Statement modelAttrStatement in modelAttributeStatements) {
    61             var targetVariableStatements = store.Select(new Statement((Entity)modelAttrStatement.Property, Ontology.PredicateModelAttributeName, Ontology.AnyEntity))
    62                .Where(t => (string)((Literal)t.Property).Value == "TargetVariable")
    63                .SelectMany(t => store.Select(new Statement((Entity)modelAttrStatement.Property, Ontology.PredicateModelAttributeValue, Ontology.AnyEntity)))
    64                .GroupBy(t => (int)((Literal)t.Property).Value);
    65             foreach (var targetVariable in targetVariableStatements) {
    66               if (numberOfModelsOfTargetVariableOfDataSet[datasetStatement.Subject].ContainsKey(targetVariable.Key)) {
    67                 numberOfModelsOfTargetVariableOfDataSet[datasetStatement.Subject][targetVariable.Key] = targetVariable.Count();
    68               } else {
    69                 numberOfModelsOfTargetVariableOfDataSet[datasetStatement.Subject].Add(targetVariable.Key, targetVariable.Count());
    70               }
    71             }
    72           }
    73         }
    74       }
    75       foreach (KeyValuePair<Entity, Dictionary<int, int>> dataSetEntry in numberOfModelsOfTargetVariableOfDataSet) {
    76         DataSet dataSet = new DataSet(store, dataSetEntry.Key);
    77         foreach (int targetVariable in dataSet.Problem.AllowedTargetVariables)
    78           if (!dataSetEntry.Value.ContainsKey(targetVariable) || dataSetEntry.Value[targetVariable] < 10) {
    79             IEngine engine = CreateEngine(dataSet.Problem, targetVariable);
    80             if (engine != null) {
    81               QueueJob(new Execution(dataSetEntry.Key, engine, targetVariable));
    82             }
    83           }
    84       }
     53      //Dictionary<Entity, Dictionary<int, int>> numberOfModelsOfTargetVariableOfDataSet = new Dictionary<Entity, Dictionary<int, int>>();
     54      //var datasetStatements = store.Select(new Statement(Ontology.AnyEntity, Ontology.PredicateInstanceOf, Ontology.TypeDataSet));
     55      //foreach (Statement datasetStatement in datasetStatements) {
     56      //  numberOfModelsOfTargetVariableOfDataSet.Add(datasetStatement.Subject, new Dictionary<int, int>());
     57      //  var modelStatements = store.Select(new Statement(datasetStatement.Subject, Ontology.PredicateHasModel, Ontology.AnyEntity));
     58      //  foreach (Statement modelStatement in modelStatements) {
     59      //    var modelAttributeStatements = store.Select(new Statement((Entity)modelStatement.Property, Ontology.PredicateModelAttribute, Ontology.AnyEntity));
     60      //    foreach (Statement modelAttrStatement in modelAttributeStatements) {
     61      //      var targetVariableStatements = store.Select(new Statement((Entity)modelAttrStatement.Property, Ontology.PredicateModelAttributeName, Ontology.AnyEntity))
     62      //         .Where(t => (string)((Literal)t.Property).Value == "TargetVariable")
     63      //         .SelectMany(t => store.Select(new Statement((Entity)modelAttrStatement.Property, Ontology.PredicateModelAttributeValue, Ontology.AnyEntity)))
     64      //         .GroupBy(t => (int)((Literal)t.Property).Value);
     65      //      foreach (var targetVariable in targetVariableStatements) {
     66      //        if (numberOfModelsOfTargetVariableOfDataSet[datasetStatement.Subject].ContainsKey(targetVariable.Key)) {
     67      //          numberOfModelsOfTargetVariableOfDataSet[datasetStatement.Subject][targetVariable.Key] = targetVariable.Count();
     68      //        } else {
     69      //          numberOfModelsOfTargetVariableOfDataSet[datasetStatement.Subject].Add(targetVariable.Key, targetVariable.Count());
     70      //        }
     71      //      }
     72      //    }
     73      //  }
     74      //}
     75      //foreach (KeyValuePair<Entity, Dictionary<int, int>> dataSetEntry in numberOfModelsOfTargetVariableOfDataSet) {
     76      //  DataSet dataSet = new DataSet(store, dataSetEntry.Key);
     77      //  foreach (int targetVariable in dataSet.Problem.AllowedTargetVariables)
     78      //    if (!dataSetEntry.Value.ContainsKey(targetVariable) || dataSetEntry.Value[targetVariable] < 10) {
     79      //      IEngine engine = CreateEngine(dataSet.Problem, targetVariable);
     80      //      if (engine != null) {
     81      //        QueueJob(new Execution(dataSetEntry.Key, engine, targetVariable));
     82      //      }
     83      //    }
     84      //}
    8585    }
    8686

  • branches/CEDMA-Refactoring-Ticket419/HeuristicLab.CEDMA.Server/Server.cs

    r1060 r1129  
    7171      try {
    7272        NetTcpBinding binding = new NetTcpBinding();
    73         binding.MaxReceivedMessageSize = 100000000; // 100Mbytes
    74         binding.ReaderQuotas.MaxStringContentLength = 100000000; // also 100M chars
    75         binding.ReaderQuotas.MaxArrayLength = 100000000; // also 100M elements;
     73        binding.SendTimeout = new TimeSpan(1, 0, 0);
     74        binding.MaxReceivedMessageSize = 1000000000; // 100Mbytes
     75        binding.ReaderQuotas.MaxStringContentLength = 1000000000; // also 100M chars
     76        binding.ReaderQuotas.MaxArrayLength = 1000000000; // also 100M elements;
    7677        binding.Security.Mode = SecurityMode.None;
    7778
Note: See TracChangeset for help on using the changeset viewer.