I've probably overlooked something simple, but when converting a
datastream to a table how does one convert a long to timestamp(3) that
will not be your event or proc time.

I've tried

        tEnv.createTemporaryView(
                "myTable"
                ,myDatastream
                ,....
                ,$("myLongTS").toTimestamp()
        )
which produces the exception,

org.apache.flink.table.api.ValidationException: Field reference
expression or alias on field expression expected.

I've also tried,

$("myLongTS").toTimestamp().as("myLongTS")
$("myLongTS as myLongTS").toTimestamp()

Haven't found Gooogling to be of much help on this one.

--
Thank You,
Aeden

Reply via email to