[GOBBLIN-1336] Implement a streaming version of TimePartitionedDataPublisher

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.16.0
• Fix Version/s: 0.17.0
• Component/s: gobblin-core
• Assignee: Abhishek Tiwari
• Reporter: Sudarshan Vasudevan
• Created: 12/Dec/20 01:20
• Updated: 14/Jun/23 04:13

Description

A TimePartitionedDataPublisher that is intended for streaming mode of execution. This data publisher performs a state clean up on each publish action.