code: def test_stream_trigger(self):
      df = self.spark.readStream.format("text").load(
          "python/test_support/sql/streaming"
      )
  
      # Should take at least one arg
      try:
          df.writeStream.trigger()
      except ValueError:
          pass
  
      # Should not take multiple args
      try:
          df.writeStream.trigger(once=True, processingTime="5 seconds")
      except ValueError:
          pass
  
      # Should not take multiple args
      try:
          df.writeStream.trigger(
              processingTime="5 seconds", continuous="1 second"
          )
      except ValueError:
          pass
  
      # Should take only keyword args
      try:
          df.writeStream.trigger("5 seconds")
          self.fail("Should have thrown an exception")
      except TypeError:
          pass
  
imports: import os
  import shutil
  import tempfile
  import time
  from pyspark.sql import Row
  from pyspark.sql.functions import lit
  from pyspark.sql.types import StructType, StructField, IntegerType, StringType
  from pyspark.testing.sqlutils import ReusedSQLTestCase
label_desc: Use image node_id 2 for calling the StreamingTestsMixin obj's underlying member method code with example usage: obj.test_stream_trigger() without return types