Skip to content

P
physical
Commit e42d8857 authored by 段英荣's avatar 段英荣
Browse files
Options

modify topic transfer

parent 83c687d0
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
libs/table_scan.py
View file @ e42d8857
...@@ -5,6 +5,7 @@ from __future__ import unicode_literals, print_function, absolute_import ...@@ -5,6 +5,7 @@ from __future__ import unicode_literals, print_function, absolute_import
import six import six
import random import random
from django.db import models from django.db import models
import logging
class ITableChunk(object): class ITableChunk(object):
...@@ -173,6 +174,7 @@ class TableSlicer(object): ...@@ -173,6 +174,7 @@ class TableSlicer(object):
def chunks(self): def chunks(self):
reversed_sep_list = list(reversed(self._sep_list)) reversed_sep_list = list(reversed(self._sep_list))
logging.info("duan add,reversed_sep_list:%d" % reversed_sep_list)
for i in range(len(self._sep_list) - 1): for i in range(len(self._sep_list) - 1):
pk_start = reversed_sep_list[i+1] pk_start = reversed_sep_list[i+1]
pk_stop = reversed_sep_list[i] pk_stop = reversed_sep_list[i]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment