Changeset 232 for trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/web/commands/CMDloadSessionsFromClickstream.java

Timestamp:

10/05/11 00:39:28 (13 years ago)

Author:

sherbold

Message:

• extended de.ugoe.cs.eventbench.web.WeblogParser? with functionality to determine frequent users
• adapted command loadSessionsFromClickstream allow optional determination of frequent users

File:

• trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/web/commands/CMDloadSessionsFromClickstream.java (modified) (5 diffs)

trunk/EventBenchConsole/src/de/ugoe/cs/eventbench/web/commands/CMDloadSessionsFromClickstream.java

@@ -5 +5 @@
 import java.security.InvalidParameterException;
 import java.text.ParseException;
+import java.util.Collection;
 import java.util.List;
 
 import de.ugoe.cs.eventbench.data.GlobalDataContainer;
 import de.ugoe.cs.eventbench.web.WeblogParser;
+import de.ugoe.cs.eventbench.web.data.WebEvent;
 import de.ugoe.cs.util.console.Command;
 import de.ugoe.cs.util.console.Console;
@@ -38 +40 @@
                 int minLength = -1;
                 int maxLength = -1;
-                if( parameters.size()>=3 ) {
+                boolean generateFrequentUsers = false;
+                int frequentUserThreshold = 20;
+                if (parameters.size() >= 3) {
                         serverUrl = (String) parameters.get(2);
                 }
-                if (parameters.size() >= 5) {
+                if (parameters.size() >= 6) {
                         timeout = Integer.parseInt((String) parameters.get(3));
                         minLength = Integer.parseInt((String) parameters.get(4));
                         maxLength = Integer.parseInt((String) parameters.get(5));
                 }
+                if (parameters.size() >= 8) {
+                        generateFrequentUsers = Boolean.parseBoolean((String) parameters
+                                        .get(6));
+                        frequentUserThreshold = Integer
+                                        .parseInt((String) parameters.get(7));
+                }
 
                 WeblogParser parser = new WeblogParser();
-                if( serverUrl!=null ) {
+                if (serverUrl != null) {
                         parser.setUrl(serverUrl);
                 }
@@ -55 +65 @@
                         parser.setMinLength(minLength);
                         parser.setMaxLength(maxLength);
+                }
+                if (generateFrequentUsers) {
+                        parser.setFrequentUserThreshold(frequentUserThreshold);
                 }
                 try {
@@ -71 +84 @@
                         Console.traceln("Old data \"" + sequencesName + "\" overwritten");
                 }
+                if (generateFrequentUsers) {
+                        List<String> frequentUserIDs = parser.getFrequentUsers();
+                        List<Collection<List<WebEvent>>> frequentUserSessions = parser
+                                        .getFrequentUserSequences();
+                        for (int i = 0; i < frequentUserIDs.size(); i++) {
+                                GlobalDataContainer.getInstance().addData(
+                                                sequencesName + "_" + frequentUserIDs.get(i),
+                                                frequentUserSessions.get(i));
+                        }
+                }
         }
 
@@ -80 +103 @@
         @Override
         public void help() {
-                Console.println("Usage: loadSessionsFromClickstream <filename> <sequencesName> {<serverUrl>} {<timeout> <minSessionLength> <maxSessionLength>}");
+                Console.println("Usage: loadSessionsFromClickstream <filename> <sequencesName> {<serverUrl>} {<timeout> <minSessionLength> <maxSessionLength>} {<generateFrequentUsers> <frequentUserThreshold>}");
         }