Financial_Statement_Reader
Reads _financial_statements.json files from dataset/*/Financial Statement Data/. Extracts income_statement, balance_sheet, cashflow via JSON Path -> JSON to Table -> Ungroup. Concatenates the 3 branches, derives sector/source_file from path, parses period_end, sets ticker and load_batch_id from flow vars, casts metric_value to Double, filters to 8 columns and appends into stg.stg_financial_statements.
Reads _financial_statements.json files from dataset/*/Financial Statement Data/. Extracts income_statement, balance_sheet, cashflow via JSON Path -> JSON to Table -> Ungroup. Concatenates the 3 branches, derives sector/source_file from path, parses period_end, sets ticker and load_batch_id from flow vars, casts metric_value to Double, filters to 8 columns and appends into stg.stg_financial_statements.
Nodes
- Expression3 ×
- Column Filter1 ×
- Column Renamer1 ×
- DB SQL Executor (Labs)1 ×
- DB Writer1 ×
- GroupBy1 ×
- JSON Path1 ×
- Line Reader1 ×
- List Files/Folders1 ×
- Loop End1 ×
- Path to String1 ×
- PostgreSQL Connector1 ×
- String Replacer1 ×
- String to Date&Time1 ×
- String to JSON1 ×
- Table Row to Variable Loop Start1 ×
- Ungroup1 ×
Extensions
Links
- No links available