Hi, I have implement myRule that implement ConverterRule,and define my
DataStreamNode like
public class DataStreamCalc extends Calc implements DataStreamRel {
public DataStreamCalc(RelOptCluster cluster, RelTraitSet traits,
List<RelHint> hints, RelNode child, RexProgram program) {
super(cluster, traits, hints, child, program);
}
/**
* eg: use for merge calc
*/
@Override
public Calc copy(RelTraitSet traitSet, RelNode child, RexProgram program) {
return new
DataStreamCalc(getCluster(),getTraitSet(),hints,input,getProgram());
}
@Override
public RelOptCost computeSelfCost(RelOptPlanner planner, RelMetadataQuery
mq) {
return Costs.defaultCost();
}
@Override
public DataStream<Row> translateToPlan(FlinkPlanner planner) {
return null;
}
}
,I hava add ProjectToCalcRule and FilterToCalcRule. however it still can not
find BestPlan.
and the stackTrace like the attachment.
[email protected]
