from pyspark.sql.types import StructType, StructField, LongType, StringType, TimestampTypefrom pyspark.sql import functions as F, Windowfrom delta.tables import DeltaTableimport logging# Set up logginglogging.basicConfig(level=logging.INFO)logger = l...