pl 

drain (TStreamingSetupTask)

pl 

receiveWorkPort (TStreamingSetupTask)

pl 

streamingComputationTopology (TStreamingSetupTask)

pl 

workerHarnessPort (TStreamingSetupTask)