package com.megatim.fdxcommons.tools.database.queries.metadata;
|
|
import com.megatim.fdxcommons.model.integration.TableDefinition;
|
import com.megatim.fdxcommons.tools.database.exceptions.BadDataValueException;
|
import com.megatim.fdxcommons.tools.database.exceptions.ColumnNotFoundException;
|
import com.megatim.fdxcommons.tools.database.exceptions.LocalDateTimeValueParseError;
|
import com.megatim.fdxcommons.tools.utils.FdxParsedDataAction;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ForkJoinPool;
|
|
/**
|
*
|
* @author Gabuntu
|
*/
|
public class FdxParsedData {
|
|
private final List<LinkedHashMap<String, Object>> sourceData;
|
private final TableDefinition tableDefinition;
|
|
public FdxParsedData(List<LinkedHashMap<String, Object>> sourceData, TableDefinition tableDefinition) {
|
this.sourceData = sourceData;
|
this.tableDefinition = tableDefinition;
|
}
|
|
public List<Map<String, Object>> data() throws BadDataValueException, LocalDateTimeValueParseError, ColumnNotFoundException {
|
ForkJoinPool pool = new ForkJoinPool();
|
return pool.invoke(new FdxParsedDataAction(sourceData, tableDefinition));
|
}
|
|
}
|
