X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=src%2Fdata%2Fcasereader.h;h=8f80c30ca0799033499b0f71a9716065fb9f0908;hb=81579d9e9f994fb2908f50af41c3eb033d216e58;hp=d4a1cce5188a7a467569cbceb95ec9f30a1db402;hpb=0553d00dca10c2d2beeffd88fd12120e43a01025;p=pspp-builds.git diff --git a/src/data/casereader.h b/src/data/casereader.h index d4a1cce5..8f80c30c 100644 --- a/src/data/casereader.h +++ b/src/data/casereader.h @@ -1,5 +1,5 @@ /* PSPP - a program for statistical analysis. - Copyright (C) 2007 Free Software Foundation, Inc. + Copyright (C) 2007, 2009, 2011 Free Software Foundation, Inc. This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -51,15 +51,16 @@ #ifndef DATA_CASEREADER_H #define DATA_CASEREADER_H 1 -#include -#include -#include +#include "libpspp/compiler.h" +#include "data/case.h" +#include "data/missing-values.h" struct dictionary; struct casereader; struct casewriter; +struct subcase; -bool casereader_read (struct casereader *, struct ccase *); +struct ccase *casereader_read (struct casereader *); bool casereader_destroy (struct casereader *); struct casereader *casereader_clone (const struct casereader *); @@ -68,19 +69,23 @@ void casereader_split (struct casereader *, struct casereader *casereader_rename (struct casereader *); void casereader_swap (struct casereader *, struct casereader *); -bool casereader_peek (struct casereader *, casenumber, struct ccase *) - WARN_UNUSED_RESULT; +struct ccase *casereader_peek (struct casereader *, casenumber); +bool casereader_is_empty (struct casereader *); bool casereader_error (const struct casereader *); void casereader_force_error (struct casereader *); const struct taint *casereader_get_taint (const struct casereader *); casenumber casereader_get_case_cnt (struct casereader *); -casenumber casereader_count_cases (struct casereader *); -size_t casereader_get_value_cnt (struct casereader *); +casenumber casereader_count_cases (const struct casereader *); +void casereader_truncate (struct casereader *, casenumber); +const struct caseproto *casereader_get_proto (const struct casereader *); +casenumber casereader_advance (struct casereader *, casenumber); void casereader_transfer (struct casereader *, struct casewriter *); +struct casereader *casereader_create_empty (const struct caseproto *); + struct casereader * casereader_create_filter_func (struct casereader *, bool (*include) (const struct ccase *, @@ -95,8 +100,9 @@ casereader_create_filter_weight (struct casereader *, struct casewriter *exclude); struct casereader * casereader_create_filter_missing (struct casereader *, - const struct variable **vars, size_t var_cnt, + const struct variable *const*vars, size_t var_cnt, enum mv_class, + casenumber *n_missing, struct casewriter *exclude); struct casereader * @@ -104,11 +110,61 @@ casereader_create_counter (struct casereader *, casenumber *counter, casenumber initial_value); struct casereader * -casereader_create_translator (struct casereader *, size_t output_value_cnt, - void (*translate) (struct ccase *input, - struct ccase *output, - void *aux), +casereader_create_translator (struct casereader *, + const struct caseproto *output_proto, + struct ccase *(*translate) (struct ccase *, + void *aux), bool (*destroy) (void *aux), void *aux); +struct casereader * +casereader_translate_stateless (struct casereader *, + const struct caseproto *output_proto, + struct ccase *(*translate) (struct ccase *, + casenumber idx, + const void *aux), + bool (*destroy) (void *aux), + void *aux); + +struct casereader *casereader_project (struct casereader *, + const struct subcase *); +struct casereader *casereader_project_1 (struct casereader *, int column); +struct casereader *casereader_select (struct casereader *, + casenumber first, casenumber last, + casenumber by); + +/* A function which creates a numberic value from an existing case */ +typedef double new_value_func (const struct ccase *, casenumber, void *); + +struct casereader * +casereader_create_append_numeric (struct casereader *subreader, + new_value_func func, void *aux, + void (*destroy) (void *aux)); + +struct casereader * +casereader_create_arithmetic_sequence (struct casereader *, + double first, double increment); + +enum rank_error + { + RANK_ERR_NONE = 0, + RANK_ERR_NEGATIVE_WEIGHT = 0x01, + RANK_ERR_UNSORTED = 0x02 + }; + + +typedef void distinct_func (double v, casenumber n, double w, void *aux); + +struct casereader * +casereader_create_append_rank (struct casereader *, + const struct variable *v, const struct variable *w, + enum rank_error *err, + distinct_func *distinct_callback, void *aux); + +struct casereader * +casereader_create_distinct (struct casereader *input, + const struct variable *key, + const struct variable *weight); + + #endif /* data/casereader.h */