Streaming half of lambda architecture working.