Java源码示例:io.airlift.tpch.TpchEntity

示例1
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());
		}
	}
}
 
示例2
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());
		}
	}
}