Page History

sm_data = CONNECTOR({
              port = 0,
              source = 'preprocessing_source',
              schema = ${sm_schema}            
            }          
          )

[...]
calc_w1 = PREDICATEWINDOW({
              start = 'true',
#IF OUTOFORDER="TRUE"
			  end = "!isNull(__last_1.i) && floor(__last_1.i/${w1_size}) != floor(i/${w1_size})",
#ELSE
              end = "size(__all) == ${w1_size}-1",
#ENDIF
              nesting = true,
              keependingelement = true,
              USEELEMENTONLYFORSTARTOREND = true,
              allowsamestartandendts = true,
              keepTimeOrder = false             
            },
            w1_preprocess
          )