flink-sql1.3数据从datahub摄入时间与sink hologres的时间怎么获取？

在使用Flink SQL进行数据摄取和存储时，你可以通过定义合适的Watermark策略来获取数据的摄入时间和sink Hologres的时间。Watermark是一种特殊的元数据，它可以用来跟踪事件的发生时间。
对于DataHub而言，你可以定义一个恰当的Event Time Watermark策略，以便跟踪每一条数据的摄入时间。具体来说，你可以根据DataHub中的时间戳字段来确定每条数据的摄入时间，并将这些时间戳值用作定义Watermark策略的基础。一旦定义好了Watermark策略，Flink就会自动地对每条数据进行标记，从而可以方便地查询和分析数据的摄入时间。
而对于Hologres而言，你可以通过定义一个恰当的结果Time Watermark策略来跟踪数据的sink时间。具体来说，你可以根据Hologres中的时间戳字段来确定每条数据的sink时间，并将这些时间戳值用作定义Watermark策略的基础。一旦定义好了Watermark策略，Flink就会自动地对每条数据进行标记，从而可以方便地查询和分析数据的sink时间。

在专有云flink-sql 1.3中，要获取从DataHub摄入数据的时间以及将数据写入Hologres的时间，可以通过使用内置的函数和时间日期转换方法来实现。具体来说，您可以在Flink SQL中使用PostgreSQL的子集函数来处理时间和日期相关的操作。

对于从DataHub摄入数据的时间，您可以在Flink SQL中使用DataHub API中的事件时间属性来获取。DataHub API提供了事件的时间戳信息，您可以根据这个时间戳来获取数据的时间。例如，假设您使用了INSERT INTO语句将数据从DataHub读取到Flink表中，您可以使用以下代码来获取事件时间：

SELECT event_timestamp() AS ingestion_time FROM your_table;

上述代码将返回一个表示数据摄入时间的字段，即ingestion_time。

另一方面，要将数据写入Hologres并获取写入时间，您可以在Flink SQL中使用Hologres连接器的相关功能。首先，确保您已创建了Hologres表，并且使用的Flink计算引擎版本为VVR 2.0.0及以上。然后，可以使用Hologres连接器将数据写入Hologres表，并在插入操作中获取当前时间作为写入时间。以下是一个示例：

INSERT INTO your_hologres_table (column1, column2)
VALUES ('value1', 'value2'),
       (value3, value4)
TIMESTAMP FORMAT('yyyy-MM-dd HH:mm:ss');

上述代码将在插入数据时记录当前时间作为写入时间，并将其格式化为指定的字符串格式。您可以根据需要调整时间格式字符串。

Flink-SQL 中，可以从 Datahub 和 Hologres 中检索时间信息的方法如下：

Datahub 可以使用水印（watermark）来获取时间戳。Watermark 是事件时间和处理时间的概念。事件时间描述了一个事件在其源系统中生成的实际时间；处理时间则是事件到达某一算子的实际时间。

Hologres 利用窗口、事件时间、更新状态等功能实现时间维度的操作。比如，在 DataStream API 中可通过 getRuntimeContext().getCurrentProcessingTime() 或 getTimestamp() 获取当前事件时间戳。而在 DataSet API 中，可以通过 getExecutionEnvironment().getParallelism() 方法获取当前分区内的处理时间戳。然后可以通过事件时间模式的 Watermark 特征提取时间信息。

示例：

SELECT 
    id, 
    proctime,
    event_time
FROM datahub_table;

你可以根据需要调整时间窗口策略，在 Hologres 中进行时间相关的计算或聚合。更多信息可参考 Apache Flink 文档：https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html 和 https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/sql/queries.html。

数据进入 datahub 的时间？
有system-time 这个 meta 字段
TIMESTAMP METADATA VIRTUAL
系统时间。可以用 current_timestamp，取 Flink 系统时间。数据写入 Hologres 的时间？这个可以暂时没有 meta 可以获取。此回答整理自钉群“实时计算Flink产品交流群”