3. only keep prefered form and it's normalized equivalent, using inner join of streams
4. Tap out to elasticsearch