Safe Haskell | None |
---|---|
Language | GHC2021 |
Synopsis
- data CSVTableStrategy
- type SpecProgramForYaml b = SpecProgramReferenceForYaml (SpecProgram b)
- newtype YamlRange a = YamlRange {}
- type BackendMetaConstraints b = (MaybeDefault (YamlBackendTableMeta b), MaybeDefault (YamlBackendViewMeta b), MaybeDefault (YamlBackendMaterializedViewMeta b), FromJSON (YamlBackendTableMeta b), FromJSON (YamlBackendViewMeta b), FromJSON (YamlBackendMaterializedViewMeta b), CSVImport b)
- parseTargetType :: BackendMetaConstraints b => Value -> WarningParser (SpecTarget b)
- external :: SpecProgramForYaml b
- sql_query :: BackendMetaConstraints b => SpecProgramForYaml b
- sql_query_with_schema :: Default (BackendTableMeta b) => SpecProgramForYaml b
- sql_file :: BackendMetaConstraints b => SpecProgramForYaml b
- sql_file_with_schema :: Default (BackendTableMeta b) => SpecProgramForYaml b
- sql_file_insert :: Default (BackendTableMeta b) => SpecProgramForYaml b
- sql_file_with_schema_insert :: Default (BackendTableMeta b) => SpecProgramForYaml b
- csv_file :: (BackendMetaConstraints b, Default (BackendTableMeta b)) => SpecProgramForYaml b
- csv_file_bq :: (Typeable b, BackendMetaConstraints b, Default (BackendTableMeta b)) => SpecProgramForYaml b
- copy :: BackendMetaConstraints b => SpecProgramForYaml b
- incremental_by_pk :: (BackendMetaConstraints b, Default (BackendTableMeta b), SqlConcat b) => SpecProgramForYaml b
- incremental_by_time :: (BackendMetaConstraints b, Default (BackendTableMeta b)) => SpecProgramForYaml b
- long_to_wide :: BackendMetaConstraints b => SpecProgramForYaml b
Documentation
data CSVTableStrategy #
csv importing options
Instances
type SpecProgramForYaml b = SpecProgramReferenceForYaml (SpecProgram b) #
type BackendMetaConstraints b = (MaybeDefault (YamlBackendTableMeta b), MaybeDefault (YamlBackendViewMeta b), MaybeDefault (YamlBackendMaterializedViewMeta b), FromJSON (YamlBackendTableMeta b), FromJSON (YamlBackendViewMeta b), FromJSON (YamlBackendMaterializedViewMeta b), CSVImport b) #
parseTargetType :: BackendMetaConstraints b => Value -> WarningParser (SpecTarget b) #
external :: SpecProgramForYaml b #
Define table with external shell script or command with arguments
external: shell: ./import_table.sh --from "{{{db_url}}}" --table "{{{table.db}}}"
or > external: > command: ./import_table.sh > arguments: > - --from "{{{db_url}}}" > - --table "{{{table.db}}}"
sql_query :: BackendMetaConstraints b => SpecProgramForYaml b #
Define table with SQL query specified directly in YAML
sql_query: query: SELECT * FROM foo
sql_query_with_schema :: Default (BackendTableMeta b) => SpecProgramForYaml b #
sql_file :: BackendMetaConstraints b => SpecProgramForYaml b #
Define table with SQL query specified directly in YAML.
vars
is an optional object used to specify variables used in mustache interpolation.
sql_file: source: some_file.sql vars: agg: sum
sql_file_with_schema :: Default (BackendTableMeta b) => SpecProgramForYaml b #
Define table with Explicit DDL to create schema and (optionally) SQL Insert Statements to add data, with ExtendedStatement specified directly in YAML.
vars
is an optional object used to specify variables used in mustache interpolation. The table will always be recreated if update strategy calls for it,
and any existing data on tbale will be lost.
sql_file_with_schema: source: some_file_extended.sql vars: agg: sum
sql_file_insert :: Default (BackendTableMeta b) => SpecProgramForYaml b #
Insert into a table (or create if non-existent) with SQL query specified directly in YAML. The data is appended to the table, and the table is never truncated.
vars
is an optional object used to specify variables used in mustache interpolation.
sql_file_insert: source: some_file.sql vars: agg: sum
sql_file_with_schema_insert :: Default (BackendTableMeta b) => SpecProgramForYaml b #
Insert into a table (or create if non-existent) with explicit DDL to create schema and SQL Insert Statements to add data,
with ExtendedStatement specified directly in YAML. The data is appended to the table, and the table is never truncated.
vars
is an optional object used to specify variables used in mustache interpolation.
sql_file_with_schema_insert: source: some_file.sql vars: agg: sum
csv_file :: (BackendMetaConstraints b, Default (BackendTableMeta b)) => SpecProgramForYaml b #
Create a table from yaml schema specification and load content from a given CSV file.
source
CSV file path
type
can be int, double, text, day, datetime
header
CSV header is present in source file
columns
ordered (as in CSV source file columns) list of column name-type association
create
create table by default is true
chunks
optional chunks size in which source file is loaded
csv_separator
optional character providing the csv separator character (',' by default)
csv_quote_char
optional character providing quotes character ('"' by default)
csv_file: source: input.csv chunks: 50 header: true create: false csv_separator: ',' csv_quote_char: '"' columns: - field1: type1 .. - fieldn: typen
csv_file_bq :: (Typeable b, BackendMetaConstraints b, Default (BackendTableMeta b)) => SpecProgramForYaml b #
copy :: BackendMetaConstraints b => SpecProgramForYaml b #
Copy a table
copy: table: table_to_be_copied if_exists: append
incremental_by_pk :: (BackendMetaConstraints b, Default (BackendTableMeta b), SqlConcat b) => SpecProgramForYaml b #
incremental_by_time :: (BackendMetaConstraints b, Default (BackendTableMeta b)) => SpecProgramForYaml b #