Modules§
Macros§
- yaml_
map_ get_ str - Macro to extract a string value from a YAML map
Structs§
- Array
- Auto
Transform Output - Context
Req - Dispatched
To - Where the pipeline executed is dispatched to, with context information
- Greptime
Pipeline Params - Parameters that can be used to configure the greptime pipelines.
- Greptime
Transformer - fields not in the columns will be discarded to prevent automatic column creation in GreptimeDB
- Map
- Pipeline
- Pipeline
Context - Schema
Info - This is used to record the current state schema information and a sequential cache of field names. As you traverse the user input JSON, this will change. It will record a superset of all user input schemas.
- Select
Info - SelectInfo is used to store the selected keys from OpenTelemetry record attrs The key is used to uplift value from the attributes and serve as column name in the table
- Transformed
Output
Enums§
- Content
- Identity
Time Index - Pipeline
Definition - Enum for holding information of a pipeline, which is either pipeline itself,
or information that be used to retrieve a pipeline from
PipelineHandler - Pipeline
Exec Output - The result of pipeline execution
- Pipeline
Way - Value
- Value can be used as type acts as value: the enclosed value is the actual value acts as type: the enclosed value is the default value
Constants§
Traits§
- Processor
- Processor trait defines the interface for all processors.
Functions§
- from_
pipeline_ map_ to_ opt - identity_
pipeline - Identity pipeline for Greptime This pipeline will convert the input JSON array to Greptime Rows params table is used to set the semantic type of the row key column to Tag
- json_
array_ to_ map - json_
to_ map - parse
- simd_
json_ array_ to_ map - simd_
json_ to_ map
Type Aliases§
- Pipeline
Info - Pipeline info. A tuple of timestamp and pipeline reference.
- Pipeline
Map - Pipeline
Ref - Pipeline
Table Ref - Pipeline
Version - Pipeline version. An optional timestamp with nanosecond precision.