Module transform 

Record transformation pipeline.

Built-in transforms (optional Cargo features)

Variant	Feature flag	Default
RecordTransform::Flatten	transform-flatten	enabled
RecordTransform::RenameKeys	transform-rename-keys	enabled
RecordTransform::KeysToSnakeCase	transform-snake-case	enabled

Disable a transform (and its dependencies) by opting out of its feature:

[dependencies]
faucet-stream = { version = "*", default-features = false,
                  features = ["transform-flatten"] }

Custom transforms

RecordTransform::Custom is always available regardless of features. Pass any closure or function pointer via RecordTransform::custom.

Enums

CompiledTransform

Pre-compiled form of a RecordTransform.

RecordTransform

A transformation applied to every record fetched by a [crate::stream::RestStream].

Functions

apply_all

Apply a slice of pre-compiled transforms to a record, in order.

compile

Compile a RecordTransform into its CompiledTransform form.

to_snake_case

Convert a single key string to snake_case (mirrors Meltano’s algorithm).