class_docstr: Wrapper class for interacting with per-group state data in `applyInPandasWithState`.
docstr: Get the current processing time as milliseconds in epoch time.
  In a streaming query, this will return a constant value throughout the duration of a
  trigger, even if the trigger is re-executed.
docstr_tok: ["Get","the","current","processing","time","as","milliseconds","in","epoch","time",".","In","a","streaming","query",",","this","will","return","a","constant","value","throughout","the","duration","of","a","trigger",",","even","if","the","trigger","is","re-executed","."]
code: def getCurrentProcessingTimeMs(self) -> int:
      """
      Get the current processing time as milliseconds in epoch time.
      In a streaming query, this will return a constant value throughout the duration of a
      trigger, even if the trigger is re-executed.
      """
      return self._batch_processing_time_ms
  
imports: import datetime
  import json
  from typing import Tuple, Optional
  from pyspark.sql.types import DateType, Row, StructType
  from pyspark.sql.utils import has_numpy
  from pyspark.errors import PySparkTypeError, PySparkValueError, PySparkRuntimeError
label_desc: Use image node_id 12 for calling the GroupState obj's underlying member method code with example usage: obj.getCurrentProcessingTimeMs() and returns: self