File tree
118 files changed
+8475
-0
lines changed- streampipes-extensions- streampipes-processors-enricher-jvm/src/main/resources- org.apache.streampipes.processors.enricher.jvm.jseval
- org.apache.streampipes.processors.enricher.jvm.processor.expression
- org.apache.streampipes.processors.enricher.jvm.processor.limitsalert
- org.apache.streampipes.processors.enricher.jvm.processor.limitsenrichment
- org.apache.streampipes.processors.enricher.jvm.processor.math.mathop
- org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop
- org.apache.streampipes.processors.enricher.jvm.processor.trigonometry
- org.apache.streampipes.processors.enricher.jvm.sizemeasure
- org.apache.streampipes.processors.enricher.jvm.valuechange
 
- streampipes-processors-filters-jvm/src/main/resources- org.apache.streampipes.processors.filters.jvm.compose
- org.apache.streampipes.processors.filters.jvm.enrich
- org.apache.streampipes.processors.filters.jvm.limit
- org.apache.streampipes.processors.filters.jvm.merge
- org.apache.streampipes.processors.filters.jvm.movingaverage
- org.apache.streampipes.processors.filters.jvm.numericalfilter
- org.apache.streampipes.processors.filters.jvm.numericaltextfilter
- org.apache.streampipes.processors.filters.jvm.processor.booleanfilter
- org.apache.streampipes.processors.filters.jvm.project
- org.apache.streampipes.processors.filters.jvm.schema
- org.apache.streampipes.processors.filters.jvm.sdt
- org.apache.streampipes.processors.filters.jvm.textfilter
- org.apache.streampipes.processors.filters.jvm.threshold
- org.apache.streampipes.processors.filters.jvm.throughputmon
 
- streampipes-processors-filters-siddhi/src/main/resources- org.apache.streampipes.processors.siddhi.count
- org.apache.streampipes.processors.siddhi.frequencychange
- org.apache.streampipes.processors.siddhi.frequency
- org.apache.streampipes.processors.siddhi.increase
- org.apache.streampipes.processors.siddhi.listcollector
- org.apache.streampipes.processors.siddhi.listfilter
- org.apache.streampipes.processors.siddhi.numericalfilter
- org.apache.streampipes.processors.siddhi.sequence
- org.apache.streampipes.processors.siddhi.stop
- org.apache.streampipes.processors.siddhi.topk
 
- streampipes-processors-geo-jvm/src/main/resources- org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic
- org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine
- org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname
- org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator
 
- streampipes-processors-transformation-jvm/src/main/resources- org.apache.streampipes.processors.transformation.jvm.booloperator.inverter
- org.apache.streampipes.processors.transformation.jvm.booloperator.timer
- org.apache.streampipes.processors.transformation.jvm.datetime
- org.apache.streampipes.processors.transformation.jvm.duration-value
- org.apache.streampipes.processors.transformation.jvm.field-mapper
- org.apache.streampipes.processors.transformation.jvm.fieldhasher
- org.apache.streampipes.processors.transformation.jvm.fieldrename
- org.apache.streampipes.processors.transformation.jvm.measurementunitconverter
- org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge
- org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state
- org.apache.streampipes.processors.transformation.jvm.processor.state.buffer
- org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer
- org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number
- org.apache.streampipes.processors.transformation.jvm.processor.staticmetadata
- org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state
- org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor
- org.apache.streampipes.processors.transformation.jvm.round
- org.apache.streampipes.processors.transformation.jvm.split-array
- org.apache.streampipes.processors.transformation.jvm.stringoperator.counter
- org.apache.streampipes.processors.transformation.jvm.stringoperator.timer
- org.apache.streampipes.processors.transformation.jvm.taskduration
- org.apache.streampipes.processors.transformation.jvm.transform-to-boolean
 
 
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
118 files changed
+8475
-0
lines changedLines changed: 137 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
|  | |||
|  | 1 | + | |
|  | 2 | + | |
|  | 3 | + | |
|  | 4 | + | |
|  | 5 | + | |
|  | 6 | + | |
|  | 7 | + | |
|  | 8 | + | |
|  | 9 | + | |
|  | 10 | + | |
|  | 11 | + | |
|  | 12 | + | |
|  | 13 | + | |
|  | 14 | + | |
|  | 15 | + | |
|  | 16 | + | |
|  | 17 | + | |
|  | 18 | + | |
|  | 19 | + | |
|  | 20 | + | |
|  | 21 | + | |
|  | 22 | + | |
|  | 23 | + | |
|  | 24 | + | |
|  | 25 | + | |
|  | 26 | + | |
|  | 27 | + | |
|  | 28 | + | |
|  | 29 | + | |
|  | 30 | + | |
|  | 31 | + | |
|  | 32 | + | |
|  | 33 | + | |
|  | 34 | + | |
|  | 35 | + | |
|  | 36 | + | |
|  | 37 | + | |
|  | 38 | + | |
|  | 39 | + | |
|  | 40 | + | |
|  | 41 | + | |
|  | 42 | + | |
|  | 43 | + | |
|  | 44 | + | |
|  | 45 | + | |
|  | 46 | + | |
|  | 47 | + | |
|  | 48 | + | |
|  | 49 | + | |
|  | 50 | + | |
|  | 51 | + | |
|  | 52 | + | |
|  | 53 | + | |
|  | 54 | + | |
|  | 55 | + | |
|  | 56 | + | |
|  | 57 | + | |
|  | 58 | + | |
|  | 59 | + | |
|  | 60 | + | |
|  | 61 | + | |
|  | 62 | + | |
|  | 63 | + | |
|  | 64 | + | |
|  | 65 | + | |
|  | 66 | + | |
|  | 67 | + | |
|  | 68 | + | |
|  | 69 | + | |
|  | 70 | + | |
|  | 71 | + | |
|  | 72 | + | |
|  | 73 | + | |
|  | 74 | + | |
|  | 75 | + | |
|  | 76 | + | |
|  | 77 | + | |
|  | 78 | + | |
|  | 79 | + | |
|  | 80 | + | |
|  | 81 | + | |
|  | 82 | + | |
|  | 83 | + | |
|  | 84 | + | |
|  | 85 | + | |
|  | 86 | + | |
|  | 87 | + | |
|  | 88 | + | |
|  | 89 | + | |
|  | 90 | + | |
|  | 91 | + | |
|  | 92 | + | |
|  | 93 | + | |
|  | 94 | + | |
|  | 95 | + | |
|  | 96 | + | |
|  | 97 | + | |
|  | 98 | + | |
|  | 99 | + | |
|  | 100 | + | |
|  | 101 | + | |
|  | 102 | + | |
|  | 103 | + | |
|  | 104 | + | |
|  | 105 | + | |
|  | 106 | + | |
|  | 107 | + | |
|  | 108 | + | |
|  | 109 | + | |
|  | 110 | + | |
|  | 111 | + | |
|  | 112 | + | |
|  | 113 | + | |
|  | 114 | + | |
|  | 115 | + | |
|  | 116 | + | |
|  | 117 | + | |
|  | 118 | + | |
|  | 119 | + | |
|  | 120 | + | |
|  | 121 | + | |
|  | 122 | + | |
|  | 123 | + | |
|  | 124 | + | |
|  | 125 | + | |
|  | 126 | + | |
|  | 127 | + | |
|  | 128 | + | |
|  | 129 | + | |
|  | 130 | + | |
|  | 131 | + | |
|  | 132 | + | |
|  | 133 | + | |
|  | 134 | + | |
|  | 135 | + | |
|  | 136 | + | |
|  | 137 | + | |
Lines changed: 23 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
|  | |||
|  | 1 | + | |
|  | 2 | + | |
|  | 3 | + | |
|  | 4 | + | |
|  | 5 | + | |
|  | 6 | + | |
|  | 7 | + | |
|  | 8 | + | |
|  | 9 | + | |
|  | 10 | + | |
|  | 11 | + | |
|  | 12 | + | |
|  | 13 | + | |
|  | 14 | + | |
|  | 15 | + | |
|  | 16 | + | |
|  | 17 | + | |
|  | 18 | + | |
|  | 19 | + | |
|  | 20 | + | |
|  | 21 | + | |
|  | 22 | + | |
|  | 23 | + | |
Lines changed: 114 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
|  | |||
|  | 1 | + | |
|  | 2 | + | |
|  | 3 | + | |
|  | 4 | + | |
|  | 5 | + | |
|  | 6 | + | |
|  | 7 | + | |
|  | 8 | + | |
|  | 9 | + | |
|  | 10 | + | |
|  | 11 | + | |
|  | 12 | + | |
|  | 13 | + | |
|  | 14 | + | |
|  | 15 | + | |
|  | 16 | + | |
|  | 17 | + | |
|  | 18 | + | |
|  | 19 | + | |
|  | 20 | + | |
|  | 21 | + | |
|  | 22 | + | |
|  | 23 | + | |
|  | 24 | + | |
|  | 25 | + | |
|  | 26 | + | |
|  | 27 | + | |
|  | 28 | + | |
|  | 29 | + | |
|  | 30 | + | |
|  | 31 | + | |
|  | 32 | + | |
|  | 33 | + | |
|  | 34 | + | |
|  | 35 | + | |
|  | 36 | + | |
|  | 37 | + | |
|  | 38 | + | |
|  | 39 | + | |
|  | 40 | + | |
|  | 41 | + | |
|  | 42 | + | |
|  | 43 | + | |
|  | 44 | + | |
|  | 45 | + | |
|  | 46 | + | |
|  | 47 | + | |
|  | 48 | + | |
|  | 49 | + | |
|  | 50 | + | |
|  | 51 | + | |
|  | 52 | + | |
|  | 53 | + | |
|  | 54 | + | |
|  | 55 | + | |
|  | 56 | + | |
|  | 57 | + | |
|  | 58 | + | |
|  | 59 | + | |
|  | 60 | + | |
|  | 61 | + | |
|  | 62 | + | |
|  | 63 | + | |
|  | 64 | + | |
|  | 65 | + | |
|  | 66 | + | |
|  | 67 | + | |
|  | 68 | + | |
|  | 69 | + | |
|  | 70 | + | |
|  | 71 | + | |
|  | 72 | + | |
|  | 73 | + | |
|  | 74 | + | |
|  | 75 | + | |
|  | 76 | + | |
|  | 77 | + | |
|  | 78 | + | |
|  | 79 | + | |
|  | 80 | + | |
|  | 81 | + | |
|  | 82 | + | |
|  | 83 | + | |
|  | 84 | + | |
|  | 85 | + | |
|  | 86 | + | |
|  | 87 | + | |
|  | 88 | + | |
|  | 89 | + | |
|  | 90 | + | |
|  | 91 | + | |
|  | 92 | + | |
|  | 93 | + | |
|  | 94 | + | |
|  | 95 | + | |
|  | 96 | + | |
|  | 97 | + | |
|  | 98 | + | |
|  | 99 | + | |
|  | 100 | + | |
|  | 101 | + | |
|  | 102 | + | |
|  | 103 | + | |
|  | 104 | + | |
|  | 105 | + | |
|  | 106 | + | |
|  | 107 | + | |
|  | 108 | + | |
|  | 109 | + | |
|  | 110 | + | |
|  | 111 | + | |
|  | 112 | + | |
|  | 113 | + | |
|  | 114 | + | |
Lines changed: 29 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
|  | |||
|  | 1 | + | |
|  | 2 | + | |
|  | 3 | + | |
|  | 4 | + | |
|  | 5 | + | |
|  | 6 | + | |
|  | 7 | + | |
|  | 8 | + | |
|  | 9 | + | |
|  | 10 | + | |
|  | 11 | + | |
|  | 12 | + | |
|  | 13 | + | |
|  | 14 | + | |
|  | 15 | + | |
|  | 16 | + | |
|  | 17 | + | |
|  | 18 | + | |
|  | 19 | + | |
|  | 20 | + | |
|  | 21 | + | |
|  | 22 | + | |
|  | 23 | + | |
|  | 24 | + | |
|  | 25 | + | |
|  | 26 | + | |
|  | 27 | + | |
|  | 28 | + | |
|  | 29 | + | |
0 commit comments