Peter

@jurby we currently do not have work planned for this integration.

@unruledboy For the partitioning aspect, you could use the Grouping functions as you suggest, but this has limitations, e.g., all devices must abide by the same singular timeline, such that...

I'm not sure what you mean by "overlapping cycles". Each device should either be charging or draining at any given point, right? E.g., here's a quick and dirty sample that...

The OnCompleted call was just for test purposes. You have many other options to control the Flush behavior: - FlushPolicy - Calling Process.Flush (Process is returned by QueryContainer.Restore) - Don't...

By buffer size, i was referring to Config.DataBatchSize, not maxDuration. If no FlushPolicy.None is specified, then each Trill operator will not flush its output batch until it is full with...

For parallelization, it is generally left to the consumer. I think ideally you would partition the input source, e.g. by device id, and have separate (possibly otherwise identical) parallel Trill...

Thanks @unruledboy , there is a bug in our partitioned pattern matching code where matches aren't detected properly. @rodrigoaatmicrosoft has a fix and will send a PR for the issue...

The sample provided is compatible with multicast, but it depends on your query logic, and how much of the query pipeline is shared between the different forks. From the IStreamable...

Please make sure to honor all style cop (Roslyn analyzers) and VS style guidelines (should be red lines in your environment). If you are using VS and not seeing them...

I realize the old code could use better documentation but the new code you are adding is not trivial and needs to be properly commented/documented. Please take time to comment...