Need to figure out way to record the field lineage operations for the streaming pipelines. There are few issues in doing so currently -
1. Lifecycle for the streaming pipelines is different than batch, for example we record the lineage once the batch program is complete, however there is no completion of the streaming pipelines
2. Because of checkpointing, once started, runtime arguments of the streaming pipelines cannot be changed, so each run will record the same set of operations. We may not want to record operations per run then.