DataStream.explain

This will not trigger the execution of your computation graph but will produce a graph of the execution plan.

Parameters:

Name	Type	Description	Default
mode	str	'graph' will show a graph, 'text' will print a textual description.	'graph'

Return

None.

Source code in pyquokka/datastream.py

def explain(self, mode="graph"):
    '''
    This will not trigger the execution of your computation graph but will produce a graph of the execution plan. 
    Args:
        mode (str): 'graph' will show a graph, 'text' will print a textual description.
    Return:
        None.
    '''
    dataset = self.quokka_context.new_dataset(self, self.schema)
    return self.quokka_context.execute_node(dataset.source_node_id, explain=True, mode=mode)