Skip to content

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: