Open octmar opened 3 years ago
Update: This seems to happen when i'm pushing PartitionedStreamEvent. Changed the registering ingress to: var ingress = container.RegisterPartitionedInput( streamEvents: observable.Synchronize(), partitionExtractor: e => e.IndexId, startEdgeExtractor: e => e.Date.Ticks, flushPolicy: PartitionedFlushPolicy.None, onCompletedPolicy: OnCompletedPolicy.None ); In this case data seem to be ingressing correctly with it's own timeline by partition and the pipe.Flush() correctly issues an output .
Hello, I need some help with the following scenario: I have multiple devices that are raising events to a trill ingress stream. Whenever i ingress an event i want to also issue a flush of output from trill. What i did was to setup a partitioned ingress, where each partition would represent a device. I do not want to use lowwatermark policies since from what i've read this will move time globally and not for a specific device only. I have this sample code to test this scenario:
On this sample i use a timer to post events only for one device and as you can see, on each post i also do a pipe.flush() where i would expect this to force a flush, which is not happening. If i would change flushpolicy on lowwatermark and for each event i also create a lowwatermark event then it flushes output, but this is not ok for my scenario because i don't want to move time for all devices. Can you help me out to figure what i am missing ?