feldera_types/preprocess.rs
1//! Configuration describing a preprocessor
2
3use serde::{Deserialize, Serialize};
4use serde_json::Value;
5
6/// Configuration for describing a preprocessor
7#[derive(Debug, Deserialize, Clone, Eq, PartialEq, Serialize)]
8pub struct PreprocessorConfig {
9 /// Name of the preprocessor.
10 /// All preprocessors with the same name will perform the same task.
11 pub name: String,
12 /// True if the preprocessor is message-oriented: true if each preprocessor
13 /// output record corresponds to a whole number of of parser records.
14 pub message_oriented: bool,
15 /// Arbitrary additional configuration.
16 pub config: Value,
17}