Tag: latency

What does latency metrics represent in Flink and are them really valid to evaluate the latency of an application?

apache-flink flink-streaming java latency

I’ve a pipeline developed as shown below: I’m thinking hard about a way to value latency from input to output, but the relation between input and output isn’t 1 to 1 but there are a lot of transformations that make the latency evaluation conceptually very hard. I know about the latency metrics given by using the method: env.getConfig().setLatencyTrackingInterval(1000), but I

Storing lots of small records for sub millisecond latency retrieval

java json latency

I have a use case for needing to be able to retrieve a document (~1.5kb) from some store with latency of < 1ms if possible. The store will contain at least 2-3 million such documents. Sample ...