Package edu.cmu.graphchi.datablocks

Examples of edu.cmu.graphchi.datablocks.FloatPairConverter

135
136
137
138
139
140
141
142
143
        this.graphName = graphName;
        engine = new GraphChiEngine<FloatPair, Float>(graphName, numShards);
        engine.setEnableScheduler(false);
        engine.setSkipZeroDegreeVertices(true);
        engine.setEdataConverter(new FloatConverter());
        engine.setVertexDataConverter(new FloatPairConverter());
        engine.setMaxWindow(20000000);
        engine.run(this, 8);
    }
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
        engine.run(this, 8);
    }

    private void outputResults(String graphName) throws IOException {

        VertexAggregator.foreach(engine.numVertices(), graphName, new FloatPairConverter(), new ForeachCallback<FloatPair>() {
            @Override
            public void callback(int vertexId, FloatPair vertexValue) {
                if (vertexValue.first > 0) {
                    System.out.println(engine.getVertexIdTranslate().backward(vertexId)  + "\t" + vertexValue.first);
                }
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
        run(getGraphName(), getNumShards());
        results = new ArrayList<IdFloat>(100000);

        // Collect results - into memory ... This may consume a lot of memory.
        // It would be better to have an iterator for the vertex data.
        VertexAggregator.foreach(engine.numVertices(), graphName, new FloatPairConverter(), new ForeachCallback<FloatPair>() {
            @Override
            public void callback(int vertexId, FloatPair vertexValue) {
                if (vertexValue.first > 0) {
                    results.add(new IdFloat(engine.getVertexIdTranslate().backward(vertexId), vertexValue.first));
                }
View Full Code Here
222
223
224
225
226
227
228
        }, new EdgeProcessor<Float>() {
            @Override
            public Float receiveEdge(int from, int to, String token) {
                return Float.parseFloat(token);
            }
        }, new FloatPairConverter(), new FloatConverter());
    }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
            try {
                logger.info("NORMALIZING - LEFT");


                leftNorm = (float) Math.sqrt(leftSideSqrSum);
                VertexTransformer.transform((int) ctx.getNumVertices(), graphName, new FloatPairConverter(), new VertexTransformCallBack<FloatPair>() {
                    public FloatPair map(int vertexId, FloatPair value) {
                        return new FloatPair(value.first/leftNorm, value.second);
                    }
                });
View Full Code Here
171
172
173
174
175
176
177
178
179
        this.graphName = graphName;
        engine = new GraphChiEngine<FloatPair, Float>(graphName, numShards);
        engine.setEnableScheduler(false);
        engine.setSkipZeroDegreeVertices(true);
        engine.setEdataConverter(new FloatConverter());
        engine.setVertexDataConverter(new FloatPairConverter());
        engine.setMaxWindow(20000000);
        engine.run(this, 8);
    }
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
        engine.run(this, 8);
    }

    private void outputResults(String graphName) throws IOException {

        VertexAggregator.foreach(engine.numVertices(), graphName, new FloatPairConverter(), new ForeachCallback<FloatPair>() {
            public void callback(int vertexId, FloatPair vertexValue) {
                if (vertexValue.first > 0) {
                    System.out.println(engine.getVertexIdTranslate().backward(vertexId)  + "\t" + vertexValue.first);
                }
            }
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
        run(getGraphName(), getNumShards());
        results = new ArrayList<IdFloat>(100000);

        // Collect results - into memory ... This may consume a lot of memory.
        // It would be better to have an iterator for the vertex data.
        VertexAggregator.foreach(engine.numVertices(), graphName, new FloatPairConverter(), new ForeachCallback<FloatPair>() {
            public void callback(int vertexId, FloatPair vertexValue) {
                if (vertexValue.first > 0) {
                    results.add(new IdFloat(engine.getVertexIdTranslate().backward(vertexId), vertexValue.first));
                }
            }
View Full Code Here
254
255
256
257
258
259
260
            }
        }, new EdgeProcessor<Float>() {
            public Float receiveEdge(int from, int to, String token) {
                return Float.parseFloat(token);
            }
        }, new FloatPairConverter(), new FloatConverter());
    }
View Full Code Here
83
84
85
86
87
88
89
            }
        }, new EdgeProcessor<FloatPair>() {
            public FloatPair receiveEdge(int from, int to, String token) {
                return new FloatPair(Float.parseFloat(token), 0.f);
            }
        }, new FloatConverter(), new FloatPairConverter());
    }
View Full Code Here
TOP

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

  • com.twitter.pers.bipartite.HITSSmallMem
  • com.twitter.pers.bipartite.SALSASmallMem
  • edu.cmu.graphchi.apps.pig.PigWeightedPagerank
  • edu.cmu.graphchi.apps.WeightedPagerank
    • 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.