T- Type of the tuple.
public class StreamScope<T> extends Peek<T>
This class exists so that we can register a StreamScope at runtime with jobId info (lacking a Function level initialize(FuntionScope) mechanism) and so the Console can differentiate a StreamScope peek from any other random Peek oplet use. Remove this oplet subclass if/when it's no longer needed to achieve the above purpose.
|Constructor and Description|
Create a new instance.
|Modifier and Type||Method and Description|
Initialize the oplet.
getDestination, getInputs, start, submit
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.