Package io.deephaven.kafka.ingest

Class ParallelParser<T>

java.lang.Object

io.deephaven.kafka.ingest.ParallelParser<T>

Type Parameters:

T -

public class ParallelParser<T>
extends Object

A utility intended to assist in parallel-parsing inbound messages from a Kafka broker while ensuring that row(s) are written to disk in the order corresponding to the order in which they were sent to the utility.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait