|
|
@@ -112,12 +112,12 @@ class Rocket(object): |
|
|
|
try: |
|
|
|
(ts, row) = self.layoutparser.parse(line) |
|
|
|
except ValueError as e: |
|
|
|
raise ParseError((linenum, ERR_UNKNOWN, e)) |
|
|
|
raise ParseError(linenum, ERR_UNKNOWN, e) |
|
|
|
if ts <= last_timestamp: |
|
|
|
raise ParseError((linenum, ERR_NON_MONOTONIC, ts)) |
|
|
|
raise ParseError(linenum, ERR_NON_MONOTONIC, ts) |
|
|
|
last_timestamp = ts |
|
|
|
if ts < start or ts >= end: |
|
|
|
raise ParseError((linenum, ERR_OUT_OF_INTERVAL, ts)) |
|
|
|
raise ParseError(linenum, ERR_OUT_OF_INTERVAL, ts) |
|
|
|
self.append_iter(1, [row]) |
|
|
|
written += 1 |
|
|
|
return (written, indata.tell(), last_timestamp, linenum) |
|
|
|