TStreamingSetupTask

pl 

receiveWorkPort

pl 

workerHarnessPort

pl 

streamingComputationTopology

pl 

drain

TGoogleBaseObject