valitydev/yandex-tank
14
0
Fork 0
mirror of https://github.com/valitydev/yandex-tank.git synced 2024-11-06 18:35:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

start work on chopper

Browse Source
This commit is contained in:
Alexey Lavrenuke 2015-11-24 14:35:41 +03:00
parent 73f018db08
commit 3669d68cfd
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
yandextank/plugins/NumpyAggregator/chopper.py
View File

@ -0,0 +1,9 @@
"""
Split incoming DataFrames into chunks, cache them, union chunks with same key
and pass to the underlying aggregator.
"""
class Chopper(object):
def __init__(self, arg):
self.arg = arg