| @@ -144,8 +144,11 class HDFReader(Reader, ProcessingUnit): | |||||
| 144 |
|
144 | |||
| 145 | self.__readMetadata() |
|
145 | self.__readMetadata() | |
| 146 | self.__readData() |
|
146 | self.__readData() | |
| 147 |
self.__setBlockList() |
|
147 | self.__setBlockList() | |
| 148 |
|
148 | # similar to master | ||
|
|
149 | if 'type' in self.meta: | |||
|
|
150 | self.dataOut = eval(self.meta['type'])() | |||
|
|
151 | # similar to master | |||
| 149 | for attr in self.meta: |
|
152 | for attr in self.meta: | |
| 150 | setattr(self.dataOut, attr, self.meta[attr]) |
|
153 | setattr(self.dataOut, attr, self.meta[attr]) | |
| 151 |
|
154 | |||
| @@ -181,6 +184,13 class HDFReader(Reader, ProcessingUnit): | |||||
| 181 |
|
184 | |||
| 182 | self.blockList = ind |
|
185 | self.blockList = ind | |
| 183 | self.blocksPerFile = len(ind) |
|
186 | self.blocksPerFile = len(ind) | |
|
|
187 | # similar to master | |||
|
|
188 | if len(ind)==0: | |||
|
|
189 | print("[Reading] Block No. %d/%d -> %s [Skipping]" % (self.blockIndex, | |||
|
|
190 | self.blocksPerFile, | |||
|
|
191 | thisDatetime)) | |||
|
|
192 | self.setNextFile() | |||
|
|
193 | # similar to master | |||
| 184 | return |
|
194 | return | |
| 185 |
|
195 | |||
| 186 | def __readMetadata(self): |
|
196 | def __readMetadata(self): | |
| @@ -274,10 +284,10 class HDFReader(Reader, ProcessingUnit): | |||||
| 274 | self.setNextFile() |
|
284 | self.setNextFile() | |
| 275 |
|
285 | |||
| 276 | self.getData() |
|
286 | self.getData() | |
| 277 |
|
287 | ''' # this block is missing in master. | ||
| 278 | if 'type' in self.meta: |
|
288 | if 'type' in self.meta: | |
| 279 | self.dataOut.type = self.meta['type'].decode('utf-8') |
|
289 | self.dataOut.type = self.meta['type'].decode('utf-8') | |
| 280 |
|
290 | ''' | ||
| 281 | return |
|
291 | return | |
| 282 |
|
292 | |||
| 283 | @MPDecorator |
|
293 | @MPDecorator | |
General Comments 0
You need to be logged in to leave comments.
Login now