package com.alibaba.otter.node.etl.model.protobuf

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: RowData

• optional int32 index = 1

  *列下标*

• optional string name = 2

  *列名*

• optional string value = 3

  *列值,timestamp,Datetime是一个long型的数字*

• optional bool isPrimaryKey = 4

  *当前列是否是主键*

• optional bool isNull = 5

  *当前列是否可以为空*

• optional int32 type = 6

  *当前列的数据类型*

• optional bool isUpdate = 7

  *当前列是否发生真实变更*

• optional Identity identity = 1

• repeated FileData files = 2

  *每个batch里面变更数据所关联的文件信息*

*文件对象*

Used in: FileBatch

• optional string eventType = 1

  *变更数据的操作类型(I/U/D/C/A/E)*

• optional string namespace = 2

  *Aranda中特有的*

• optional string path = 3

  *文件的路径*

• optional int64 lastModifiedTime = 4

  *文件最后一次修改时间*

• optional int64 size = 5

  *文件的大小*

• optional int64 tableId = 6

• optional int64 pairId = 9

  *映射规则id*

*同步数据表示对象*

Used in: FileBatch, RowBatch

• optional int64 channelId = 1

  *通道标示*

• optional int64 pipelineId = 2

• optional int64 processId = 3

*数据包*

• optional Identity identity = 1

• repeated RowData rows = 2

  *每个batch里面的所有变更数据*

*数据*

Used in: RowBatch

• optional int64 tableId = 1

• optional string schemaName = 2

• optional string tableName = 3

• optional string eventType = 4

  *变更数据的操作类型(I/U/D)*

• repeated Column oldKeys = 5

  *变更前的主键，可能是复合主键*

• repeated Column keys = 6

  *变更后的主键，可能是复合主键*

• repeated Column columns = 7

  *变更数据的每列变更信息,不包含主键*

• optional int64 executeTime = 8

  *变更数据的业务时间*

• optional int64 pairId = 9

  *映射规则id*

• optional string syncMode = 10

  *同步模式(R/F)*

• optional string syncConsistency = 11

  *同步一致性(B/S/M) *

• optional int64 size = 12

  * eventsize *

• optional bool remedy = 13

  * isRemedy *

• optional string sql = 14

  * dml/ddl sql *

• optional string ddlSchemaName = 15

  * current ddl schemaName *

• optional string hint = 16

  * dml/ddl sql *

• optional bool withoutSchema = 17

  * without schema *