Crate pipeline

source ·

Modules§

Structs§

Enums§

  • 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

Traits§

  • Processor trait defines the interface for all processors A processor is a transformation that can be applied to a field in a document It can be used to extract, transform, or enrich data Now Processor only have one input field. In the future, we may support multiple input fields. The output of a processor is a map of key-value pairs that will be merged into the document when you use exec_map method.

Functions§

  • Identity pipeline for Greptime This pipeline will convert the input JSON array to Greptime Rows

Type Aliases§

  • Pipeline info. A tuple of timestamp and pipeline reference.
  • Pipeline version. An optional timestamp with nanosecond precision. If the version is None, it means the latest version of the pipeline. User can specify the version by providing a timestamp string formatted as iso8601. When it used in cache key, it will be converted to i64 meaning the number of nanoseconds since the epoch.