+ if (config.getBoolean("use-lz4-compression")) {
+ final String size = config.getString("lz4-blocksize");
+ streamFactory = InputOutputStreamFactory.lz4(size);
+ LOG.debug("Using LZ4 Input/Output Stream, blocksize: {}", size);
+ } else {
+ streamFactory = InputOutputStreamFactory.simple();
+ LOG.debug("Using plain Input/Output Stream");
+ }
+