()
| 157 | } |
| 158 | |
| 159 | func createTestTable() *schema.Table { |
| 160 | tableName := fmt.Sprintf("cq_delete_test_%d_%04d", time.Now().UnixNano(), rand.Intn(1000)) |
| 161 | table := &schema.Table{ |
| 162 | Name: tableName, |
| 163 | Columns: schema.ColumnList{ |
| 164 | schema.Column{Name: "id", Type: arrow.BinaryTypes.String, PrimaryKey: true, NotNull: true}, |
| 165 | schema.CqSourceNameColumn, |
| 166 | schema.CqSyncTimeColumn, |
| 167 | }, |
| 168 | } |
| 169 | return table |
| 170 | } |