Skip to content
Snippets Groups Projects
Commit e5a4b0c9 authored by Peter Lünenschloß's avatar Peter Lünenschloß
Browse files

minor changes

parent 153218c3
No related branches found
No related tags found
4 merge requests!193Release 1.4,!188Release 1.4,!49Dataprocessing features,!44Dataprocessing features
Pipeline #3584 passed with stage
in 9 minutes and 36 seconds
......@@ -7,6 +7,7 @@ from saqc.funcs.register import register
from saqc.lib.ts_operators import interpolateNANs, validationTrafo
from saqc.lib.tools import composeFunction
@register()
def proc_interpolateMissing(data, field, flagger, method, inter_order=2, inter_limit=2, interpol_flag='UNFLAGGED',
downgrade_interpolation=False, return_chunk_bounds=False, **kwargs):
......@@ -20,6 +21,7 @@ def proc_interpolateMissing(data, field, flagger, method, inter_order=2, inter_l
flag=getattr(flagger, interpol_flag), **kwargs)
return inter_data, flagger
@register()
def proc_resample(data, field, flagger, freq, func="mean", max_invalid_total=None, max_invalid_consec=None,
flag_agg_func='max', **kwargs):
......@@ -61,4 +63,11 @@ def proc_resample(data, field, flagger, freq, func="mean", max_invalid_total=Non
all_flags[field] = datflags
flagger = flagger.initFlags(flags=all_flags)
return data, flagger
@register()
def proc_transform(data, field, flagger, func, **kwargs):
func = composeFunction(func)
data[field] = data[field].transform(func)
return data, flagger
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment