Class OperatorProxies.OperatorProxy

java.lang.Object
com.pervasive.datarush.operators.OperatorProxies.OperatorProxy
Direct Known Subclasses:
OperatorProxies.CompositeOperatorProxy, OperatorProxies.IterativeOperatorProxy, OperatorProxies.StreamingOperatorProxy
Enclosing class:
OperatorProxies

public static class OperatorProxies.OperatorProxy extends Object
Public only as a matter of implementation; not intended for external use
  • Method Details

    • getTarget

      public AbstractLogicalOperator getTarget()
      Public only as a matter of implementation; not intended for external use
      Returns:
      the target operator
    • isParallelismDisabled

      public boolean isParallelismDisabled()
      Public only as a matter of implementation; not intended for external use
      Returns:
      whether parallelism is disabled
    • setParallelismDisabled

      public void setParallelismDisabled(boolean disabled)
      Public only as a matter of implementation; not intended for external use
      Parameters:
      disabled - whether parallelism is disabled
    • notifyError

      public final void notifyError(Throwable e)
      Public only as a matter of implementation; not intended for external use
      Parameters:
      e - the error that occurred