OmniSteam SQL framework: Use: StreamOperatorWrapper (maybe refactorying soon)

NOT use: OperatorChain (SQL use OperatorChainV2 which is under runtime/tasks) StreamTask StreamTaskNetworkInput StreamTaskNetworkOutput