Struct FlowNodeToJson 

pub struct FlowNodeToJson { /* private fields */ }

Implementations

impl FlowNodeToJson

pub fn new() -> Self

Trait Implementations

impl Default for FlowNodeToJson

fn default() -> Self

Returns the “default value” for a type.

impl Function for FlowNodeToJson

fn kinds(&self) -> &[FunctionKind]

The execution shapes this function supports (Scalar, Aggregate, Generator). Required: every function declares at least one kind.

fn accumulator( &self, _ctx: &mut FunctionContext<'_>, ) -> Option<Box<dyn Accumulator>>

Aggregate accumulator factory. Only functions whose kinds() includes FunctionKind::Aggregate need to override this.

impl<'a> Routine<FunctionContext<'a>> for FlowNodeToJson

fn info(&self) -> &RoutineInfo

fn return_type(&self, _input_types: &[Type]) -> Type

fn execute( &self, ctx: &mut FunctionContext<'a>, args: &Columns, ) -> Result<Columns, RoutineError>

Execute the routine.

fn accepted_types(&self) -> InputTypes

fn propagates_options(&self) -> bool

fn call(&self, ctx: &mut C, args: &Columns) -> Result<Columns, RoutineError>

Calls the routine, automatically propagating Option columns if propagates_options() returns true. The option-propagation behaviour is identical for both contexts, hence the shared default.