BSortQBox.h

Go to the documentation of this file.

#ifndef BSORT_QBOX_H
#define BSORT_QBOX_H

#include "QBox.h"

#include "BufferList.h"
#include "FieldExt.h"
#include "HashForBufferList.h"

BOREALIS_NAMESPACE_BEGIN;

class BSortQBox : public QBox
{
private:

    void addToBuffer( char *tuple );
    void addSingleToBuffer( char *att_value, BufferList::node new_node );
    void addDoubleToBuffer( char *att_value, BufferList::node new_node );
    void addInt32ToBuffer(  char *att_value, BufferList::node new_node );
    void addInt64ToBuffer(  char *att_value, BufferList::node new_node );
    void addStringToBuffer( char *att_value, BufferList::node new_node );

    // something has to be passed to this method that will initialize everything
    
    void emitLowest(BufferList *buffer,EnqIterator);
    void emitTuple(char *tuple,EnqIterator);
    
    void parseGroupBy(char *atts);

    HashForBufferList *_buffer_hash;
    BufferList     *_buffer; // this should be called "currentBuffer or something"
    char           *_group_by_atts;
    int           _slack;
    
    FieldExt       *_field_att;
    FieldExt       **_field_group;
    int            _num_group_by_atts;
    // This (nul-terminated) string is a concatenation (0x01 delimited)
    //of the group by attribute values from the current tuple.
    char           *_group_by_values_str;
    
    int            _num_tuples_emitted;
    int            _output_tuple_size;
    char           *_curr_tuple;
    char           *_output_tuple_ptr;
    
protected:
    void setupImpl() throw (AuroraException);
    void initImpl() throw (AuroraException);
    void runImpl(QBoxInvocation&) throw (AuroraException);
    
    AURORA_DECLARE_QBOX(BSortQBox, "bsort");
};

BOREALIS_NAMESPACE_END;

#endif

---