process

CREATE STREAM transition
  WITH (
   TIMESTAMP='START_TIME_,END_TIME_',
   KAFKA_TOPIC='transition',
   VALUE_FORMAT='DELIMITED'
  ) AS
    SELECT
      PROC_DEF_ID_, 
      EXECUTION_ID_, 
      NAME_ ,
      START_TIME_, 
      END_TIME_,
      TIMESTAMPTOSTRING(START_TIME_, 'yyyy-MM-dd HH:mm:ss.SSS') AS START_TIME,
      TIMESTAMPTOSTRING(END_TIME_, 'yyyy-MM-dd HH:mm:ss.SSS') AS END_TIME
    FROM PROCESS
    EMIT CHANGES;