Searched refs:getStreamAndOpFlags (Results 1 – 9 of 9) 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()
141 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()174 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) { in makeRef()261 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {286 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {373 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {398 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {485 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {510 } else if (!StreamOpFlag.ORDERED.isKnown(helper.getStreamAndOpFlags())) {617 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
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()
470 … return StreamOpFlag.SIZED.isKnown(getStreamAndOpFlags()) ? spliterator.getExactSizeIfKnown() : -1; in exactOutputSizeIfKnown()483 if (!StreamOpFlag.SHORT_CIRCUIT.isKnown(getStreamAndOpFlags())) { in copyInto()508 public final int getStreamAndOpFlags() { in getStreamAndOpFlags() method in AbstractPipeline
284 … boolean isShortCircuit = StreamOpFlag.SHORT_CIRCUIT.isKnown(helper.getStreamAndOpFlags()); in compute()
230 return StreamOpFlag.SIZED.isKnown(ph.getStreamAndOpFlags())240 … int c = StreamOpFlag.toCharacteristics(StreamOpFlag.toStreamFlags(ph.getStreamAndOpFlags()));
89 int flags = helper.getStreamAndOpFlags(); in opEvaluateParallel()
90 int flags = helper.getStreamAndOpFlags(); in opEvaluateParallel()