perfsonar development work

Author: gijs
Date: 2007-09-07 09:03:11 -0400 (Fri, 07 Sep 2007)
New Revision: 2794

Modified:
   branches/new-structure/trunk/surfnet_java-flowsa-ma/.classpath
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/axis-1.4/WEB-INF/server-config.wsdd
   branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/service.properties
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaGetRequest.java
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaMAServiceEngine.java
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/TopFlowsResponse.java
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/NfdumpControll.java
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopData.java
   
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopQuery.java
Log:
groundwork topflow request/response

Modified: branches/new-structure/trunk/surfnet_java-flowsa-ma/.classpath
===================================================================
--- branches/new-structure/trunk/surfnet_java-flowsa-ma/.classpath      
2007-09-07 12:57:35 UTC (rev 2793)
+++ branches/new-structure/trunk/surfnet_java-flowsa-ma/.classpath      
2007-09-07 13:03:11 UTC (rev 2794)
@@ -2,7 +2,7 @@
 <classpath>
        <classpathentry kind="src" path="src/main/java"/>
        <classpathentry kind="src" path="src/test/java"/>
-       <classpathentry kind="con" 
path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+       <classpathentry kind="con" 
path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/java-1.5.0-sun-1.5.0.11"/>
        <classpathentry kind="con" 
path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"/>
        <classpathentry kind="output" path="bin"/>
 </classpath>

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/axis-1.4/WEB-INF/server-config.wsdd
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/axis-1.4/WEB-INF/server-config.wsdd
        2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/axis-1.4/WEB-INF/server-config.wsdd
        2007-09-07 13:03:11 UTC (rev 2794)
@@ -5,9 +5,9 @@
   <parameter name="enableNamespacePrefixOptimization" value="false"/>
   <parameter name="dotNetSoapEncFix" value="true"/>
   <parameter name="disablePrettyXML" value="true"/>
+  <parameter name="attachments.implementation" 
value="org.apache.axis.attachments.AttachmentsImpl"/>
+  <parameter name="sendXsiTypes" value="true"/>
   <parameter name="sendMultiRefs" value="true"/>
-  <parameter name="sendXsiTypes" value="true"/>
-  <parameter name="attachments.implementation" 
value="org.apache.axis.attachments.AttachmentsImpl"/>
   <parameter name="sendXMLDeclaration" value="true"/>
   <requestFlow>
    <handler type="java:org.apache.axis.handlers.JWSHandler">
@@ -29,10 +29,6 @@
   <parameter name="className" value="org.apache.axis.utils.Admin"/>
   <namespace>http://xml.apache.org/axis/wsdd/</namespace>
  </service>
- <service name="Version" provider="java:RPC">
-  <parameter name="allowedMethods" value="getVersion"/>
-  <parameter name="className" value="org.apache.axis.Version"/>
- </service>
  <service name="FlowsaMeasurementArchiveService" provider="java:MSG" 
style="message" use="literal">
   <requestFlow>
    <handler name="soapmonitor" 
type="java:org.apache.axis.handlers.SOAPMonitorHandler"/>
@@ -46,6 +42,10 @@
                        http://perfsonar.org/services/measurementArchive
                </namespace>
  </service>
+ <service name="Version" provider="java:RPC">
+  <parameter name="allowedMethods" value="getVersion"/>
+  <parameter name="className" value="org.apache.axis.Version"/>
+ </service>
  <transport name="http">
   <requestFlow>
    <handler type="URLMapper"/>

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/service.properties
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/service.properties 
2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/conf/service.properties 
2007-09-07 13:03:11 UTC (rev 2794)
@@ -10,21 +10,29 @@
 service.ma.message_types=SetupDataRequest
 
 # === Flowsa specific properties ===
-# exporters - list of source devices that generated our data.
 # service.ma.flowsa.exporters - a number indicating the amount of different 
sources
 # service.ma.flowsa.exporter1.hostname - 
 # service.ma.flowsa.exporter1.port - 
 # service.ma.flowsa.exporter1.description - 
-service.ma.flowsa.exporters=1
-service.ma.flowsa.exporter1.hostname=test
-service.ma.flowsa.exporter1.port=0
-service.ma.flowsa.exporter1.description=test 
+service.ma.flowsa.exporters=4
+service.ma.flowsa.exporter1.hostname=xsr01.asd001a.surf.net
+service.ma.flowsa.exporter1.port=29001
+service.ma.flowsa.exporter1.description=SURFnet6 Core Router Amsterdam1
+service.ma.flowsa.exporter2.hostname=xsr01.asd002a.surf.net
+service.ma.flowsa.exporter2.port=29003
+service.ma.flowsa.exporter2.description=SURFnet6 Core Router Amsterdam2
+service.ma.flowsa.exporter3.hostname=xsr03.asd001a.surf.net
+service.ma.flowsa.exporter3.port=29002
+service.ma.flowsa.exporter3.description=SURFnet6 Border Router Amsterdam1
+service.ma.flowsa.exporter4.hostname=xsr03.asd002a.surf.net
+service.ma.flowsa.exporter4.port=29004
+service.ma.flowsa.exporter4.description=SURFnet6 Border Router Amsterdam2
 
 # --- query properties ---
 # query.timeout - timeout/max execution time of a query (value is in seconds)
 # query.max-results - if more then <value> results are encountered stop 
processing
 service.ma.flowsa.query.timeout=10
-service.ma.flowsa.query.max-results=10000
+service.ma.flowsa.query.max-results=1000
 
 # --- nfdump properties ---
 # nfdump.source - location of nfcapd files

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaGetRequest.java
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaGetRequest.java
     2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaGetRequest.java
     2007-09-07 13:03:11 UTC (rev 2794)
@@ -1,10 +1,14 @@
 package org.perfsonar.service.measurementArchive.flowsa;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Set;
+import java.util.SortedSet;
+import java.util.TreeSet;
 
 import org.ggf.ns.nmwg.base.v2_0.Message;
 import org.ggf.ns.nmwg.base.v2_0.Metadata;
@@ -17,6 +21,7 @@
 import org.perfsonar.base.auxiliary.ComponentNames;
 import org.perfsonar.base.auxiliary.components.logger.LoggerComponent;
 import org.perfsonar.base.exceptions.PerfSONARException;
+import org.perfsonar.service.measurementArchive.flowsa.nfcapd.Exporter;
 import 
org.perfsonar.service.measurementArchive.flowsa.nfdump.AggegrationRule;
 import org.perfsonar.service.measurementArchive.flowsa.nfdump.Filter;
 import 
org.perfsonar.service.measurementArchive.flowsa.nfdump.filters.SimpleFilter;
@@ -35,8 +40,8 @@
                this.request = request;
                this.logger = FlowsaGetRequest.getLoggerComponent();
                processMetadata(request);
-       }
-       
+       }
+
        private void processMetadata(Message request) {
         for(Metadata metadata : request.getMetadataArray()) {
                processSubject(metadata.getSubject());
@@ -103,11 +108,12 @@
        }
        
        public Date getStartTime() {
+               // TODO implement time
                return null;
        }
 
        public Date getEndTime() {
-               // TODO Auto-generated method stub
+               // TODO implement time
                return null;
        }
 
@@ -141,4 +147,24 @@
        public Metadata[] getMetadata() {
                return request.getMetadataArray();
        }
+
+       public String getTopStatistic() {
+               // TODO Auto-generated method stub
+               return null;
+       }
+
+       public String getOrderBy() {
+               // TODO Auto-generated method stub
+               return null;
+       }
+
+       public boolean isSplittingProtocol() {
+               // TODO Auto-generated method stub
+               return false;
+       }
+
+       public int getTopN() {
+               // TODO Auto-generated method stub
+               return 0;
+       }
 }

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaMAServiceEngine.java
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaMAServiceEngine.java
        2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/FlowsaMAServiceEngine.java
        2007-09-07 13:03:11 UTC (rev 2794)
@@ -163,15 +163,7 @@
     protected RawFlowsResponse handleRawFlowRequest(FlowsaGetRequest 
request) throws InterruptedException, ExecutionException, TimeoutException, 
PerfSONARException {
        SortedSet<String> files = new TreeSet<String>();
        Set<String> directories = new TreeSet<String>();
-       for(String hostName : request.getHostNames()) {
-               Exporter exporter = nfcapd.getExporterByHostName(hostName);
-               if(exporter!=null) {
-                       files.addAll(Arrays.asList(exporter.getFileNames()));
-                       directories.add(exporter.getDirectory());
-               } else {
-                       logger.error("No exporter with hostname: "+hostName);
-               }
-       }
+       fillFilesAndDirectories(request, files, directories);
        
        if(directories.size() == 0) {
                throw new PerfSONARException("error.ma.query","Query didn't 
contain a subject known by this MA");
@@ -188,8 +180,7 @@
         logger.debug("FlowsaMAServiceEngine.handleRawFlowRequest: Executing 
query.");
         List<Flow> result = nfdump.execute(query);
         logger.debug("FlowsaMAServiceEngine.handleRawFlowRequest: Creating 
response.");
-        RawFlowsResponse response = new 
RawFlowsResponse(request.getMetadata(), result);
-        return response;
+        return new RawFlowsResponse(request.getMetadata(), result);
     }
     /**
      * handles a Statistics request. creates a query from 
@@ -203,17 +194,9 @@
      * @throws PerfSONARException 
      */
     protected Message handleStatisticsFlowRequest(FlowsaGetRequest request) 
throws InterruptedException, ExecutionException, TimeoutException, 
PerfSONARException {
-       SortedSet<String> files = new TreeSet<String>();
+               SortedSet<String> files = new TreeSet<String>();
        Set<String> directories = new TreeSet<String>();
-       for(String hostName : request.getHostNames()) {
-               Exporter exporter = nfcapd.getExporterByHostName(hostName);
-               if(exporter!=null) {
-                       files.addAll(Arrays.asList(exporter.getFileNames()));
-                       directories.add(exporter.getDirectory());
-               } else {
-                       logger.error("No exporter with hostname: "+hostName);
-               }
-       }
+       fillFilesAndDirectories(request, files, directories);
        
        if(directories.size() == 0) {
                throw new PerfSONARException("error.ma.query","Query didn't 
contain a subject known by this MA");
@@ -228,9 +211,9 @@
         logger.debug("FlowsaMAServiceEngine.handleRawFlowRequest: Executing 
query.");
         Statistics result = nfdump.execute(query);
         logger.debug("FlowsaMAServiceEngine.handleRawFlowRequest: Creating 
response.");
-        FlowStatisticsResponse response = new 
FlowStatisticsResponse(request.getMetadata(), result);
-        return response;
+        return new FlowStatisticsResponse(request.getMetadata(), result);
     }    
+    
     /**
      * handles a TopFlowRequest. creates a query from 
      * the request and executes it in nfdump, the result 
@@ -240,11 +223,33 @@
      * @throws InterruptedException
      * @throws ExecutionException
      * @throws TimeoutException
+     * @throws PerfSONARException 
      */
-    protected Message handleTopFlowRequest(FlowsaGetRequest 
flowsaGetRequest) throws InterruptedException, ExecutionException, 
TimeoutException {
-        TopQuery query = new TopQuery();
-        TopData result = nfdump.execute(query);
-        return new TopFlowsResponse(result);
+    protected Message handleTopFlowRequest(FlowsaGetRequest request) throws 
InterruptedException, ExecutionException, TimeoutException, 
PerfSONARException {
+       SortedSet<String> files = new TreeSet<String>();
+       Set<String> directories = new TreeSet<String>();
+       fillFilesAndDirectories(request, files, directories);
+       
+       if(directories.size() == 0) {
+               throw new PerfSONARException("error.ma.query","Query didn't 
contain a subject known by this MA");
+       }
+       
+               TopQuery query = new TopQuery(
+                       request.getStartTime(), 
+                       request.getEndTime(),
+                       request.getFilter(),
+                       request.getAggegrationRule(),
+                       directories,
+                       files,
+                       request.getTopStatistic(),
+                       request.getOrderBy(),
+                       request.isSplittingProtocol(),
+                       request.getTopN()
+        );
+        logger.debug("FlowsaMAServiceEngine.handleTopFlowRequest: Executing 
query.");
+        List<TopData> result = nfdump.execute(query);
+        logger.debug("FlowsaMAServiceEngine.handleTopFlowRequest: Creating 
response.");
+        return new TopFlowsResponse(request.getMetadata(), result);
     }
  
        /**
@@ -308,6 +313,17 @@
                
                return new NfcapdControll(exporters, startNfcapdProcesses);
        }
+       private void fillFilesAndDirectories(FlowsaGetRequest request, 
SortedSet<String> files, Set<String> directories) {
+               for(String hostName : request.getHostNames()) {
+                       Exporter exporter = 
nfcapd.getExporterByHostName(hostName);
+                       if(exporter!=null) {
+                               
files.addAll(Arrays.asList(exporter.getFileNames()));
+                               directories.add(exporter.getDirectory());
+                       } else {
+                               logger.error("No exporter with hostname: 
"+hostName);
+                       }
+               }
+       }
        /**
         * looks up the property from the specified source. returns the 
default value 
         * if the source didn't supply one.

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/TopFlowsResponse.java
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/TopFlowsResponse.java
     2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/TopFlowsResponse.java
     2007-09-07 13:03:11 UTC (rev 2794)
@@ -1,12 +1,15 @@
 package org.perfsonar.service.measurementArchive.flowsa;
 
-import org.ggf.ns.nmwg.base.v2_0.Message;
+import java.util.List;
+
+import org.ggf.ns.nmwg.base.v2_0.Metadata;
 import org.perfsonar.service.measurementArchive.flowsa.nfdump.TopData;
 
-public class TopFlowsResponse extends Message {
+public class TopFlowsResponse extends FlowsaGetResponse {
 
-    public TopFlowsResponse(TopData result) {
-        // TODO Auto-generated constructor stub
-    }
+       public TopFlowsResponse(Metadata[] metadata, List<TopData> result) {
+               super(metadata);
+               // TODO Auto-generated constructor stub
+       }
  
 }

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/NfdumpControll.java
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/NfdumpControll.java
        2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/NfdumpControll.java
        2007-09-07 13:03:11 UTC (rev 2794)
@@ -159,11 +159,11 @@
      * @throws ExecutionException when something went wrong executing the 
query-task
      * @throws TimeoutException when the query-task took too long
      */
-    public TopData execute(TopQuery query) throws InterruptedException, 
ExecutionException, TimeoutException {
+    public List<TopData> execute(TopQuery query) throws 
InterruptedException, ExecutionException, TimeoutException {
         List<String> commands = createCommandsFrom(query);
-        Callable<TopData> task = new 
NfdumpTask<TopData>(commands,readerFactory) {
+        Callable<List<TopData>> task = new 
NfdumpTask<List<TopData>>(commands,readerFactory) {
             @Override
-            public TopData call(NfdumpOutputReader reader) throws Exception {
+            public List<TopData> call(NfdumpOutputReader reader) throws 
Exception {
                // TODO implements task for Topdata
                 throw new UnsupportedOperationException("not 
implemented");//reader.readTopData();
             }

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopData.java
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopData.java
       2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopData.java
       2007-09-07 13:03:11 UTC (rev 2794)
@@ -4,11 +4,13 @@
  * A data object / java bean for Top data.
  * 
  * @author Michael Bischoff
- * @version $id$
+ * @version $Id$
  */
 public class TopData {
-    private String dateFirstSeen;
-    private String protocol;
+       private String dateFirstSeen;
+    private String duration;
+    private String topStatistic;
+       private String protocol;
     private String parameter;
     private String flows;
     private String packets;
@@ -16,5 +18,71 @@
     private String packetsPerSecond;
     private String bytesPerSecond;
     private String bytesPerPacket;
-    //TODO finish bean
+
+    public String getDateFirstSeen() {
+               return dateFirstSeen;
+       }
+       public void setDateFirstSeen(String dateFirstSeen) {
+               this.dateFirstSeen = dateFirstSeen;
+       }
+       public String getDuration() {
+               return duration;
+       }
+       public void setDuration(String duration) {
+               this.duration = duration;
+       }
+       public String getTopStatistic() {
+               return topStatistic;
+       }
+       public void setTopStatistic(String topStatistic) {
+               this.topStatistic = topStatistic;
+       }
+       public String getProtocol() {
+               return protocol;
+       }
+       public void setProtocol(String protocol) {
+               this.protocol = protocol;
+       }
+       public String getParameter() {
+               return parameter;
+       }
+       public void setParameter(String parameter) {
+               this.parameter = parameter;
+       }
+       public String getFlows() {
+               return flows;
+       }
+       public void setFlows(String flows) {
+               this.flows = flows;
+       }
+       public String getPackets() {
+               return packets;
+       }
+       public void setPackets(String packets) {
+               this.packets = packets;
+       }
+       public String getBytes() {
+               return bytes;
+       }
+       public void setBytes(String bytes) {
+               this.bytes = bytes;
+       }
+       public String getPacketsPerSecond() {
+               return packetsPerSecond;
+       }
+       public void setPacketsPerSecond(String packetsPerSecond) {
+               this.packetsPerSecond = packetsPerSecond;
+       }
+       public String getBytesPerSecond() {
+               return bytesPerSecond;
+       }
+       public void setBytesPerSecond(String bytesPerSecond) {
+               this.bytesPerSecond = bytesPerSecond;
+       }
+       public String getBytesPerPacket() {
+               return bytesPerPacket;
+       }
+       public void setBytesPerPacket(String bytesPerPacket) {
+               this.bytesPerPacket = bytesPerPacket;
+       }
 }

Modified: 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopQuery.java
===================================================================
--- 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopQuery.java
      2007-09-07 12:57:35 UTC (rev 2793)
+++ 
branches/new-structure/trunk/surfnet_java-flowsa-ma/src/main/java/org/perfsonar/service/measurementArchive/flowsa/nfdump/TopQuery.java
      2007-09-07 13:03:11 UTC (rev 2794)
@@ -1,5 +1,9 @@
 package org.perfsonar.service.measurementArchive.flowsa.nfdump;
 
+import java.util.Date;
+import java.util.Set;
+import java.util.SortedSet;
+
 /**
  * A implementation of 
{@link
 NfdumpQuery} for Top data
  * 
@@ -8,5 +12,70 @@
  *
  */
 public class TopQuery extends NfdumpQuery {
-       // TODO implement query
+       private Filter filter;
+       private AggegrationRule aggegrationRule;
+       private String topStatistic;
+       private String orderBy;
+       private boolean splitProtocol; 
+       private int topN;
+       
+       public TopQuery(Date startTime, Date endTime, Filter filter,
+            AggegrationRule aggegrationRule, Set<String> 
directories,SortedSet<String> files,
+            String topStatistic, String orderBy, boolean splitProtocol, int 
topN) {
+               super(startTime, endTime, directories, files);
+        this.filter = filter;
+        this.aggegrationRule = aggegrationRule;
+        this.topStatistic = topStatistic;
+        this.orderBy = orderBy;
+        this.splitProtocol = splitProtocol;
+        this.topN = topN;
+       }
+
+       public Filter getFilter() {
+               return filter;
+       }
+
+       public void setFilter(Filter filter) {
+               this.filter = filter;
+       }
+
+       public AggegrationRule getAggegrationRule() {
+               return aggegrationRule;
+       }
+
+       public void setAggegrationRule(AggegrationRule aggegrationRule) {
+               this.aggegrationRule = aggegrationRule;
+       }
+
+       public String getTopStatistic() {
+               return topStatistic;
+       }
+
+       public void setTopStatistic(String topStatistic) {
+               this.topStatistic = topStatistic;
+       }
+
+       public String getOrderBy() {
+               return orderBy;
+       }
+
+       public void setOrderBy(String orderBy) {
+               this.orderBy = orderBy;
+       }
+
+       public boolean isSplitProtocol() {
+               return splitProtocol;
+       }
+
+       public void setSplitProtocol(boolean splitProtocol) {
+               this.splitProtocol = splitProtocol;
+       }
+
+       public int getTopN() {
+               return topN;
+       }
+
+       public void setTopN(int topN) {
+               this.topN = topN;
+       }
 }