Sum rows in an uploaded table.
(self, context, reader, writer)
| 515 | assert False, "Should not happen" |
| 516 | |
| 517 | def exchange_transform(self, context, reader, writer): |
| 518 | """Sum rows in an uploaded table.""" |
| 519 | assert reader.stats.num_messages == 0 |
| 520 | for field in reader.schema: |
| 521 | if not pa.types.is_integer(field.type): |
| 522 | raise pa.ArrowInvalid("Invalid field: " + repr(field)) |
| 523 | table = reader.read_all() |
| 524 | assert reader.stats.num_messages != 0 |
| 525 | sums = [0] * table.num_rows |
| 526 | for column in table: |
| 527 | for row, value in enumerate(column): |
| 528 | sums[row] += value.as_py() |
| 529 | result = pa.Table.from_arrays([pa.array(sums)], names=["sum"]) |
| 530 | writer.begin(result.schema) |
| 531 | writer.write_table(result) |
| 532 | |
| 533 | |
| 534 | class HttpBasicServerAuthHandler(ServerAuthHandler): |
no test coverage detected