Operator DPSAux
The DPSAux operator's purpose is to support primitive Java operators that desire to use the DPS toolkit Java APIs. An instance of this operator must be included in the application graph in order for such Java operators within the application to work correctly.
Example
use com.teracloud.streams.store.distributed::DPSAux;
public composite Main {
//This operator is required in order for the primitive Java operators to function properly.
() as DPSAux_1 = DPSAux() {}
//Now, the Java operator within this application can use the DPS Java APIs.
stream<rstring ticker_symbol> IdGenerator = MyJavaPrimitiveOperator() {
}
}
Summary
- Ports
- This operator has 0 input ports and 0 output ports.
- Windowing
- This operator does not accept any windowing configurations.
- Parameters
- This operator does not support parameters.
- Metrics
- This operator does not report any metrics.
Properties
- Implementation
- C++
- Threading
- Never - Operator never provides a single threaded execution context.
- DPSAux
-
// This operator is only needed if a Java primitive operator uses the DPS Java API () as ${opInvocationName} = com.teracloud.streams.store.distributed::DPSAux() {}
- DPS Library