Блог

В Gelly я пытаюсь создать специальное ребро, называемое временным ребром, чтобы упростить это, я создал класс с именем Temporaledgev3:

 public class TemporalEdgev3<K, V> extends Edge<K, Tuple3<V,Integer,Integer>> {

/*
Creates new temporaledge with only null values
 */
public TemporalEdgev3() {}

/*
* Constructor to make a temporal edge version 2, has 5 input values but makes a
* typle 3 which is compatible with Gelly
* */
public TemporalEdgev3(K src, K trg, V val, Integer start, Integer end) {
    this.f0 = src;
    this.f1 = trg;
    this.f2 = new Tuple3<V,Integer,Integer>(val,start,end);
}
  

Теперь я пытаюсь добавить эти ребра в набор данных Flink, чтобы его можно было использовать на графике, но, похоже, я не могу понять, как это сделать. Однако, когда я использую класс Edge с теми же конструкторами, он работает.

Вот код, последняя строка выдает ошибку

 // a temporal set created with Flink, now we need to make it into a temporal set into gelly
DataSet<Tuple5<Long,Long, Double,Integer, Integer>> temporalset = env.readCsvFile("./datasets/testdata")
        .fieldDelimiter(",")  // node IDs are separated by spaces
        .ignoreComments("%")  // comments start with "%"
        .types(Long.class,Long.class,Double.class,Integer.class,Integer.class); // read the node IDs as Longs

DataSet<TemporalEdgev3<Long,Double>> edgeset3 = temporalset.map(new MapFunction<Tuple5<Long, Long, Double, Integer, Integer>, TemporalEdgev3<Long, Double>>() {
    @Override
    public TemporalEdgev3<Long, Double> map(Tuple5<Long, Long, Double, Integer, Integer> value) throws Exception {

        return new TemporalEdgev3<Long, Double>(value.f0,value.f1,value.f2,value.f3,value.f4);
    }
});

DataSet<Edge<Long,Tuple3<Double,Integer,Integer>>> edgeset4 = temporalset.map(new MapFunction<Tuple5<Long, Long, Double, Integer, Integer>, Edge<Long, Tuple3<Double, Integer, Integer>>>() {
    @Override
    public Edge<Long, Tuple3<Double, Integer, Integer>> map(Tuple5<Long, Long, Double, Integer, Integer> value) throws Exception {
        return new Edge<Long, Tuple3<Double, Integer, Integer>>(value.f0,value.f1, new Tuple3<Double, Integer, Integer>(value.f2,value.f3,value.f4));
    }
});

Graph<Long, NullValue, Tuple3<Double,Integer,Integer>> temporalgraph = Graph.fromDataSet(edgeset4,env);

Graph<Long,NullValue, Tuple3<Double,Integer,Integer>> temporalgraph2 = Graph.fromDataSet(edgeset3,env);
  

Ошибка:
Неправильный 1-й тип аргумента. Найдено: ‘org.apache.flink.api.java.DataSet>’, требуется: ‘org.apache.flink.api.java.DataSet>’ меньше…

 fromDataSet
(org.apache.flink.api.java.DataSet<org.apache.flink.graph.Edge<K,EV>>,
ExecutionEnvironment)
in Graph cannot be applied
to
(org.apache.flink.api.java.DataSet<flink.gelly.school.TemporalEdgev3<java.lang.Long,java.lang.Double>>,
ExecutionEnvironment)
 
 reason: no instance(s) of type variable(s) EV, K exist so that TemporalEdgev3<Long, Double> conforms to Edge<K, EV>
  

Может быть, я просто не понимаю, как использовать общие типы

Вам не нужно расширять Edge тип. Вы можете просто использовать a Tuple3 или пользовательский тип значения edge.

Ваше объявление graph Graph<Long, NullValue, Tuple3<Double,Integer,Integer>> ожидает a DataSet<Edge<Long, Tuple3<Double,Integer,Integer>>> в качестве входных данных для ребер. Вот почему ваше temporalgraph2 объявление работает, но temporalgraph не работает.