com.pervasive.datarush.operators

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 Summary

Methods

Modifier and Type	Method and Description
AbstractLogicalOperator	getTarget() Public only as a matter of implementation; not intended for external use
boolean	isParallelismDisabled() Public only as a matter of implementation; not intended for external use
void	notifyError(Throwable e) Public only as a matter of implementation; not intended for external use
void	setParallelismDisabled(boolean disabled) Public only as a matter of implementation; not intended for external use

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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