Class Setup_JXTpp

src/main/java/client/Setup_JXTpp.java:23–238

Created with IntelliJ IDEA. @Author: KaiDu @Date: 2023/11/06/16:26 @Description: the setup algorithm of JXT++

 * @Description: the setup algorithm of JXT++
 */
public class Setup_JXTpp {
    private static String K_aes = "8975924566f6e252";
    private static String K_token = "89b7a92966f6eb32";
    private static String K_w = "7975922666f6eb02";
    private static String K_wp = "787599ac86f2e82";
    private static String K_z = "9862192ad6f6ef65";
    private static String K_h = "9874a22554e7db85";
    private static String K_c = "6574b33984e7fb55";
    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;

    private Xor8 xor;

    private int[] l_max;

    private Map<BigInteger, ArrayList<byte[]>> 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_JXTpp(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
        l_max = new int[join_column];
        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<>();
        Map<String, Integer> l_max_cnt = new HashMap<>();
        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 and statistics the l_max
        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);