Implement size based splitting to get rid of JVM heap related exceptions
Extract also arrival timestamp for later group by using modulo