FlowFunction¶
FlowFunction is an abstraction of transformation functions that define flows.
FlowFunction is created when FlowAnalysis is requested to createFlowFunctionFromLogicalPlan.
Contract¶
call¶
call(
allInputs: Set[TableIdentifier],
availableInputs: Seq[Input],
configuration: Map[String, String],
queryContext: QueryContext,
queryOrigin: QueryOrigin): FlowFunctionResult
Transformation that yields a FlowFunctionResult (with the data, if successful)
Used when:
FlowResolveris requested to attemptResolveFlow