Lines Matching refs:flags
41 int flags = op.opGetFlags();
44 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) {
46 public Sink opWrapSink(int flags, Sink<T> sink) {
47 return op.opWrapSink(flags, isParallel(), sink);
51 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
53 public Sink opWrapSink(int flags, Sink sink) {
54 return op.opWrapSink(flags, isParallel(), sink);
58 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
60 public Sink opWrapSink(int flags, Sink sink) {
61 return op.opWrapSink(flags, isParallel(), sink);
65 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
67 public Sink opWrapSink(int flags, Sink sink) {
68 return op.opWrapSink(flags, isParallel(), sink);
81 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);