Package edu.cmu.graphchi.datablocks

Examples of edu.cmu.graphchi.datablocks.FloatConverter

28
29
30
31
32
33
34
35
36
37
38
     * @return
     * @throws IOException
     */
    public static TreeSet<IdFloat> topListFloat(String baseFilename, int numVertices, final int topN) throws IOException{
        final TreeSet<IdFloat> topList = new TreeSet<IdFloat>(new IdFloat.Comparator());
        VertexAggregator.foreach(numVertices, baseFilename, new FloatConverter(), new ForeachCallback<Float>()  {
            IdFloat least;
            public void callback(int vertexId, Float vertexValue) {
                if (topList.size() < topN) {
                    topList.add(new IdFloat(vertexId, vertexValue));
                    least = topList.last();
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
        logger.info("Loading ranks...");
        long st = System.currentTimeMillis();
        int numVertices = ChiFilenames.numVertices(baseFilename, numShards);
        ranks = new float[numVertices];
        Iterator<VertexIdValue<Float>> iter = VertexAggregator.vertexIterator(numVertices, baseFilename,
                new FloatConverter(), VertexIdTranslate.identity());
        while(iter.hasNext()) {
            VertexIdValue<Float> idVal = iter.next();
            ranks[idVal.getVertexId()] = idVal.getValue();
        }
        logger.info("Loaded ranks to memory in " + (System.currentTimeMillis() - st) + " ms");
View Full Code Here
17
18
19
20
21
22
23
24
25
26
27
    public void testVertexValue() {
        DataBlockManager blockMgr = new DataBlockManager();

        int blockId = blockMgr.allocateBlock(1024* 1024);

        FloatConverter floatConv = new FloatConverter();

        ChiVertex.edgeValueConverter = floatConv;
        ChiVertex.vertexValueConverter = floatConv;
        ChiVertex.blockManager = blockMgr;
        ChiVertex<Float, Float> vertex = new ChiVertex<Float, Float>(1, new VertexDegree(0, 0));
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
    public void testInEdges() {
        DataBlockManager blockMgr = new DataBlockManager();

        int blockId = blockMgr.allocateBlock(1024 * 1024);

        FloatConverter floatConv = new FloatConverter();
        int nInedges = 1000;

        ChiVertex.edgeValueConverter = floatConv;
        ChiVertex.vertexValueConverter = floatConv;
        ChiVertex.blockManager = blockMgr;
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
    public void testOutEdges() {
        DataBlockManager blockMgr = new DataBlockManager();

        int blockId = blockMgr.allocateBlock(1024 * 1024);

        FloatConverter floatConv = new FloatConverter();
        int nOutedges = 5559;

        ChiVertex.edgeValueConverter = floatConv;
        ChiVertex.vertexValueConverter = floatConv;
        ChiVertex.blockManager = blockMgr;
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
    public void testSortWithValues() {
        long[] ids = new long[] {7,4,5,8,2,9};
        float[] valuef = new float[] {7.0f, 4.0f, 5.0f, 8.0f, 2.0f, 9.0f};
        byte[] valuedat = new byte[4 * valuef.length];

        FloatConverter floatConv = new FloatConverter();
        for(int i=0; i < valuef.length; i++) {
            byte[] tmp = new byte[4];
            floatConv.setValue(tmp, valuef[i]);
            System.arraycopy(tmp, 0, valuedat, i * 4, 4);
        }

        FastSharder.sortWithValues(ids, valuedat, 4);

        for(int i=0; i < valuef.length; i++) {
             byte[] tmp = new byte[4];
             System.arraycopy(valuedat, i * 4, tmp, 0, 4);
             float f = floatConv.getValue(tmp);
             assertEquals(ids[i] * 1.0f, f);
             assertTrue(i == 0 || ids[i] > ids[i-1]);
        }
    }
View Full Code Here
TOP

Related Classes of edu.cmu.graphchi.datablocks.FloatConverter

  • com.twitter.pers.bipartite.HITSSmallMem
  • com.twitter.pers.bipartite.SALSASmallMem
  • edu.cmu.graphchi.apps.ALSMatrixFactorization
  • edu.cmu.graphchi.apps.Pagerank
  • edu.cmu.graphchi.apps.pig.PigALSMatrixFactorization
  • edu.cmu.graphchi.apps.pig.PigPagerank
  • edu.cmu.graphchi.apps.pig.PigWeightedPagerank
  • edu.cmu.graphchi.apps.recommendations.MovieRecommender
  • edu.cmu.graphchi.apps.WeightedPagerank
  • edu.cmu.graphchi.preprocessing.TestIdPacking
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.