Lines Matching refs:flags
33 int flags = op.opGetFlags();
36 return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) {
37 public Sink opWrapSink(int flags, Sink<T> sink) {
38 return op.opWrapSink(flags, isParallel(), sink);
42 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
43 public Sink opWrapSink(int flags, Sink sink) {
44 return op.opWrapSink(flags, isParallel(), sink);
48 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
50 public Sink opWrapSink(int flags, Sink sink) {
51 return op.opWrapSink(flags, isParallel(), sink);
55 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) {
57 public Sink opWrapSink(int flags, Sink sink) {
58 return op.opWrapSink(flags, isParallel(), sink);
71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);