Package com.intel.hadoop.graphbuilder.graph

Examples of com.intel.hadoop.graphbuilder.graph.Edge.source()

81
82
83
84
85
86
87
88
89
90
91
      if (graphparser.isEdgeData(line)) {
        Edge e = graphparser.parseEdge(line, vidparser, edataparser);
        if (reduceEndPoint == EdgeTransformMR.SOURCE) {
          val.init(e.target(), e.EdgeData());
          out.collect((VidType) e.source(), val);
        } else {
          val.init(e.source(), e.EdgeData());
          out.collect((VidType) e.target(), val);
        }
      } else {
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
        Edge e = graphparser.parseEdge(line, vidparser, edataparser);
        if (reduceEndPoint == EdgeTransformMR.SOURCE) {
          val.init(e.target(), e.EdgeData());
          out.collect((VidType) e.source(), val);
        } else {
          val.init(e.source(), e.EdgeData());
          out.collect((VidType) e.target(), val);
        }
      } else {
        LOG.error("Skip line: " + line);
      }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
    @Override
    public void map(LongWritable key, Text val,
        OutputCollector<IntWritable, Text> out, Reporter arg3)
        throws IOException {
      Edge e = graphparser.parseEdge(val.toString(), vidparser, edataparser);
      int hash = e.source().hashCode() % numChunks;
      if (hash < 0)
        hash += numChunks;
      out.collect(new IntWritable(hash), val);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.