bda-datastore/src/main/java/gr/ntua/ece/cslab/selis/bda/datastore/StorageBackend.java
public void init(MasterData masterData) throws Exception {
        DTconnector.put(masterData);
        /*List<KeyValue> columns = new LinkedList<>();
        for (DimensionTable table: masterData.getTables()) {
            String key = table.getSchema().getPrimaryKey();
            String type = "";
            for (KeyValue column : table.getSchema().getColumnTypes())
                if (column.getKey().matches(key))
                    type = column.getValue();
            KeyValue field = new KeyValue(table.getName()+"_"+key, type);
            columns.add(field);
        }
        Message emptyMsg = new Message(new LinkedList<>(), columns);
        ELconnector.put(emptyMsg);*/
    }
/** Initialize the eventLog and dimension tables in the underlying FS Using the masterData.
     *  MasterData include in json format for all the dimension tables the name, schema, data and the primary key of
     *  each table. Using the primary keys of the dimension tables the eventLog is created with these foreign keys
     *  and an extra column named 'message' is created in the eventLog that contains the actual message (that will
     *  be in json format). **/
Initialize the eventLog and dimension tables in the underlying FS Using the masterData.
MasterData include in json format for all the dimension tables the name, schema, data and the primary key of
each table. Using the primary keys of the dimension tables the eventLog is created with these foreign keys
and an extra column named 'message' is created in the eventLog that contains the actual message (that will
be in json format).
Initialize the eventLog and dimension tables in the underlying FS Using the masterData . MasterData include in json format for all the dimension tables the name schema data and the primary key of each table . Using the primary keys of the dimension tables the eventLog is created with these foreign keys and an extra column named ' message ' is created in the eventLog that contains the actual message ( that will be in json format ) .
public void init(MasterData masterData) throws Exception {
        DTconnector.put(masterData);
        /*List<KeyValue> columns = new LinkedList<>();
        for (DimensionTable table: masterData.getTables()) {
            String key = table.getSchema().getPrimaryKey();
            String type = "";
            for (KeyValue column : table.getSchema().getColumnTypes())
                if (column.getKey().matches(key))
                    type = column.getValue();
            KeyValue field = new KeyValue(table.getName()+"_"+key, type);
            columns.add(field);
        }
        Message emptyMsg = new Message(new LinkedList<>(), columns);
        ELconnector.put(emptyMsg);*/
    }
public void init ( MasterData masterData ) throws Exception { DTconnector . put ( masterData ) ; /*List<KeyValue> columns = new LinkedList<>();
        for (DimensionTable table: masterData.getTables()) {
            String key = table.getSchema().getPrimaryKey();
            String type = "";
            for (KeyValue column : table.getSchema().getColumnTypes())
                if (column.getKey().matches(key))
                    type = column.getValue();
            KeyValue field = new KeyValue(table.getName()+"_"+key, type);
            columns.add(field);
        }
        Message emptyMsg = new Message(new LinkedList<>(), columns);
        ELconnector.put(emptyMsg);*/ }
Initialize the eventLog and dimension tables in the underlying FS Using the masterData.
Initialize the eventLog and dimension tables in the underlying FS Using the masterData .