@abstractmethod
  def on_element(self, element, window, context):
    pass
Called when a new element arrives in a window.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/transforms/trigger.py/TriggerFn.on_element