34#ifndef __TEMPORAL_AGGFUNCS_H__
35#define __TEMPORAL_AGGFUNCS_H__
40#include "general/skiplist.h"
41#include "general/temporal.h"
42#include "general/type_util.h"
63 bool crossings,
int *newcount);
Temporal * temporal_tagg_finalfn(SkipList *state)
Generic final function for aggregating temporal values.
Definition: temporal_aggfuncs.c:606
Datum(* datum_func2)(Datum, Datum)
Definition: temporal.h:367
uintptr_t Datum
Definition: pg_ext_defs.in.h:4
Datum transform(PG_FUNCTION_ARGS)
Structure to represent skiplists that keep the current state of an aggregation.
Definition: meos.h:240
Structure to represent temporal values of instant subtype.
Definition: meos.h:148
Structure to represent temporal values of sequence set subtype.
Definition: meos.h:186
Structure to represent temporal values of instant set or sequence subtype.
Definition: meos.h:165
Structure to represent the common structure of temporal values of any temporal subtype.
Definition: meos.h:136
Datum datum_min_float8(Datum l, Datum r)
Return the minimum value of the two arguments.
Definition: temporal_aggfuncs.c:79
SkipList * temporal_tagg_transform_transfn(SkipList *state, const Temporal *temp, datum_func2 func, bool crossings, TInstant *(*transform)(const TInstant *))
Transition function for aggregating temporal values that require a transformation to each composing i...
Definition: temporal_aggfuncs.c:856
SkipList * tinstant_tagg_transfn(SkipList *state, const TInstant *inst, datum_func2 func)
Generic transition function for aggregating temporal values of instant subtype.
Definition: temporal_aggfuncs.c:452
Datum datum_sum_double4(Datum l, Datum r)
Return the sum of the two arguments.
Definition: temporal_aggfuncs.c:144
Datum datum_sum_float8(Datum l, Datum r)
Return the sum of the two arguments.
Definition: temporal_aggfuncs.c:115
SkipList * temporal_tagg_combinefn(SkipList *state1, SkipList *state2, datum_func2 func, bool crossings)
Generic combine function for aggregating temporal values.
Definition: temporal_aggfuncs.c:579
Datum datum_max_float8(Datum l, Datum r)
Return the maximum value of the two arguments.
Definition: temporal_aggfuncs.c:88
Temporal ** temporal_transform_tcount(const Temporal *temp, int *count)
Transform a temporal value into a temporal integer value for performing temporal count aggregation (d...
Definition: temporal_aggfuncs.c:951
SkipList * temporal_tagg_combinefn1(SkipList *state1, SkipList *state2, datum_func2 func, bool crossings)
Datum datum_max_int32(Datum l, Datum r)
Return the maximum value of the two arguments.
Definition: temporal_aggfuncs.c:70
Datum datum_sum_double3(Datum l, Datum r)
Return the sum of the two arguments.
Definition: temporal_aggfuncs.c:134
TInstant ** tinstant_tagg(TInstant **instants1, int count1, TInstant **instants2, int count2, Datum(*func)(Datum, Datum), int *newcount)
SkipList * tsequenceset_tagg_transfn(SkipList *state, const TSequenceSet *ss, datum_func2 func, bool crossings)
Generic transition function for aggregating temporal values of sequence set subtype.
Definition: temporal_aggfuncs.c:526
SkipList * tdiscseq_tagg_transfn(SkipList *state, const TSequence *seq, datum_func2 func)
Generic transition function for aggregating temporal discrete sequence values.
Definition: temporal_aggfuncs.c:476
Datum datum_min_int32(Datum l, Datum r)
Temporal aggregate functions.
Definition: temporal_aggfuncs.c:61
Datum datum_min_text(Datum l, Datum r)
Return the minimum value of the two arguments.
Definition: temporal_aggfuncs.c:97
Datum datum_sum_double2(Datum l, Datum r)
Return the sum of the two arguments.
Definition: temporal_aggfuncs.c:124
Temporal ** temporal_transform_tagg(const Temporal *temp, int *count, TInstant *(*func)(const TInstant *))
Transform a temporal value for aggregation.
Definition: temporal_aggfuncs.c:809
SkipList * temporal_tagg_transfn(SkipList *state, const Temporal *temp, datum_func2, bool crossings)
Generic transition function for aggregating temporal values of sequence set subtype.
Definition: temporal_aggfuncs.c:552
SkipList * tcontseq_tagg_transfn(SkipList *state, const TSequence *seq, datum_func2 func, bool interpoint)
Generic transition function for aggregating temporal values of sequence subtype.
Definition: temporal_aggfuncs.c:502
TSequenceSet * tsequence_tavg_finalfn(TSequence **sequences, int count)
Final function for temporal average aggregation of temporal sequence values.
Definition: temporal_aggfuncs.c:1041
TSequence ** tsequence_tagg(TSequence **sequences1, int count1, TSequence **sequences2, int count2, Datum(*func)(Datum, Datum), bool crossings, int *newcount)
TInstant * tnumberinst_transform_tavg(const TInstant *inst)
Transform a temporal number into a temporal double2 value for performing temporal average aggregation...
Definition: temporal_aggfuncs.c:1009
TSequence * tinstant_tavg_finalfn(TInstant **instants, int count)
Final function for temporal average aggregation of temporal instat values.
Definition: temporal_aggfuncs.c:1023
Datum datum_max_text(Datum l, Datum r)
Return the maximum value of the two arguments.
Definition: temporal_aggfuncs.c:106