in src/main/java/com/google/solutions/df/log/aggregations/StreamingBenchmark.java [118:132]
public void setup() throws IOException {
dataGenerator = new JsonDataGeneratorImpl();
Metadata metadata = FileSystems.matchSingleFileSpec(schemaLocation);
// Copy the schema file into a string which can be used for generation.
try (ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream()) {
try (ReadableByteChannel readerChannel = FileSystems.open(metadata.resourceId())) {
try (WritableByteChannel writerChannel = Channels.newChannel(byteArrayOutputStream)) {
ByteStreams.copy(readerChannel, writerChannel);
}
}
schema = byteArrayOutputStream.toString();
}
}