MobilityDB 1.1
temporal_aggfuncs.h
Go to the documentation of this file.
1/*****************************************************************************
2 *
3 * This MobilityDB code is provided under The PostgreSQL License.
4 * Copyright (c) 2016-2023, Université libre de Bruxelles and MobilityDB
5 * contributors
6 *
7 * MobilityDB includes portions of PostGIS version 3 source code released
8 * under the GNU General Public License (GPLv2 or later).
9 * Copyright (c) 2001-2023, PostGIS contributors
10 *
11 * Permission to use, copy, modify, and distribute this software and its
12 * documentation for any purpose, without fee, and without a written
13 * agreement is hereby granted, provided that the above copyright notice and
14 * this paragraph and the following two paragraphs appear in all copies.
15 *
16 * IN NO EVENT SHALL UNIVERSITE LIBRE DE BRUXELLES BE LIABLE TO ANY PARTY FOR
17 * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES, INCLUDING
18 * LOST PROFITS, ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION,
19 * EVEN IF UNIVERSITE LIBRE DE BRUXELLES HAS BEEN ADVISED OF THE POSSIBILITY
20 * OF SUCH DAMAGE.
21 *
22 * UNIVERSITE LIBRE DE BRUXELLES SPECIFICALLY DISCLAIMS ANY WARRANTIES,
23 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
24 * AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS ON
25 * AN "AS IS" BASIS, AND UNIVERSITE LIBRE DE BRUXELLES HAS NO OBLIGATIONS TO
26 * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS. 
27 *
28 *****************************************************************************/
29
34#ifndef __TEMPORAL_AGGFUNCS_H__
35#define __TEMPORAL_AGGFUNCS_H__
36
37/* PostgreSQL */
38#include <postgres.h>
39/* MEOS */
40#include "general/skiplist.h"
41#include "general/temporal.h"
42#include "general/type_util.h"
43
44/*****************************************************************************/
45
46extern Datum datum_min_int32(Datum l, Datum r);
47extern Datum datum_max_int32(Datum l, Datum r);
51extern Datum datum_min_text(Datum l, Datum r);
52extern Datum datum_max_text(Datum l, Datum r);
56
57/* Generic aggregation functions */
58
59extern TInstant **tinstant_tagg(TInstant **instants1, int count1,
60 TInstant **instants2, int count2, Datum (*func)(Datum, Datum), int *newcount);
61extern TSequence **tsequence_tagg(TSequence **sequences1, int count1,
62 TSequence **sequences2, int count2, Datum (*func)(Datum, Datum),
63 bool crossings, int *newcount);
65 datum_func2 func, bool interpoint);
67 datum_func2 func, bool crossings);
68
70 datum_func2 func);
71extern TSequence *tinstant_tavg_finalfn(TInstant **instants, int count);
72extern TSequenceSet *tsequence_tavg_finalfn(TSequence **sequences, int count);
74extern Temporal **temporal_transform_tcount(const Temporal *temp, int *count);
75extern Temporal **temporal_transform_tagg(const Temporal *temp, int *count,
76 TInstant *(*func)(const TInstant *));
78 const TSequenceSet *ss, datum_func2 func, bool crossings);
80 datum_func2 func);
81
83 datum_func2, bool crossings);
84extern SkipList *temporal_tagg_combinefn(SkipList *state1, SkipList *state2,
85 datum_func2 func, bool crossings);
88 datum_func2 func, bool crossings, TInstant *(*transform)(const TInstant *));
89
90/*****************************************************************************/
91
92#endif
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
Definition: pgtz.h:42
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