6 #ifndef __AGGREGATE_UNIQUE_H__ 7 #define __AGGREGATE_UNIQUE_H__ 9 #include "../GenericRecord.hpp" 67 options(std::map<std::string, std::string>())
308 AggregateUniqueRequest(
const std::string& tableName_,
const std::string& columnName_,
const int64_t offset_,
const int64_t limit_,
const std::map<std::string, std::string>& options_):
570 AggregateUniqueRequest(
const std::string& tableName_,
const std::string& columnName_,
const int64_t offset_,
const int64_t limit_,
const std::string& encoding_,
const std::map<std::string, std::string>& options_):
781 template<>
struct codec_traits<
gpudb::AggregateUniqueRequest>
787 ::avro::encode(e, v.
offset);
788 ::avro::encode(e, v.
limit);
795 if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
797 const std::vector<size_t> fo = rd->fieldOrder();
799 for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
812 ::avro::decode(d, v.
offset);
816 ::avro::decode(d, v.
limit);
836 ::avro::decode(d, v.
offset);
837 ::avro::decode(d, v.
limit);
864 info(std::map<std::string, std::string>())
904 std::map<std::string, std::string>
info;
910 template<>
struct codec_traits<
gpudb::RawAggregateUniqueResponse>
919 ::avro::encode(e, v.
info);
924 if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
926 const std::vector<size_t> fo = rd->fieldOrder();
928 for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
953 ::avro::decode(d, v.
info);
968 ::avro::decode(d, v.
info);
992 info(std::map<std::string, std::string>()),
1010 std::vector<gpudb::GenericRecord>
data;
1027 std::map<std::string, std::string>
info;
1033 #endif // __AGGREGATE_UNIQUE_H__ std::string responseSchemaStr
Avro schema of data or jsonEncodedResponse.
AggregateUniqueRequest()
Constructs an AggregateUniqueRequest object with default parameters.
boost::shared_ptr< Type > gpudb_type_ptr_t
std::vector< gpudb::GenericRecord > data
Avro binary encoded response.
std::string responseSchemaStr
Avro schema of binaryEncodedResponse or jsonEncodedResponse.
std::map< std::string, std::string > info
Additional information.
bool hasMoreRecords
Too many records.
std::string tableName
Name of an existing table or view on which the operation will be performed, in [ schema_name....
std::string encoding
Specifies the encoding for returned records.
std::string tableName
The same table name as was passed in the parameter list.
A set of parameters for GPUdb::aggregateUnique.
std::string tableName
The same table name as was passed in the parameter list.
std::string columnName
Name of the column or an expression containing one or more column names on which the unique function ...
int64_t offset
A positive integer indicating the number of initial results to skip (this can be useful for paging th...
A set of results returned by GPUdb::aggregateUnique.
AggregateUniqueResponse()
Constructs an AggregateUniqueResponse object with default parameters.
std::string jsonEncodedResponse
Avro JSON encoded response.
RawAggregateUniqueResponse()
Constructs a RawAggregateUniqueResponse object with default parameters.
bool hasMoreRecords
Too many records.
gpudb_type_ptr_t dataTypePtr
AggregateUniqueRequest(const std::string &tableName_, const std::string &columnName_, const int64_t offset_, const int64_t limit_, const std::string &encoding_, const std::map< std::string, std::string > &options_)
Constructs an AggregateUniqueRequest object with the specified parameters.
std::map< std::string, std::string > options
Optional parameters.
int64_t limit
A positive integer indicating the maximum number of results to be returned, or END_OF_SET (-9999) to ...
std::vector< uint8_t > binaryEncodedResponse
Avro binary encoded response.
std::map< std::string, std::string > info
Additional information.
A set of results returned by GPUdb::aggregateUniqueRaw.
AggregateUniqueRequest(const std::string &tableName_, const std::string &columnName_, const int64_t offset_, const int64_t limit_, const std::map< std::string, std::string > &options_)
Constructs an AggregateUniqueRequest object with the specified parameters.