transaction_id

函数功能

以属性方式读写事务ID。

函数原型

1
2
3
4

@property
def transaction_id(self)
@transaction_id.setter
def transaction_id(self, new_value)

参数说明

返回值

transaction_id的属性。

调用示例

1
2
3
4
5

import dataflow as df
graph = df.FlowGraph(...)
flowinfo = FlowInfo(...)
flowinfo.transaction_id = 10
print(flowinfo.transaction_id)

约束说明

• 只有构图接口通过set_contains_n_mapping_node设置为true时才生效。
• transaction_id只能增大不能减小，外部不设置的情况下，transaction_id从1开始自增。
• transaction_id达到uint64_max值后会报错。
• 开启数据对齐时，需要确保每批输入数据的transaction_id一致，否则可能导致数据不对齐。
• 只有设置transaction_id非0的时候才会使能自定义transaction_id。