Uses of Interface
net.pricefx.formulaengine.scripting.queryapi.PipelineStage

Packages that use PipelineStage

Package	Description
net.pricefx.formulaengine.optimization
net.pricefx.formulaengine.scripting.queryapi

Uses of PipelineStage in net.pricefx.formulaengine.optimization

Methods in net.pricefx.formulaengine.optimization with parameters of type PipelineStage

Modifier and Type	Method	Description
long	ModelFormulaContextReadWrite.loadTable(DatamartContext.Table table, PipelineStage query, boolean truncate)	Sample code:
long	ModelParallelCalculationFormulaItemContext.loadTable(DatamartContext.Table table, PipelineStage query, boolean truncate)	Sample code:

Uses of PipelineStage in net.pricefx.formulaengine.scripting.queryapi

Methods in net.pricefx.formulaengine.scripting.queryapi that return PipelineStage

Modifier and Type	Method	Description
PipelineStage	PipelineStage.addColumns(Function<Tables.Columns,Collection<? extends Selectable>> expressions)	Adds a stage that adds columns to this stage output.
PipelineStage	PipelineStage.aggregate(Function<Tables.Columns,Collection<? extends Selectable>> selectables)	Adds a stage that aggregates all this stage output rows.
PipelineStage	PipelineStage.aggregateBy(Function<Tables.Columns,Collection<? extends Expression>> by, Function<Tables.Columns,Collection<? extends Selectable>> selectables)	Adds a stage that aggregates the outputs of this stage by a given set of expressions.
PipelineStage	PipelineStage.crossJoin(PipelineStage pipeline, BiFunction<Tables.Columns,Tables.Columns,Collection<? extends Selectable>> selectables)	Adds a crossJoin stage that joins to this PipelineStage another PipelineStage.
PipelineStage	PipelineStage.crossJoin(Tables.Table table, Function<Tables.Columns,Collection<? extends Selectable>> selectables)	Adds a crossJoin stage that joins to this PipelineStage another Tables.Table.
PipelineStage	PipelineStage.distinct()	Adds a stage that removes duplicate rows from this stage output row set.
PipelineStage	PipelineStage.except(PipelineStage rightPipeline)	Adds an except stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.exceptAll(PipelineStage rightPipeline)	Adds an exceptAll stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.filter(Function<Tables.Columns,Expression> condition)	Adds a stage that only keeps this stage output rows which verify the given expression.
PipelineStage	PipelineStage.innerJoin(PipelineStage pipeline, BiFunction<Tables.Columns,Tables.Columns,Collection<? extends Selectable>> selectables, BiFunction<Tables.Columns,Tables.Columns,Expression> joinCriteria)	Adds an innerJoin stage that joins this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.innerJoin(Tables.Table table, Function<Tables.Columns,Collection<? extends Selectable>> selectables, Function<Tables.Columns,Expression> joinCriteria)	Adds an innerJoin stage that joins this PipelineStage to another Tables.Table.
PipelineStage	PipelineStage.intersect(PipelineStage rightPipeline)	Adds an intersect stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.intersectAll(PipelineStage rightPipeline)	Adds an intersectAll stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.leftOuterJoin(PipelineStage pipeline, BiFunction<Tables.Columns,Tables.Columns,Collection<? extends Selectable>> selectables, BiFunction<Tables.Columns,Tables.Columns,Expression> joinCriteria)	Adds a leftOuterJoin stage that joins to this PipelineStage another PipelineStage.
PipelineStage	PipelineStage.leftOuterJoin(Tables.Table table, Function<Tables.Columns,Collection<? extends Selectable>> selectables, Function<Tables.Columns,Expression> joinCriteria)	Adds a leftOuterJoin stage that joins to this PipelineStage another Tables.Table.
PipelineStage	PipelineStage.removeColumns(Function<Tables.Columns,Collection<? extends Selectable>> columns)	Adds a stage that remove the given columns from this stage output.
PipelineStage	PipelineStage.retainColumns(Function<Tables.Columns,Collection<? extends Selectable>> columns)	Deprecated. Use selectColumns(Function) instead.
PipelineStage	PipelineStage.selectColumns(Function<Tables.Columns,Collection<? extends Selectable>> columns)	Adds a stage that keeps and adds the given columns from this stage output.
PipelineStage	PipelineStage.sortBy(Function<Tables.Columns,List<Orders.Order>> orders)	Adds a stage that sorts this stage output rows.
PipelineStage	QueryApi.source(Tables.Table table)	Main entry point to start writing a query.
PipelineStage	QueryApi.source(Tables.Table table, List<? extends Selectable> selectables)	Main entry point to start writing a query.
PipelineStage	QueryApi.source(Tables.Table table, List<? extends Selectable> selectables, Expression filter)	Main entry point to start writing a query.
PipelineStage	QueryApi.source(Tables.Table table, Expression filter)	Main entry point to start writing a query.
PipelineStage	PipelineStage.take(int count)	Adds a stage that only returns the first maxResult rows of this pipeline stage output.
PipelineStage	PipelineStage.traceQuery()	Prints the result of queryString() into the current logic execution trace using PublicGroovyAPI.trace(String, String, Object).
PipelineStage	PipelineStage.union(PipelineStage rightPipeline)	Adds a union stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.unionAll(PipelineStage rightPipeline)	Adds a unionAll stage that combines this PipelineStage to another PipelineStage.

Methods in net.pricefx.formulaengine.scripting.queryapi with parameters of type PipelineStage

Modifier and Type	Method	Description
PipelineStage	PipelineStage.crossJoin(PipelineStage pipeline, BiFunction<Tables.Columns,Tables.Columns,Collection<? extends Selectable>> selectables)	Adds a crossJoin stage that joins to this PipelineStage another PipelineStage.
PipelineStage	PipelineStage.except(PipelineStage rightPipeline)	Adds an except stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.exceptAll(PipelineStage rightPipeline)	Adds an exceptAll stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.innerJoin(PipelineStage pipeline, BiFunction<Tables.Columns,Tables.Columns,Collection<? extends Selectable>> selectables, BiFunction<Tables.Columns,Tables.Columns,Expression> joinCriteria)	Adds an innerJoin stage that joins this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.intersect(PipelineStage rightPipeline)	Adds an intersect stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.intersectAll(PipelineStage rightPipeline)	Adds an intersectAll stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.leftOuterJoin(PipelineStage pipeline, BiFunction<Tables.Columns,Tables.Columns,Collection<? extends Selectable>> selectables, BiFunction<Tables.Columns,Tables.Columns,Expression> joinCriteria)	Adds a leftOuterJoin stage that joins to this PipelineStage another PipelineStage.
PipelineStage	PipelineStage.union(PipelineStage rightPipeline)	Adds a union stage that combines this PipelineStage to another PipelineStage.
PipelineStage	PipelineStage.unionAll(PipelineStage rightPipeline)	Adds a unionAll stage that combines this PipelineStage to another PipelineStage.