Namespace Wolfgang.Etl.Json
Classes
- EtlPipelineJsonSinkExtensions
Class-named JSON sink terminators for the fluent Wolfgang.Etl.Abstractions.EtlPipeline chain. Each terminator constructs the matching loader and terminates the pipeline, enabling
… .JsonLineLoader<Person>("people.jsonl").
- EtlPipelineJsonSourceExtensions
Class-named JSON source factories for the fluent Wolfgang.Etl.Abstractions.EtlPipeline chain. Each factory constructs the matching extractor and seeds the pipeline, enabling
EtlPipeline.Create().JsonLineExtractor<Person>("people.jsonl").
- JsonLineExtractor<TRecord>
Extracts items of type
TRecordfrom a JSONL (JSON Lines / NDJSON) stream.
- JsonLineLoader<TRecord>
Loads items of type
TRecordinto a JSONL (JSON Lines / NDJSON) stream.
- JsonMultiStreamExtractor<TRecord>
Extracts items of type
TRecordfrom multiple streams, reading one JSON object per stream.
- JsonMultiStreamLoader<TRecord>
Loads items of type
TRecordinto multiple streams, writing one JSON object per stream.
- JsonNamedDestination
Associates a Stream with an optional human-readable name for progress reporting.
- JsonNamedStream
Associates a Stream with an optional human-readable name for progress reporting.
- JsonReport
Progress report for JSON extraction and loading operations.
- JsonSingleStreamExtractor<TRecord>
Extracts items of type
TRecordfrom a single JSON array stream.
- JsonSingleStreamLoader<TRecord>
Loads items of type
TRecordinto a single JSON array stream.