Class that represents the context of an operator. More...
Public Member Functions |
|
| def | getName (self) |
| Get the physical name of the operator. More... |
|
| def | getClassName (self) |
| Get the name of the C++ class corresponding to the operator. More... |
|
| def | getPE (self) |
| Get the processing element hosting this operator. More... |
|
| def | getIndex (self) |
| Get the index of the operator within the PE. More... |
|
| def | getMetrics (self) |
| Get the operator metrics. More... |
|
| def | isProfilingOn (self) |
| Check if this operator is running with profiling turned on Profiling is not supported as of Streams version 4.2. More... |
|
| def | getProfilingBufferSize (self) |
| Get the reservoir size used for profiling this operator Profiling is not supported as of Streams version 4.2. More... |
|
| def | getProfilingSamplingRate (self) |
| Get the sampling rate used for profiling this operator Profiling is not supported as of Streams version 4.2. More... |
|
| def | isCheckpointingOn (self) |
| Check if operator checkpoiting is on. More... |
|
| def | getCheckpointingInterval (self) |
| Get the checkpointing interval for the operator. More... |
|
| def | getLogicalName (self) |
| Get the logical name of the operator. More... |
|
| def | getChannel (self) |
| Get the parallel region channel number the operator is in. More... |
|
| def | getMaxChannels (self) |
| Get the maximum number of channels in the current parallel region. More... |
|
| def | getLocalChannel (self) |
| Get the parallel region channel number the operator is in. More... |
|
| def | getLocalMaxChannels (self) |
| Get the maximum number of channels in the current parallel region. More... |
|
Class that represents the context of an operator.
| def streams.OperatorContext.getName | ( | self, | |
| str | |||
| ) |
Get the physical name of the operator.
| def streams.OperatorContext.getClassName | ( | self, | |
| str | |||
| ) |
Get the name of the C++ class corresponding to the operator.
| def streams.OperatorContext.getPE | ( | self, | |
| ProcessingElement | |||
| ) |
Get the processing element hosting this operator.
| def streams.OperatorContext.getIndex | ( | self, | |
| int | |||
| ) |
Get the index of the operator within the PE.
| def streams.OperatorContext.getMetrics | ( | self, | |
| OperatorMetrics | |||
| ) |
Get the operator metrics.
| def streams.OperatorContext.isProfilingOn | ( | self, | |
| bool | |||
| ) |
Check if this operator is running with profiling turned on Profiling is not supported as of Streams version 4.2.
| def streams.OperatorContext.getProfilingBufferSize | ( | self, | |
| int | |||
| ) |
Get the reservoir size used for profiling this operator Profiling is not supported as of Streams version 4.2.
| def streams.OperatorContext.getProfilingSamplingRate | ( | self, | |
| float | |||
| ) |
Get the sampling rate used for profiling this operator Profiling is not supported as of Streams version 4.2.
| def streams.OperatorContext.isCheckpointingOn | ( | self, | |
| bool | |||
| ) |
Check if operator checkpoiting is on.
| def streams.OperatorContext.getCheckpointingInterval | ( | self, | |
| float | |||
| ) |
Get the checkpointing interval for the operator.
| def streams.OperatorContext.getLogicalName | ( | self, | |
| str | |||
| ) |
Get the logical name of the operator.
| def streams.OperatorContext.getChannel | ( | self, | |
| int | |||
| ) |
Get the parallel region channel number the operator is in.
Note that in the context of a nested parallel region the range of indexes considers replicated nested regions.
| def streams.OperatorContext.getMaxChannels | ( | self, | |
| int | |||
| ) |
Get the maximum number of channels in the current parallel region.
Note that in the context of a nested parallel region the range of indexes considers replicated nested regions.
| def streams.OperatorContext.getLocalChannel | ( | self, | |
| int | |||
| ) |
Get the parallel region channel number the operator is in.
Note that in the context of nested parallel regions the returned index does not consider replicated nested regions.
| def streams.OperatorContext.getLocalMaxChannels | ( | self, | |
| int | |||
| ) |
Get the maximum number of channels in the current parallel region.
Note that in the context of nested parallel regions the returned index does not consider replicated nested regions.