class LimitRowAggregator extends SingleColumnAggregator<LimitRowAggregatorValue> implements Serializable {

    @Override
    public LimitRowAggregatorValue aggregate(RowTraversal traversal, final Column column) {
        LimitRowAggregatorValue value = new LimitRowAggregatorValue();
        final List<Object> list = new ArrayList<>();
        traversal.breakableTraversal(new BreakTraversalAction() {
            @Override
            public boolean actionPerformed(int row) {
                list.add(column.getDictionaryEncodedColumn().getValueByRow(row));
                return limitRow <= list.size();
            }
        });
        value.setValue(list);
        return value;
    }

    public  LimitRowAggregator(int limitRow);

}