reifydb_engine/flow/compiler/primitive/
inline_data.rs1use reifydb_core::interface::catalog::flow::FlowNodeId;
5use reifydb_rql::{flow::node::FlowNodeType, nodes::InlineDataNode};
6use reifydb_transaction::transaction::Transaction;
7use reifydb_type::Result;
8
9use crate::flow::compiler::{CompileOperator, FlowCompiler};
10
11pub(crate) struct InlineDataCompiler {
12 pub _inline_data: InlineDataNode,
13}
14
15impl From<InlineDataNode> for InlineDataCompiler {
16 fn from(inline_data: InlineDataNode) -> Self {
17 Self {
18 _inline_data: inline_data,
19 }
20 }
21}
22
23impl CompileOperator for InlineDataCompiler {
24 fn compile(self, compiler: &mut FlowCompiler, txn: &mut Transaction<'_>) -> Result<FlowNodeId> {
25 compiler.add_node(txn, FlowNodeType::SourceInlineData {})
26 }
27}