transform_pipeline.hpp File Reference

#include "pipeline_types.hpp"
#include "charts/chart_spec.hpp"
#include <istream>
#include <ostream>
#include <string>
#include <vector>
#include "postgres/postgres_connection.hpp"

Go to the source code of this file.

Namespaces
namespace	csvzall
namespace	csvzall::pipeline

Enumerations
enum class	csvzall::pipeline::SqlQueryInputKind { csvzall::pipeline::kCsv , csvzall::pipeline::kSqlite , csvzall::pipeline::kUnknown }

Functions
int	csvzall::pipeline::RunDerive (const std::string &assignment, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunFilter (const std::string &expression, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunSummarize (const std::string &group_by_column, const std::string &max_column, const std::vector< std::string > &show_columns, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunTimeseries (const std::string &x_column, const std::string &y_column, const std::string &series_column, const std::string &reduce, const std::string &format, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunJsonExtract (const std::string &input_path, const std::string &mapping_path, std::ostream &output, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunMax (const std::string &column, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunMin (const std::string &column, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunAppend (const std::string &existing_path, const std::string &incoming_path, bool in_place, std::ostream &output, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunMerge (const std::string &existing_path, const std::string &incoming_path, const std::string &key_column, bool in_place, std::ostream &output, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunView (const std::string &input_path, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats, int requested_port, bool open_browser, bool serve_once, bool startup_json)
int	csvzall::pipeline::RunHeatmap (const std::string &date_column, const std::string &value_column, const std::string &label_column, const std::string &start_date, const std::string &end_date, const std::string &title, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunHeatmap (const common::HeatmapSpec &spec, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunCharts (const std::string &config_path, const std::string &chart_id, bool validate_only, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunSqlExport (const std::string &input_path, const std::string &dest_path, const std::string &table_name, std::istream &input, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
int	csvzall::pipeline::RunSqlQueryCsv (const std::string &sql_query, const std::string &table_name, const std::string &format, std::istream &input, std::ostream &output, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats)
SqlQueryInputKind	csvzall::pipeline::DetectSqlQueryInputKind (const std::string &path)
int	csvzall::pipeline::RunSqlQueryDb (const std::string &sql_query, const std::string &db_path, const std::string &format, std::ostream &output, const LoggerCallbacks &logger, RunStats &stats)
bool	csvzall::pipeline::ShouldWarnIntegerDivision (const std::string &sql_query)
int	csvzall::pipeline::RunPostgresExport (std::istream &input, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats, const ::csvzall::postgres::ConnectionConfig &pg_config, const std::string &table_name, const std::string &if_exists_mode)
int	csvzall::pipeline::RunPostgresInfer (std::istream &input, const RunOptions &options, const LoggerCallbacks &logger, RunStats &stats, const std::string &table_name)