Class Setup_JXTp

src/main/java/client/Setup_JXTp.java:23–178

Created with IntelliJ IDEA. @Author: KaiDu @Date: 2023/09/22/16:37 @Description: the setup algorithm of JXT+

 * @Description: the setup algorithm of JXT+
 */
public class Setup_JXTp {
    private static String K_aes = "8975924566f6e252";
    private static String K_token = "89b7a92966f6eb32";
    private static String K_w = "7975922666f6eb02";
    private static String K_z = "9862192ad6f6ef65";
    private static String K_h = "9874a22554e7db85";
    private int table_id;
    private int key_column;
    private int join_column;
    private int record_num;
    private String condition;
    private String[] id;
    private String[][] keyword;
    private String[][] join_attr;
    private Bloom f;//the XSet is implemented by the Bloom filter
    private Map<BigInteger, ArrayList<byte[]>> tset = new LinkedHashMap<>();
    private Map<Long, ArrayList<byte[]>> cset = new HashMap<>();//the CSet for JXT+ is implemented by the map
    /**
     *
     * @param table_id_ the table index
     * @param key_column_num the number of columns which are not join attribute
     * @param join_column_num the number of column
     * @param record the number of records of the table
     */
    public Setup_JXTp(int table_id_, int key_column_num, int join_column_num, int record, String condition_t){
        table_id = table_id_;
        key_column = key_column_num;
        join_column = join_column_num;
        record_num = record;
        condition = condition_t;
    }

    public void construct() {
        //Step 1 read the dataset from the tables
        //Step 1.1 prepare the parameters
        id = new String[record_num + 1];
        keyword = new String[record_num + 1][key_column];
        join_attr = new String[record_num + 1][join_column];
        Map<String, ArrayList<Integer>> reverse_id = new LinkedHashMap<>();//the pairs of (attribute-value pair, record ids)
        String path = "data/table" + table_id + "/table" + table_id + "_k" + key_column
                + "_j" + join_column + "_" + record_num + condition +".csv";
        //Step 1.2 begin to read dataset
        try (Reader reader = Files.newBufferedReader(Paths.get(path))) {
            Iterable<CSVRecord> records = CSVFormat.DEFAULT.parse(reader);
            int counter = 0;
            for (CSVRecord record : records) {
                id[counter] = record.get(0);
                for (int j = 0; j < key_column; j++) {
                    keyword[counter][j] = record.get(j + 1);
                    if (counter != 0) {
                        String kword = keyword[0][j] + record.get(j + 1);//attribute-value pair
                        if (!reverse_id.containsKey(kword))
                            reverse_id.put(kword, new ArrayList<>());
                        reverse_id.get(kword).add(counter);
                    }
                }
                //also join-attribute values pairs are also seen as the attribute-value pair
                for (int j = 0; j < join_column; j++) {