13100369341

Committed 02 Feb 2025 01:18PM UTC coverage: 95.084% (-0.01%) from 95.097%

Build # 13100369341

Build Type

push

github

Committed by

web-flow

Commit Message

Add interpolation parameter to appendInstant (#648)

Run Details

23 of 27 new or added lines in 4 files covered. (85.19%)

2 existing lines in 1 file now uncovered.

32511 of 34192 relevant lines covered (95.08%)

736293.08 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

95.81

/mobilitydb/src/general/temporal_aggfuncs.c

/*****************************************************************************
 *
 * This MobilityDB code is provided under The PostgreSQL License.
 * Copyright (c) 2016-2024, Université libre de Bruxelles and MobilityDB
 * contributors
 *
 * MobilityDB includes portions of PostGIS version 3 source code released
 * under the GNU General Public License (GPLv2 or later).
 * Copyright (c) 2001-2024, PostGIS contributors
 *
 * Permission to use, copy, modify, and distribute this software and its
 * documentation for any purpose, without fee, and without a written
 * agreement is hereby granted, provided that the above copyright notice and
 * this paragraph and the following two paragraphs appear in all copies.
 *
 * IN NO EVENT SHALL UNIVERSITE LIBRE DE BRUXELLES BE LIABLE TO ANY PARTY FOR
 * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES, INCLUDING
 * LOST PROFITS, ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION,
 * EVEN IF UNIVERSITE LIBRE DE BRUXELLES HAS BEEN ADVISED OF THE POSSIBILITY
 * OF SUCH DAMAGE.
 *
 * UNIVERSITE LIBRE DE BRUXELLES SPECIFICALLY DISCLAIMS ANY WARRANTIES,
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
 * AND FITNESS FOR A PARTICULAR PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS ON
 * AN "AS IS" BASIS, AND UNIVERSITE LIBRE DE BRUXELLES HAS NO OBLIGATIONS TO
 * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS.
 *
 *****************************************************************************/

/**
 * @file
 * @brief Aggregate functions for temporal types
 */

#include "general/temporal_aggfuncs.h"

/* C */
#include <assert.h>
/* PostgreSQL */
#include <postgres.h>
#include <utils/timestamp.h>
/* MEOS */
#include <meos.h>
#include <meos_internal.h>
#include "general/set.h"
#include "general/skiplist.h"
#include "general/span.h"
#include "general/tbool_boolops.h"
#include "general/tbox.h"
/* MobilityDB */
#include "pg_general/meos_catalog.h"
#include "pg_general/skiplist.h"

/*****************************************************************************
 * Generic aggregate functions for TInstant and TSequence
 *****************************************************************************/

/**
 * @brief Generic transition function for aggregating temporal values
 * @param[in] fcinfo Catalog information about the external function
 * @param[in] func Aggregate function
 * @param[in] crossings True if turning points are added in the segments
 */
static Datum
Temporal_tagg_transfn(FunctionCallInfo fcinfo, datum_func2 func,
  bool crossings)
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  Temporal *temp = PG_GETARG_TEMPORAL_P(1);
  store_fcinfo(fcinfo);
  SkipList *result = temporal_tagg_transfn(state, temp, func, crossings);
  PG_FREE_IF_COPY(temp, 1);
  PG_RETURN_TEMPORAL_P(result);
}

/**
 * @brief Generic combine function for aggregating temporal values
 * @param[in] fcinfo Catalog information about the external function
 * @param[in] func Function
 * @param[in] crossings True if turning points are added in the segments
 */
static Datum
Temporal_tagg_combinefn(FunctionCallInfo fcinfo, datum_func2 func,
  bool crossings)
{
  SkipList *state1, *state2;
  INPUT_AGG_COMB_STATE(fcinfo, state1, state2);
  store_fcinfo(fcinfo);
  PG_RETURN_SKIPLIST_P(temporal_tagg_combinefn(state1, state2, func,
    crossings));
}

PGDLLEXPORT Datum Temporal_tagg_finalfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_tagg_finalfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Generic final function for temporal aggregation
 * @sqlfn tCount(), merge(), ...
 */
Datum
Temporal_tagg_finalfn(PG_FUNCTION_ARGS)
{
  MemoryContext ctx = set_aggregation_context(fcinfo);
  SkipList *state = (SkipList *) PG_GETARG_POINTER(0);
  unset_aggregation_context(ctx);
  Temporal *result = temporal_tagg_finalfn(state);
  if (! result)
    PG_RETURN_NULL();
  PG_RETURN_TEMPORAL_P(result);
}

/*****************************************************************************/

/**
 * @brief Transition function for aggregating temporal values that require a
 * transformation of each composing instant/sequence
 * @param[in] fcinfo Catalog information about the external function
 * @param[in] func Aggregate function
 * @param[in] crossings True if turning points are added in the segments
 * @param[in] transform Transform function
 */
Datum
Temporal_tagg_transform_transfn(FunctionCallInfo fcinfo, datum_func2 func,
  bool crossings, TInstant *(*transform)(const TInstant *))
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  Temporal *temp = PG_GETARG_TEMPORAL_P(1);
  store_fcinfo(fcinfo);
  state = temporal_tagg_transform_transfn(state, temp, func, crossings,
    transform);
  PG_FREE_IF_COPY(temp, 1);
  PG_RETURN_SKIPLIST_P(state);
}

/*****************************************************************************
 * Temporal count
 *****************************************************************************/

PGDLLEXPORT Datum Timestamptz_tcount_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Timestamptz_tcount_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal count aggregate of timestamptz values
 * @sqlfn tCount()
 */
Datum
Timestamptz_tcount_transfn(PG_FUNCTION_ARGS)
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  TimestampTz t = PG_GETARG_TIMESTAMPTZ(1);
  store_fcinfo(fcinfo);
  PG_RETURN_SKIPLIST_P(timestamptz_tcount_transfn(state, t));
}

PGDLLEXPORT Datum Tstzset_tcount_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tstzset_tcount_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal count aggregate of timestamptz sets
 * @sqlfn tCount()
 */
Datum
Tstzset_tcount_transfn(PG_FUNCTION_ARGS)
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  Set *s = PG_GETARG_SET_P(1);
  store_fcinfo(fcinfo);
  state = tstzset_tcount_transfn(state, s);
  PG_FREE_IF_COPY(s, 1);
  PG_RETURN_SKIPLIST_P(state);
}

PGDLLEXPORT Datum Tstzspan_tcount_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tstzspan_tcount_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal count aggregate of timestamptz spans
 * @sqlfn tCount()
 */
Datum
Tstzspan_tcount_transfn(PG_FUNCTION_ARGS)
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  Span *s = PG_GETARG_SPAN_P(1);
  store_fcinfo(fcinfo);
  PG_RETURN_SKIPLIST_P(tstzspan_tcount_transfn(state, s));
}

PGDLLEXPORT Datum Tstzspanset_tcount_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tstzspanset_tcount_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal count aggregate of timestamptz span
 * sets
 * @sqlfn tCount()
 */
Datum
Tstzspanset_tcount_transfn(PG_FUNCTION_ARGS)
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  SpanSet *ss = PG_GETARG_SPANSET_P(1);
  store_fcinfo(fcinfo);
  state = tstzspanset_tcount_transfn(state, ss);
  PG_FREE_IF_COPY(ss, 1);
  PG_RETURN_SKIPLIST_P(state);
}

/*****************************************************************************/

PGDLLEXPORT Datum Temporal_tcount_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_tcount_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal count aggregation of temporal values
 * @sqlfn tCount()
 */
Datum
Temporal_tcount_transfn(PG_FUNCTION_ARGS)
{
  SkipList *state;
  INPUT_AGG_TRANS_STATE(fcinfo, state);
  Temporal *temp = PG_GETARG_TEMPORAL_P(1);
  store_fcinfo(fcinfo);
  state = temporal_tcount_transfn(state, temp);
  PG_FREE_IF_COPY(temp, 1);
  PG_RETURN_SKIPLIST_P(state);
}

PGDLLEXPORT Datum Temporal_tcount_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_tcount_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal count aggregation of temporal values
 * @sqlfn tCount()
 */
Datum
Temporal_tcount_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_sum_int32, false);
}

/*****************************************************************************
 * Temporal extent
 *****************************************************************************/

PGDLLEXPORT Datum Temporal_extent_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_extent_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for extent aggregation of temporal booleans and
 * temporal texts
 * @sqlfn extent()
 */
Datum
Temporal_extent_transfn(PG_FUNCTION_ARGS)
{
  Span *s = PG_ARGISNULL(0) ? NULL : PG_GETARG_SPAN_P(0);
  Temporal *temp = PG_ARGISNULL(1) ? NULL : PG_GETARG_TEMPORAL_P(1);
  Span *result = temporal_extent_transfn(s, temp);
  PG_FREE_IF_COPY(temp, 1);
  if (! result)
    PG_RETURN_NULL();
  PG_RETURN_SPAN_P(result);
}

/*****************************************************************************/

PGDLLEXPORT Datum Tnumber_extent_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tnumber_extent_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for extent aggregation for temporal numbers
 * @sqlfn extent()
 */
Datum
Tnumber_extent_transfn(PG_FUNCTION_ARGS)
{
  TBox *box = PG_ARGISNULL(0) ? NULL : PG_GETARG_TBOX_P(0);
  Temporal *temp = PG_ARGISNULL(1) ? NULL : PG_GETARG_TEMPORAL_P(1);
  TBox *result = tnumber_extent_transfn(box, temp);
  PG_FREE_IF_COPY(temp, 1);
  if (! result)
    PG_RETURN_NULL();
  PG_RETURN_TBOX_P(result);
}

/*****************************************************************************
 * Temporal boolean functions
 *****************************************************************************/

PGDLLEXPORT Datum Tbool_tand_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tbool_tand_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal and aggregation of temporal booleans
 * @sqlfn tAnd()
 */
Datum
Tbool_tand_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_and, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tbool_tand_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tbool_tand_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal and aggregation of temporal booleans
 * @sqlfn tAnd()
 */
Datum
Tbool_tand_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_and, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tbool_tor_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tbool_tor_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal or aggregation of temporal booleans
 * @sqlfn tOr()
 */
Datum
Tbool_tor_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_or, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tbool_tor_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tbool_tor_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal or aggregation of temporal booleans
 * @sqlfn tOr()
 */
Datum
Tbool_tor_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_or, CROSSINGS_NO);
}

/*****************************************************************************/

PGDLLEXPORT Datum Tint_tmin_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tint_tmin_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal minimum aggregation of temporal
 * integers
 * @sqlfn tMin()
 */
Datum
Tint_tmin_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_min_int32, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tint_tmin_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tint_tmin_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal minimum aggregation of temporal
 * integers
 * @sqlfn tMin()
 */
Datum
Tint_tmin_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_min_int32, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tfloat_tmin_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tfloat_tmin_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal minimum aggregation of temporal
 * floats
 * @sqlfn tMin()
 */
Datum
Tfloat_tmin_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_min_float8, CROSSINGS);
}

PGDLLEXPORT Datum Tfloat_tmin_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tfloat_tmin_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal minimum aggregation of temporal floats
 * @sqlfn tMin()
 */
Datum
Tfloat_tmin_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_min_float8, CROSSINGS);
}

PGDLLEXPORT Datum Tint_tmax_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tint_tmax_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal maximum aggregation of temporal
 * integers
 * @sqlfn tMax()
 */
Datum
Tint_tmax_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_max_int32, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tint_tmax_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tint_tmax_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal maximum aggregation of temporal
 * integers
 * @sqlfn tMax()
 */
Datum
Tint_tmax_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_max_int32, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tfloat_tmax_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tfloat_tmax_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal maximum aggregation of temporal
 * floats
 * @sqlfn tMax()
 */
Datum
Tfloat_tmax_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_max_float8, CROSSINGS);
}

PGDLLEXPORT Datum Tfloat_tmax_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tfloat_tmax_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal maximum aggregation of temporal floats
 * values
 * @sqlfn tMax()
 */
Datum
Tfloat_tmax_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_max_float8, CROSSINGS);
}

PGDLLEXPORT Datum Tint_tsum_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tint_tsum_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal sum aggregation of temporal integers
 * @sqlfn tSum()
 */
Datum
Tint_tsum_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_sum_int32, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tint_tsum_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tint_tsum_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal sum aggregation of temporal integers
 * @sqlfn tSum()
 */
Datum
Tint_tsum_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_sum_int32, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tfloat_tsum_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tfloat_tsum_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal sum aggregation of temporal floats
 * @sqlfn tSum()
 */
Datum
Tfloat_tsum_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_sum_float8, CROSSINGS_NO);
}

PGDLLEXPORT Datum Tfloat_tsum_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tfloat_tsum_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal sum aggregation of temporal floats
 * @sqlfn tSum()
 */
Datum
Tfloat_tsum_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_sum_float8, CROSSINGS_NO);
}

/*****************************************************************************/

PGDLLEXPORT Datum Ttext_tmin_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Ttext_tmin_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal minimum aggregation of temporal texts
 * @sqlfn tMin()
 */
Datum
Ttext_tmin_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_min_text, CROSSINGS_NO);
}

PGDLLEXPORT Datum Ttext_tmin_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Ttext_tmin_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal minimum aggregation of temporal texts
 * @sqlfn tMin()
 */
Datum
Ttext_tmin_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_min_text, CROSSINGS_NO);
}

PGDLLEXPORT Datum Ttext_tmax_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Ttext_tmax_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal maximum aggregation of temporal texts
 * @sqlfn tMax()
 */
Datum
Ttext_tmax_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, &datum_max_text, CROSSINGS_NO);
}

PGDLLEXPORT Datum Ttext_tmax_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Ttext_tmax_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal maximum aggregation of temporal texts
 * @sqlfn tMax()
 */
Datum
Ttext_tmax_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_max_text, CROSSINGS_NO);
}

/*****************************************************************************
 * Temporal average
 *****************************************************************************/

PGDLLEXPORT Datum Tnumber_tavg_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tnumber_tavg_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for temporal average aggregation of temporal
 * numbers
 * @sqlfn tAvg()
 */
Datum
Tnumber_tavg_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transform_transfn(fcinfo, &datum_sum_double2,
    CROSSINGS_NO, &tnumberinst_transform_tavg);
}

PGDLLEXPORT Datum Tnumber_tavg_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tnumber_tavg_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for temporal average aggregation of temporal
 * numbers
 * @sqlfn tAvg()
 */
Datum
Tnumber_tavg_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, &datum_sum_double2, false);
}

PGDLLEXPORT Datum Tnumber_tavg_finalfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Tnumber_tavg_finalfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Final function for temporal average aggregation of temporal
 * numbers
 * @sqlfn tAvg()
 */
Datum
Tnumber_tavg_finalfn(PG_FUNCTION_ARGS)
{
  SkipList *state = (SkipList *) PG_GETARG_POINTER(0);
  Temporal *result = tnumber_tavg_finalfn(state);
  if (! result)
    PG_RETURN_NULL();
  PG_RETURN_TEMPORAL_P(result);
}

/*****************************************************************************/

PGDLLEXPORT Datum Temporal_merge_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_merge_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for merge aggregate of temporal values
 * @sqlfn merge()
 */
Datum
Temporal_merge_transfn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_transfn(fcinfo, NULL, CROSSINGS_NO);
}

PGDLLEXPORT Datum Temporal_merge_combinefn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_merge_combinefn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Combine function for merge aggregate of temporal values
 * @sqlfn merge()
 */
Datum
Temporal_merge_combinefn(PG_FUNCTION_ARGS)
{
  return Temporal_tagg_combinefn(fcinfo, NULL, CROSSINGS_NO);
}

/*****************************************************************************
 * Append aggregate functions
 *****************************************************************************/

PGDLLEXPORT Datum Temporal_app_tinst_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_app_tinst_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for append temporal instant aggregate
 * @sqlfn appendInstant()
 */
Datum
Temporal_app_tinst_transfn(PG_FUNCTION_ARGS)
{
  MemoryContext ctx = set_aggregation_context(fcinfo);
  Temporal *state = PG_ARGISNULL(0) ? NULL : PG_GETARG_TEMPORAL_P(0);
  if (PG_ARGISNULL(1))
  {
    if (state)
      PG_RETURN_TEMPORAL_P(state);
    else
      PG_RETURN_NULL();
  }
  Temporal *inst = PG_GETARG_TEMPORAL_P(1);
  unset_aggregation_context(ctx);
  /* Store fcinfo into a global variable */
  store_fcinfo(fcinfo);

  /* Get interpolation */
  interpType interp;
  if (PG_NARGS() == 2 || PG_ARGISNULL(2))
  {
    /* Set default interpolation according to the base type */
    meosType temptype = oid_type(get_fn_expr_argtype(fcinfo->flinfo, 1));
    interp = temptype_continuous(temptype) ? LINEAR : STEP;
  }
  else
  {
    /* Input interpolation */
    text *interp_txt = PG_GETARG_TEXT_P(2);
    char *interp_str = text2cstring(interp_txt);    
    interp = interptype_from_string(interp_str);
    pfree(interp_str);
  }

  /* Take into account the arguments for the gaps */
  double maxdist = -1.0;
  Interval *maxt = NULL;
  if (PG_NARGS() > 3)
  {
    /* Get the maxt and maxdist for the gaps if they are given */
    if (PG_NARGS() == 4)
    {
      if (! PG_ARGISNULL(3))
        maxt = PG_GETARG_INTERVAL_P(3);
    }
    else /* PG_NARGS() == 5 */
    {
      if (! PG_ARGISNULL(3))
        maxdist = PG_GETARG_FLOAT8(3);
      if (! PG_ARGISNULL(4))
        maxt = PG_GETARG_INTERVAL_P(4);
    }
  }

  state = temporal_app_tinst_transfn(state, (TInstant *) inst, interp, 
    maxdist, maxt);
  PG_FREE_IF_COPY(inst, 1);
  PG_RETURN_TEMPORAL_P(state);
}

PGDLLEXPORT Datum Temporal_app_tseq_transfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_app_tseq_transfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Transition function for append temporal sequence aggregate
 * @sqlfn appendSequence()
 */
Datum
Temporal_app_tseq_transfn(PG_FUNCTION_ARGS)
{
  MemoryContext ctx = set_aggregation_context(fcinfo);
  Temporal *state = PG_ARGISNULL(0) ? NULL : PG_GETARG_TEMPORAL_P(0);
  if (PG_ARGISNULL(1))
  {
    if (state)
      PG_RETURN_TEMPORAL_P(state);
    else
      PG_RETURN_NULL();
  }
  unset_aggregation_context(ctx);
  Temporal *seq = PG_GETARG_TEMPORAL_P(1);
  /* Store fcinfo into a global variable */
  store_fcinfo(fcinfo);
  state = temporal_app_tseq_transfn(state, (TSequence *) seq);
  PG_FREE_IF_COPY(seq, 1);
  PG_RETURN_TEMPORAL_P(state);
}

PGDLLEXPORT Datum Temporal_append_finalfn(PG_FUNCTION_ARGS);
PG_FUNCTION_INFO_V1(Temporal_append_finalfn);
/**
 * @ingroup mobilitydb_temporal_agg
 * @brief Final function for append temporal instant/sequence aggregate
 * @sqlfn appendInstant(), appendSequence()
 */
Datum
Temporal_append_finalfn(PG_FUNCTION_ARGS)
{
  MemoryContext ctx = set_aggregation_context(fcinfo);
  Temporal *state = PG_GETARG_TEMPORAL_P(0);
  unset_aggregation_context(ctx);
  Temporal *result = temporal_compact(state);
  if (! result)
    PG_RETURN_NULL();
  PG_RETURN_TEMPORAL_P(result);
}

/*****************************************************************************/

estebanzimanyi / MobilityDB / 13100369341

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous