Adicionado drift modifier

Author: filipebraida

src/modifiers.jl

@@ -34,5 +34,17 @@ function apply!(modifier::FilterModifier, data::DataFrame, event::Int)
     end
 
     select!(data, columns)
+    return nothing
+end
+struct DriftModifier <: Modifier
+    column::Symbol
+    filter::Function
+    drift::Function
+end
+
+function apply!(modifier::DriftModifier, data::DataFrame, event::Int)
+    elements = modifier.filter(data)
+    data[elements, modifier.column] = data[elements, modifier.column] .+ modifier.drift(event)
+
     return nothing
 end

src/stream.jl

@@ -15,6 +15,7 @@ function increment(stream::AbstractStream)
     stream.events += 1 
     return nothing
 end
+
 mutable struct BatchStream <: AbstractStream
     connector::AbstractConnector
     batch::Int
@@ -36,6 +37,7 @@ function listen(stream::BatchStream)::DataFrame
     end
 
     increment(stream)
+
     values = DataFrame[]
 
     for i = 1:stream.batch