org.apache.flink.api.common.operators.base.JoinOperatorBase to org.apache.flink.api.java.operators.JoinOperator.EquiJoin.JoinOperatorBaseBuilder