/*** serialization/deserialization ***/
ClickHouseDataConfig config = ...;
List<ClickHouseColumn> columns = ClickHouseColumn.parse("a String, b Int32");
ByteArrayOutputStream out = new ByteArrayOutputStream();
try (ClickHouseOutputStream output = ClickHouseOutputStream.of(out)) {
    // find a suitable processor based on config.getFormat()
    ClickHouseDataProcessor processor = ClickHouseDataStreamFactory.getInstance()
            .getProcessor(config, null, output, null, columns);
    // let's reuse same wrapper class for both columns
    ClickHouseValue v = ClickHouseIntegerValue.ofNull();
    for (int i=0; i<50_000; i++) {
        v.update(i);
        for (ClickHouseSerializer s : processor.getSerializers()) {
            s.serialize(v, output);
        }
    }
}
byte[] bytes = out.toByteArray();

/*** type conversion ***/
ClickHouseValue value = ClickHouseStringValue.of("123");
byte b = value.asByte();
int i = value.asInteger();
long l = value.asLong();
value.update(l + i + b); // "369"

/*** streaming ***/
int bufferSize = 8192;
int queueLength = 0; // unlimited
int timeout = 30000; // 30 seconds
ClickHousePipedOutputStream output = ClickHouseDataStreamFactory.getInstance()
        .createPipedOutputStream(bufferSize, queueLength, timeout);
// write and read in separate threads
CompletableFuture<Boolean> future = CompletableFuture.supplyAsync(() -> {
    try (ClickHouseOuputStream out = output) {
        for (int i = 0; i<50_000; i++) {
            out.writeByte(0)
        }

        return true;
    }
});

// read will be blocked until there's data available in the "pipe"
try (ClickHouseInputStream input = ClickHouseInputStream.of(output.getInputStream(), new FileInputStream("/tmp/mine.txt"))) { // read consolidated input streams
    byte b = input.readByte();
}

/*** compression/decompression ***/
int level = -1;
ClickHouseInputStream input = ClickHouseCompressionAlgorithm.of(ClickHouseCompression.ZSTD)
        .decompress(null, new FileInputStream("/tmp/compressed.data"), bufferSize, level, null);
ClickHouseOutputStream output = ClickHouseCompressionAlgorithm.of(ClickHouseCompression.LZ4)
        .compress(null, new FileInputStream("/tmp/compressed.data"), bufferSize, level, null);
input.pipe(output);