1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
from .reader import read_binary_uint8
from .varint import read_varint
class BlockStreamProfileInfo(object):
def __init__(self):
self.rows = 0
self.blocks = 0
self.bytes = 0
self.applied_limit = False # bool
self.rows_before_limit = 0
self.calculated_rows_before_limit = 0 # bool
super(BlockStreamProfileInfo, self).__init__()
def read(self, fin):
self.rows = read_varint(fin)
self.blocks = read_varint(fin)
self.bytes = read_varint(fin)
self.applied_limit = bool(read_binary_uint8(fin))
self.rows_before_limit = read_varint(fin)
self.calculated_rows_before_limit = bool(read_binary_uint8(fin))
|
