(schemaName string, tableName string)
| 64 | } |
| 65 | |
| 66 | func (c CursorConfig) GetBatchSize(schemaName string, tableName string) uint64 { |
| 67 | if c.BatchSizePerTableOverride != nil { |
| 68 | if batchSize, found := c.BatchSizePerTableOverride.TableOverride[schemaName][tableName]; found { |
| 69 | return batchSize |
| 70 | } |
| 71 | } |
| 72 | return *c.BatchSize |
| 73 | } |
| 74 | |
| 75 | type Cursor struct { |
| 76 | CursorConfig |
no outgoing calls