Class Setup_JXT

src/main/java/client/Setup_JXT.java:23–172

Created with IntelliJ IDEA. @Author: KaiDu @Date: 2023/09/12/15:44 @Description: the setup algorithm of JXT

 * @Description: the setup algorithm of JXT
 */
public class Setup_JXT {
    private static String K_aes = "8975924566f6e252";
    private static String K_token = "89b7a92966f6eb32";
    private static String K_x = "7975922666f6eb02";
    private static String K_y = "9862192ad6f6ef65";
    private static String K_h1 = "9874a22554e7db85";
    private static String K_h2 = "fad78974156f6b25";
    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;
    //the XSet is implemented by the Bloom filter
    private Bloom f;

    private Map<BigInteger, ArrayList<tuple>> tset = new LinkedHashMap<>();

    /**
     *
     * @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_JXT(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);
                    }