java流在两个不同的过滤器后生成映射

Question

它应该会返回一张地图。这个映射的键应该是字符串“transaction”和“transition”，映射的值应该是SNP对象的列表。“过渡”指的是两个阶段之间的变化

我应该如何制作这两个过滤器？

public class StreamAssignment {

    private static final List<Snp> SNP_COLLECTION = Snp.getSnpCollection();
    private static final String[] SNP_DATA = new String[14];

    static {
        SNP_DATA[0] = "100273;A;G;0.0123";
        SNP_DATA[1] = "100275;A;C;0.00323";
        SNP_DATA[2] = "117807;T;G;0.1915";
        SNP_DATA[3] = "162889;C;G;8.72E-4";
        SNP_DATA[4] = "190199;T;C;0.1019";
        SNP_DATA[5] = "277614;A;G;0.0168";
        SNP_DATA[6] = "372778;C;A;4.24E-5";
        SNP_DATA[7] = "417752;A;G;1.8474E-10";
        SNP_DATA[8] = "478808;A;G;1.535689E-8";
        SNP_DATA[9] = "556920;T;G;0.1097";
        SNP_DATA[10] = "676255;G;C;0.0016672";
        SNP_DATA[11] = "667280;A;G;0.00287";
        SNP_DATA[12] = "719876;C;A;0.006649";
        SNP_DATA[13] = "828771;A;C;0.097706";
    }

    public static Map<String, List<Snp>> getTransversionsTransitions() {
        Map<String, List<Snp>> result;
        result = SNP_COLLECTION.stream().filter();


        return null;
    }
}

SNP类

package nl.bioinf.appdesign.d_streams_lambdas;

import java.util.ArrayList;
import java.util.List;

public class Snp {
    private final long position;
    private final char reference;
    private final char alternative;
    private final double minorAlleleFrequency;

    public Snp(long position, char reference, char alternative, double minorAlleleFrequency) {
        this.position = position;
        this.reference = reference;
        this.alternative = alternative;
        this.minorAlleleFrequency = minorAlleleFrequency;
    }

    public long getPosition() {
        return position;
    }

    public char getReference() {
        return reference;
    }

    public char getAlternative() {
        return alternative;
    }

    public double getMinorAlleleFrequency() {
        return minorAlleleFrequency;
    }

    @Override
    public String toString() {
        return "Snp{" +
                "position=" + position +
                ", reference=" + reference +
                ", alternative=" + alternative +
                ", minorAlleleFrequency=" + minorAlleleFrequency +
                '}';
    }

    public final static List<Snp> getSnpCollection() {
        List<Snp> snps = new ArrayList<>();
        snps.add(new Snp(100273, 'A', 'G', 0.0123));
        snps.add(new Snp(100275, 'A', 'C', 0.00323));
        snps.add(new Snp(117807, 'T', 'G', 0.1915));
        snps.add(new Snp(162889, 'C', 'G', 0.000872));
        snps.add(new Snp(190199, 'T', 'C', 0.1019));
        snps.add(new Snp(277614, 'A', 'G', 0.0168));
        snps.add(new Snp(372778, 'C', 'A', 0.0000424));
        snps.add(new Snp(417752, 'A', 'G', 1.8474e-10));
        snps.add(new Snp(478808, 'A', 'G', 1.535689e-8));
        snps.add(new Snp(556920, 'T', 'G', 0.1097));
        snps.add(new Snp(676255, 'G', 'C', 1.6672e-3));
        snps.add(new Snp(667280, 'A', 'G', 0.00287));
        snps.add(new Snp(719876, 'C', 'A', 0.006649));
        snps.add(new Snp(828771, 'A', 'C', 0.097706));
        return snps;
    }
}

Answer 1

你可以在你的两个角色reference

import java.util.function.BiFunction;

....


public static Map<String, List<Snp>> getTransversionsTransitions() {
    BiFunction<Character,Character,String> func =
            (a,b) -> (""+a+b).matches("AG|GA|CT|TC") ? "Transitions":"Transversions";
    return SNP_COLLECTION.stream()
            .collect(Collectors.groupingBy(snp -> func.apply(snp.getReference(),snp.getAlternative())));
}

Answer 2

在重新检查您的代码并阅读您的解释后，我假设Snp类的参考和替代属性将作为示例

这就是我想出的代码。如果我误解了什么，请在评论中告诉我。

public static Map<String, List<Snp>> getTransversionsTransitions() {
    Map<String, List<Snp>> result = new HashMap<>();

    result.put("Transitions", SNP_COLLECTION.stream()
            .filter(snp -> (snp.getReference() == 'A' && snp.getAlternative() == 'G') || (snp.getReference() == 'C' && snp.getAlternative() == 'T'))
            .collect(Collectors.toList()));

    result.put("Transversions", SNP_COLLECTION.stream()
            .filter(snp -> (snp.getReference() == 'A' && snp.getAlternative() == 'C') || (snp.getReference() == 'G' && snp.getAlternative() == 'T')|| (snp.getReference() == 'C' && snp.getAlternative() == 'G'))
            .collect(Collectors.toList()));

    return result;
}

这只是检查输出是否符合预期的主要步骤

public static void main(String[] args) {
    Map<String, List<Snp>> result = getTransversionsTransitions();
    for(String key: result.keySet()){
        System.out.printf("%s => %s%n", key, result.get(key));
    }
}

Answer 3

因为您的Snp类不包含关于它是转换还是转换的信息，所以您需要一个包装类。我将省略它，但它只需要一个String-type属性、Snp-Snp属性和一个工厂方法（我们称之为parse）。

result = SNP_COLLECTION.stream()
        // do your filtering based on string values
        .map(SnpWrapper::parse) // String to Snp conversion
        // do your filtering based on Snp values
        .collect(Collectors.groupingBy(
                Wrapper::getType,
                Collectors.mapping(Wrapper::getSnp, Collectors.toList())
        ));

编辑：实际上不需要包装。你只需要提供一个实用的方法。它可以放在Snp中，也可以作为当前类中的私有方法。让我们假设它是后者，它的名称为getSnpType：

result = SNP_COLLECTION.stream()
        // do your filtering based on string values
        .map(Snp::parse) // or whatever you have for String -> Snp
        // do your filtering based on Snp values
        .collect(Collectors.groupingBy(StreamAssignment::getSnpType));