Class OperatorProxies.OperatorProxy

    • Method Detail

      • 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