Buffer

Buffer(env, cluster, planner, config)

HotBuffer(capacity, max_ingest_data_rate)

HotBuffer represents the ingest-facing part of the Buffer.

ColdBuffer(capacity, max_data_rate)

The ColdBuffer takes data from the hot buffer for use in workflow processing