| 1 | package weka.clusterers.forMetisMQI; | 
|---|
| 2 |  | 
|---|
| 3 | import java.io.File; | 
|---|
| 4 | import java.io.FileOutputStream; | 
|---|
| 5 | import java.io.IOException; | 
|---|
| 6 | import java.util.HashSet; | 
|---|
| 7 | import java.util.Iterator; | 
|---|
| 8 | import java.util.Set; | 
|---|
| 9 | import java.util.Stack; | 
|---|
| 10 |  | 
|---|
| 11 | import org.jdom.Document; | 
|---|
| 12 | import org.jdom.Element; | 
|---|
| 13 | import org.jdom.output.Format; | 
|---|
| 14 | import org.jdom.output.XMLOutputter; | 
|---|
| 15 |  | 
|---|
| 16 | import weka.clusterers.forMetisMQI.graph.Bisection; | 
|---|
| 17 | import weka.clusterers.forMetisMQI.graph.Node; | 
|---|
| 18 | import weka.clusterers.forMetisMQI.graph.Subgraph; | 
|---|
| 19 | import weka.clusterers.forMetisMQI.graph.UndirectedGraph; | 
|---|
| 20 | import weka.clusterers.forMetisMQI.util.CoarserGraphElement; | 
|---|
| 21 | import weka.clusterers.forMetisMQI.util.Configuration; | 
|---|
| 22 | import weka.clusterers.forMetisMQI.util.GraphsFrame; | 
|---|
| 23 | import weka.clusterers.forMetisMQI.util.Random; | 
|---|
| 24 | import weka.clusterers.forMetisMQI.util.Util; | 
|---|
| 25 |  | 
|---|
| 26 | public class GraphAlgorithms { | 
|---|
| 27 |  | 
|---|
| 28 |  | 
|---|
| 29 | static public Bisection KLRefinement(Bisection b) { | 
|---|
| 30 | int remainingNumberOfSwap = 50; | 
|---|
| 31 | Bisection partition = b; | 
|---|
| 32 | Bisection result = partition; | 
|---|
| 33 | int bestEdgeCut = partition.edgeCut(); | 
|---|
| 34 | Node u = partition.getCandidate(); | 
|---|
| 35 | while (u != null && remainingNumberOfSwap > 0) { | 
|---|
| 36 | partition.swap(u); | 
|---|
| 37 | if (partition.edgeCut() <= bestEdgeCut) { | 
|---|
| 38 | bestEdgeCut = partition.edgeCut(); | 
|---|
| 39 | result = partition.clone(); | 
|---|
| 40 | remainingNumberOfSwap = 50; | 
|---|
| 41 | } else | 
|---|
| 42 | remainingNumberOfSwap--; | 
|---|
| 43 | u = partition.getCandidate(); | 
|---|
| 44 | } | 
|---|
| 45 | return result; | 
|---|
| 46 | } | 
|---|
| 47 |  | 
|---|
| 48 |  | 
|---|
| 49 | /** | 
|---|
| 50 | * Given an undirected graph, performs the Kernighan-Li algorithm to find a bisection and | 
|---|
| 51 | * then returns it. | 
|---|
| 52 | * @param g | 
|---|
| 53 | * @return | 
|---|
| 54 | */ | 
|---|
| 55 | static public Bisection KL(UndirectedGraph g) { | 
|---|
| 56 | int remainingNumberOfSwap = 50; | 
|---|
| 57 | Bisection partition = new Bisection(g); | 
|---|
| 58 | Bisection result = partition; | 
|---|
| 59 | int bestEdgeCut = partition.edgeCut(); | 
|---|
| 60 | Node u = partition.getCandidate(); | 
|---|
| 61 | while (u != null && remainingNumberOfSwap > 0) { | 
|---|
| 62 | partition.swap(u); | 
|---|
| 63 | if (partition.edgeCut() <= bestEdgeCut) { | 
|---|
| 64 | bestEdgeCut = partition.edgeCut(); | 
|---|
| 65 | result = partition.clone(); | 
|---|
| 66 | remainingNumberOfSwap = 50; | 
|---|
| 67 | } else | 
|---|
| 68 | remainingNumberOfSwap--; | 
|---|
| 69 | u = partition.getCandidate(); | 
|---|
| 70 | } | 
|---|
| 71 | return result; | 
|---|
| 72 | } | 
|---|
| 73 |  | 
|---|
| 74 | static public Bisection metis(UndirectedGraph g, int sizeFinerGraph) { | 
|---|
| 75 | Coarse.setFinerSize(sizeFinerGraph); | 
|---|
| 76 | Stack<CoarserGraphElement> stack = Coarse.coarse(g); | 
|---|
| 77 | Bisection partition = null; | 
|---|
| 78 | if (stack.size() > 0) { | 
|---|
| 79 | partition = KL(stack.peek().getContracted()); | 
|---|
| 80 | if(Configuration.instance().getVerboseLevel() > 1) { | 
|---|
| 81 | GraphsFrame.instance().addPanel(Util.panelContractedGraph(stack.peek())); | 
|---|
| 82 | GraphsFrame.instance().addPanel(Util.panelContractedGraph(stack.peek(),partition.getSmallerSubgraph().createInducedSubgraph().getVertices())); | 
|---|
| 83 | } | 
|---|
| 84 | partition = Uncoarse.uncoarse(stack, partition); | 
|---|
| 85 | } | 
|---|
| 86 | return partition; | 
|---|
| 87 | } | 
|---|
| 88 |  | 
|---|
| 89 | /** | 
|---|
| 90 | * Given an UndirectedGraph, runs metis+mqi for <code>numberOfCluster</code> times and | 
|---|
| 91 | * returns a set of clusters. With the third parameter you can control the maximum size of the finer | 
|---|
| 92 | * graph during the coarsening phase. | 
|---|
| 93 | * @param g | 
|---|
| 94 | * @param numberOfCluster | 
|---|
| 95 | * @param sizeFinerGraph | 
|---|
| 96 | */ | 
|---|
| 97 | static public Set<Set<Node>> metisMqi(UndirectedGraph g) { | 
|---|
| 98 | int numberOfCluster = Configuration.instance().getNumberOfClusters(); | 
|---|
| 99 | boolean randomBisection = Configuration.instance().isRandomBisection(); | 
|---|
| 100 | int sizeFinerGraph = Configuration.instance().getSizeFinerGraph(); | 
|---|
| 101 | int verboseLevel = Configuration.instance().getVerboseLevel(); | 
|---|
| 102 | GraphsFrame gf = GraphsFrame.instance(); | 
|---|
| 103 |  | 
|---|
| 104 | Element rootXML = new Element("run"); | 
|---|
| 105 | Document logXML = new Document(rootXML); | 
|---|
| 106 | rootXML.setAttribute("seed", Long.toString(Random.instance().getSeed())); | 
|---|
| 107 | Element graphXML = new Element("graph"); | 
|---|
| 108 | graphXML.addContent(new Element("vertex").setText(Integer.toString(g.getVertexCount()))); | 
|---|
| 109 | graphXML.addContent(new Element("edge").setText(Integer.toString(g.getEdgeCount()))); | 
|---|
| 110 | rootXML.addContent(graphXML); | 
|---|
| 111 | Element clustersXML = new Element("clusters"); | 
|---|
| 112 | rootXML.addContent(clustersXML); | 
|---|
| 113 |  | 
|---|
| 114 | System.out.println("Seed: " + Random.instance().getSeed()); | 
|---|
| 115 | System.out.println("Vertex count: " + g.getVertexCount()); | 
|---|
| 116 | System.out.println("Edges count: " + g.getEdgeCount()); | 
|---|
| 117 | Set<Set<Node>> clusters = new HashSet<Set<Node>>(); | 
|---|
| 118 | UndirectedGraph gclone = g.clone(); | 
|---|
| 119 |  | 
|---|
| 120 | for (int i = 0; i < numberOfCluster; i++) { | 
|---|
| 121 | Bisection bisection = null; | 
|---|
| 122 | if(verboseLevel > 1) | 
|---|
| 123 | gf.addPanel(Util.panelGraph(g.clone())); | 
|---|
| 124 | if(!randomBisection) | 
|---|
| 125 | bisection = metis(g,sizeFinerGraph); | 
|---|
| 126 | else | 
|---|
| 127 | bisection = new Bisection(g); | 
|---|
| 128 |  | 
|---|
| 129 | if(verboseLevel > 1) | 
|---|
| 130 | gf.addPanel(Util.panelCluster(g.clone(),bisection.getSmallerSubgraph().createInducedSubgraph().getVertices())); | 
|---|
| 131 |  | 
|---|
| 132 | System.out.print("Initial partition: "); | 
|---|
| 133 | System.out.print("V1: " + bisection.getSubgraph().getVertexCount()); | 
|---|
| 134 | System.out.print(" V2: " + bisection.getComplement().getVertexCount()); | 
|---|
| 135 | System.out.println(" EC: " + bisection.edgeCut() * 0.5); | 
|---|
| 136 | System.out.println("Conductance: " + | 
|---|
| 137 | ((double)bisection.edgeCut() / 2) / Math.min(bisection.getSubgraph().totalDegree(),bisection.getComplement().totalDegree())); | 
|---|
| 138 | Set<Node> cluster = MQI.mqi(bisection,true); | 
|---|
| 139 |  | 
|---|
| 140 | UndirectedGraph clusterGraph = new Subgraph(gclone,cluster).createInducedSubgraph(); | 
|---|
| 141 |  | 
|---|
| 142 | //                      System.out.println(cluster); | 
|---|
| 143 | Bisection mqiBisection = new Bisection(new Subgraph(g,cluster)); | 
|---|
| 144 | System.out.println("Refined partition (MQI)"); | 
|---|
| 145 | double newConductance = ((double)mqiBisection.edgeCut() / 2) / Math.min(mqiBisection.getSubgraph().totalDegree(),mqiBisection.getComplement().totalDegree()); | 
|---|
| 146 | System.out.print("Cluster "+ i + ":  V=" + clusterGraph.getVertexCount() + ", E=" + clusterGraph.getEdgeCount()+", "); | 
|---|
| 147 | System.out.println("Cond: " + newConductance); | 
|---|
| 148 |  | 
|---|
| 149 |  | 
|---|
| 150 | mqiBisection = new Bisection(new Subgraph(gclone,cluster)); | 
|---|
| 151 | newConductance = ((double)mqiBisection.edgeCut() / 2) / Math.min(mqiBisection.getSubgraph().totalDegree(),mqiBisection.getComplement().totalDegree()); | 
|---|
| 152 | System.out.println("Cluster conductance: " + newConductance); | 
|---|
| 153 |  | 
|---|
| 154 |  | 
|---|
| 155 | Element clusterXML = new Element("cluster"); | 
|---|
| 156 | clusterXML.setAttribute("id", Integer.toString(i)); | 
|---|
| 157 | clusterXML.addContent(new Element("vertex").setText(Integer.toString(clusterGraph.getVertexCount()))); | 
|---|
| 158 | clusterXML.addContent(new Element("edge").setText(Integer.toString(clusterGraph.getEdgeCount()))); | 
|---|
| 159 | clusterXML.addContent(new Element("conductance").setText(Double.toString(newConductance))); | 
|---|
| 160 | clustersXML.addContent(clusterXML); | 
|---|
| 161 |  | 
|---|
| 162 | clusters.add(cluster); | 
|---|
| 163 |  | 
|---|
| 164 | System.out.println(); | 
|---|
| 165 | Iterator<Node> clustersNode = cluster.iterator(); | 
|---|
| 166 | while(clustersNode.hasNext()){ | 
|---|
| 167 | g.removeVertex(clustersNode.next()); | 
|---|
| 168 | } | 
|---|
| 169 | } | 
|---|
| 170 |  | 
|---|
| 171 |  | 
|---|
| 172 | XMLOutputter xmlOutputter = new XMLOutputter(); | 
|---|
| 173 | xmlOutputter.setFormat(Format.getPrettyFormat()); | 
|---|
| 174 | try { | 
|---|
| 175 | xmlOutputter.output(logXML, new FileOutputStream(new File(Configuration.instance().getOutputFile()))); | 
|---|
| 176 | } catch (IOException e) { | 
|---|
| 177 | e.printStackTrace(); | 
|---|
| 178 | } | 
|---|
| 179 |  | 
|---|
| 180 | if(verboseLevel > 0) { | 
|---|
| 181 | gf.addPanel(Util.panelClusters(gclone, clusters)); | 
|---|
| 182 | gf.setVisible(true); | 
|---|
| 183 | } | 
|---|
| 184 | return clusters; | 
|---|
| 185 | } | 
|---|
| 186 |  | 
|---|
| 187 | } | 
|---|