search

IBMStreams / streamsx.topology

Develop streaming applications for IBM Streams in Python, Java & Scala.
http://ibmstreams.github.io/streamsx.topology
Apache License 2.0
29 stars 43 forks source link

Python: Support tumbling window based on punctuation #2527

Closed markheger closed 4 years ago

markheger commented 4 years ago

similar to SPL code:

   Agg1 = Aggregate(Beat)                                                        
    {                                                                                 
      window                                                                          
        Beat : tumbling, punct();
markheger commented 4 years ago

merged to branch feature/punct

markheger commented 4 years ago

create a tumbling window with eviction by punctuation: window = s.batch('punct')

markheger commented 4 years ago

Python window.Aggregate() needs to support a "punctWindow".

Affected operator: com.ibm.streamsx.topology/com.ibm.streamsx.topology.functional.python/Aggregate/Aggregate_cpp.cgt

markheger commented 4 years ago 
        window = s.batch('punct')
        a = window.aggregate(SumMaxValues())
markheger commented 4 years ago

merged to develop branch for 1.16.0a