private static void generateTable(double scale, String path) throws IOException {
File dir = new File(path + "/table");
dir.mkdir();
for (TpchTable table : TpchTable.getTables()) {
Iterable generator = table.createGenerator(scale, 1, 1);
StringBuilder builder = new StringBuilder();
generator.forEach(s -> {
String line = ((TpchEntity) s).toLine().trim();
if (line.endsWith("|")) {
line = line.substring(0, line.length() - 1);
}
builder.append(line).append('\n');
});
try (BufferedWriter writer = new BufferedWriter(
new OutputStreamWriter(
new FileOutputStream(path + "/table/" + table.getTableName() + ".csv")))
) {
writer.write(builder.toString());
}
}
}
private static void generateTable(double scale, String path) throws IOException {
File dir = new File(path + "/table");
dir.mkdir();
for (TpchTable table : TpchTable.getTables()) {
Iterable generator = table.createGenerator(scale, 1, 1);
StringBuilder builder = new StringBuilder();
generator.forEach(s -> {
String line = ((TpchEntity) s).toLine().trim();
if (line.endsWith("|")) {
line = line.substring(0, line.length() - 1);
}
builder.append(line).append('\n');
});
try (BufferedWriter writer = new BufferedWriter(
new OutputStreamWriter(
new FileOutputStream(path + "/table/" + table.getTableName() + ".csv")))
) {
writer.write(builder.toString());
}
}
}