Searched refs:getStreamAndOpFlags (Results 1 – 11 of 11) sorted by relevance
72 if (StreamOpFlag.DISTINCT.isKnown(helper.getStreamAndOpFlags())) { in makeRef()76 else if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()106 if (StreamOpFlag.DISTINCT.isKnown(helper.getStreamAndOpFlags())) { in makeRef()110 else if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()
137 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()170 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()263 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {288 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {381 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {406 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {499 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {524 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {631 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);640 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
69 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeTakeWhileRef()129 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {189 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {249 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {355 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {433 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {511 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {589 if (StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {1207 this.isOrdered = StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags());1230 Sink<P_OUT> s = op.opWrapSink(helper.getStreamAndOpFlags(), builder);[all …]
75 public abstract int getStreamAndOpFlags(); in getStreamAndOpFlags() method in PipelineHelper
152 if (StreamOpFlag.SORTED.isKnown(helper.getStreamAndOpFlags()) && isNaturalSort) { in opEvaluateParallel()189 if (StreamOpFlag.SORTED.isKnown(helper.getStreamAndOpFlags())) { in opEvaluateParallel()228 if (StreamOpFlag.SORTED.isKnown(helper.getStreamAndOpFlags())) { in opEvaluateParallel()267 if (StreamOpFlag.SORTED.isKnown(helper.getStreamAndOpFlags())) { in opEvaluateParallel()
473 int flags = getStreamAndOpFlags(); in exactOutputSizeIfKnown()511 if (!StreamOpFlag.SHORT_CIRCUIT.isKnown(getStreamAndOpFlags())) { in copyInto()538 public final int getStreamAndOpFlags() { in getStreamAndOpFlags() method in AbstractPipeline
159 boolean mustFindFirst = StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags()); in evaluateParallel()
283 … boolean isShortCircuit = StreamOpFlag.SHORT_CIRCUIT.isKnown(helper.getStreamAndOpFlags()); in compute()
238 … int c = StreamOpFlag.toCharacteristics(StreamOpFlag.toStreamFlags(ph.getStreamAndOpFlags()));
89 int flags = helper.getStreamAndOpFlags(); in opEvaluateParallel()
90 int flags = helper.getStreamAndOpFlags(); in opEvaluateParallel()