Searched refs:SinkTerminal (Results 1 – 1 of 1) sorted by relevance
1495 class SinkTerminal(object): class1623 def __init__(self, source_collection: DataSourceCollection, sink_terminal: SinkTerminal): argument2366 input_sink = SinkTerminal(self._input_description.signature())2368 logger.debug('SinkTerminal configured: {}'.format(SinkTerminal))