Uses of Interface
net.pricefx.formulaengine.scripting.queryapi.PipelineStage
Packages that use PipelineStage
Package
Description
-
Uses of PipelineStage in net.pricefx.formulaengine.optimization
Methods in net.pricefx.formulaengine.optimization with parameters of type PipelineStageModifier and TypeMethodDescriptionlongModelFormulaContextReadWrite.loadTable(DatamartContext.Table table, PipelineStage query, boolean truncate) Sample code:longModelParallelCalculationFormulaItemContext.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 PipelineStageModifier and TypeMethodDescriptionPipelineStage.addColumns(Function<Tables.Columns, Collection<? extends Selectable>> expressions) Adds a stage that adds columns to this stage output.PipelineStage.aggregate(Function<Tables.Columns, Collection<? extends Selectable>> selectables) Adds a stage that aggregates all this stage output rows.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.crossJoin(PipelineStage pipeline, BiFunction<Tables.Columns, Tables.Columns, Collection<? extends Selectable>> selectables) Adds a crossJoin stage that joins to thisPipelineStageanotherPipelineStage.PipelineStage.crossJoin(Tables.Table table, Function<Tables.Columns, Collection<? extends Selectable>> selectables) Adds a crossJoin stage that joins to thisPipelineStageanotherTables.Table.PipelineStage.distinct()Adds a stage that removes duplicate rows from this stage output row set.PipelineStage.except(PipelineStage rightPipeline) Adds an except stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.exceptAll(PipelineStage rightPipeline) Adds an exceptAll stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.filter(Function<Tables.Columns, Expression> condition) Adds a stage that only keeps this stage output rows which verify the given expression.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 thisPipelineStageto anotherPipelineStage.PipelineStage.innerJoin(Tables.Table table, Function<Tables.Columns, Collection<? extends Selectable>> selectables, Function<Tables.Columns, Expression> joinCriteria) Adds an innerJoin stage that joins thisPipelineStageto anotherTables.Table.PipelineStage.intersect(PipelineStage rightPipeline) Adds an intersect stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.intersectAll(PipelineStage rightPipeline) Adds an intersectAll stage that combines thisPipelineStageto anotherPipelineStage.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 thisPipelineStageanotherPipelineStage.PipelineStage.leftOuterJoin(Tables.Table table, Function<Tables.Columns, Collection<? extends Selectable>> selectables, Function<Tables.Columns, Expression> joinCriteria) Adds a leftOuterJoin stage that joins to thisPipelineStageanotherTables.Table.PipelineStage.removeColumns(Function<Tables.Columns, Collection<? extends Selectable>> columns) Adds a stage that remove the given columns from this stage output.PipelineStage.retainColumns(Function<Tables.Columns, Collection<? extends Selectable>> columns) Deprecated.PipelineStage.selectColumns(Function<Tables.Columns, Collection<? extends Selectable>> columns) Adds a stage that keeps and adds the given columns from this stage output.PipelineStage.sortBy(Function<Tables.Columns, List<Orders.Order>> orders) Adds a stage that sorts this stage output rows.QueryApi.source(Tables.Table table) Main entry point to start writing a query.QueryApi.source(Tables.Table table, List<? extends Selectable> selectables) Main entry point to start writing a query.QueryApi.source(Tables.Table table, List<? extends Selectable> selectables, Expression filter) Main entry point to start writing a query.QueryApi.source(Tables.Table table, Expression filter) Main entry point to start writing a query.PipelineStage.take(int count) Adds a stage that only returns the firstmaxResultrows of this pipeline stage output.PipelineStage.traceQuery()Prints the result ofqueryString()into the current logic execution trace usingPublicGroovyAPI.trace(String, String, Object).PipelineStage.union(PipelineStage rightPipeline) Adds a union stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.unionAll(PipelineStage rightPipeline) Adds a unionAll stage that combines thisPipelineStageto anotherPipelineStage.Methods in net.pricefx.formulaengine.scripting.queryapi with parameters of type PipelineStageModifier and TypeMethodDescriptionPipelineStage.crossJoin(PipelineStage pipeline, BiFunction<Tables.Columns, Tables.Columns, Collection<? extends Selectable>> selectables) Adds a crossJoin stage that joins to thisPipelineStageanotherPipelineStage.PipelineStage.except(PipelineStage rightPipeline) Adds an except stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.exceptAll(PipelineStage rightPipeline) Adds an exceptAll stage that combines thisPipelineStageto anotherPipelineStage.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 thisPipelineStageto anotherPipelineStage.PipelineStage.intersect(PipelineStage rightPipeline) Adds an intersect stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.intersectAll(PipelineStage rightPipeline) Adds an intersectAll stage that combines thisPipelineStageto anotherPipelineStage.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 thisPipelineStageanotherPipelineStage.PipelineStage.union(PipelineStage rightPipeline) Adds a union stage that combines thisPipelineStageto anotherPipelineStage.PipelineStage.unionAll(PipelineStage rightPipeline) Adds a unionAll stage that combines thisPipelineStageto anotherPipelineStage.
selectColumns(Function)instead.