Matan Perelmuter
09/02/2024, 6:55 PMclass POJO {
OffsetDateTime created_at;
}
Table table = tEnv.fromDataStream(stream,
Schema.newBuilder()
.columnByExpression("proc_time", "PROCTIME()")
.build()
);
It parse the time as RAW
(
`created_at` RAW('java.time.OffsetDateTime', '...'),
`proc_time` TIMESTAMP_LTZ(3) NOT NULL *PROCTIME* AS PROCTIME()
)
any idea why? the documentation says it should be compatibleMatan Perelmuter
09/12/2024, 10:35 PMTypeSerializer<OffsetDateTime>
and annotate the field
@DataTypeHint(value = "RAW", rawSerializer = OffsetDateTimeSerializer.class, bridgedTo = OffsetDateTime.class)
public OffsetDateTime created_at;
but now I'm getting:
Query schema: [created_at: RAW('java.time.OffsetDateTime', '...')]
Sink schema: [created_at: RAW('java.time.OffsetDateTime', '...')]