GPUdb C++ API  Version 7.0.19.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
aggregate_unique.h
Go to the documentation of this file.
1 /*
2  * This file was autogenerated by the GPUdb schema processor.
3  *
4  * DO NOT EDIT DIRECTLY.
5  */
6 #ifndef __AGGREGATE_UNIQUE_H__
7 #define __AGGREGATE_UNIQUE_H__
8 
9 #include "../GenericRecord.hpp"
10 
11 namespace gpudb
12 {
13 
51  {
52 
58  tableName(std::string()),
59  columnName(std::string()),
60  offset(int64_t()),
61  limit(int64_t()),
62  encoding(std::string("binary")),
63  options(std::map<std::string, std::string>())
64  {
65  }
66 
173  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_):
174  tableName( tableName_ ),
175  columnName( columnName_ ),
176  offset( offset_ ),
177  limit( limit_ ),
178  encoding( "binary" ),
179  options( options_ )
180  {
181  }
182 
300  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_):
301  tableName( tableName_ ),
302  columnName( columnName_ ),
303  offset( offset_ ),
304  limit( limit_ ),
305  encoding( encoding_ ),
306  options( options_ )
307  {
308  }
309 
310  std::string tableName;
311  std::string columnName;
312  int64_t offset;
313  int64_t limit;
314  std::string encoding;
315  std::map<std::string, std::string> options;
316  };
317 }
318 
319 namespace avro
320 {
321  template<> struct codec_traits<gpudb::AggregateUniqueRequest>
322  {
323  static void encode(Encoder& e, const gpudb::AggregateUniqueRequest& v)
324  {
325  ::avro::encode(e, v.tableName);
326  ::avro::encode(e, v.columnName);
327  ::avro::encode(e, v.offset);
328  ::avro::encode(e, v.limit);
329  ::avro::encode(e, v.encoding);
330  ::avro::encode(e, v.options);
331  }
332 
333  static void decode(Decoder& d, gpudb::AggregateUniqueRequest& v)
334  {
335  if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
336  {
337  const std::vector<size_t> fo = rd->fieldOrder();
338 
339  for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
340  {
341  switch (*it)
342  {
343  case 0:
344  ::avro::decode(d, v.tableName);
345  break;
346 
347  case 1:
348  ::avro::decode(d, v.columnName);
349  break;
350 
351  case 2:
352  ::avro::decode(d, v.offset);
353  break;
354 
355  case 3:
356  ::avro::decode(d, v.limit);
357  break;
358 
359  case 4:
360  ::avro::decode(d, v.encoding);
361  break;
362 
363  case 5:
364  ::avro::decode(d, v.options);
365  break;
366 
367  default:
368  break;
369  }
370  }
371  }
372  else
373  {
374  ::avro::decode(d, v.tableName);
375  ::avro::decode(d, v.columnName);
376  ::avro::decode(d, v.offset);
377  ::avro::decode(d, v.limit);
378  ::avro::decode(d, v.encoding);
379  ::avro::decode(d, v.options);
380  }
381  }
382  };
383 }
384 
385 namespace gpudb
386 {
387 
425  {
426 
432  tableName(std::string()),
433  responseSchemaStr(std::string()),
434  binaryEncodedResponse(std::vector<uint8_t>()),
435  jsonEncodedResponse(std::string()),
436  hasMoreRecords(bool()),
437  info(std::map<std::string, std::string>())
438  {
439  }
440 
441  std::string tableName;
442  std::string responseSchemaStr;
443  std::vector<uint8_t> binaryEncodedResponse;
444  std::string jsonEncodedResponse;
446  std::map<std::string, std::string> info;
447  };
448 }
449 
450 namespace avro
451 {
452  template<> struct codec_traits<gpudb::RawAggregateUniqueResponse>
453  {
454  static void encode(Encoder& e, const gpudb::RawAggregateUniqueResponse& v)
455  {
456  ::avro::encode(e, v.tableName);
457  ::avro::encode(e, v.responseSchemaStr);
458  ::avro::encode(e, v.binaryEncodedResponse);
459  ::avro::encode(e, v.jsonEncodedResponse);
460  ::avro::encode(e, v.hasMoreRecords);
461  ::avro::encode(e, v.info);
462  }
463 
464  static void decode(Decoder& d, gpudb::RawAggregateUniqueResponse& v)
465  {
466  if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
467  {
468  const std::vector<size_t> fo = rd->fieldOrder();
469 
470  for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
471  {
472  switch (*it)
473  {
474  case 0:
475  ::avro::decode(d, v.tableName);
476  break;
477 
478  case 1:
479  ::avro::decode(d, v.responseSchemaStr);
480  break;
481 
482  case 2:
483  ::avro::decode(d, v.binaryEncodedResponse);
484  break;
485 
486  case 3:
487  ::avro::decode(d, v.jsonEncodedResponse);
488  break;
489 
490  case 4:
491  ::avro::decode(d, v.hasMoreRecords);
492  break;
493 
494  case 5:
495  ::avro::decode(d, v.info);
496  break;
497 
498  default:
499  break;
500  }
501  }
502  }
503  else
504  {
505  ::avro::decode(d, v.tableName);
506  ::avro::decode(d, v.responseSchemaStr);
507  ::avro::decode(d, v.binaryEncodedResponse);
508  ::avro::decode(d, v.jsonEncodedResponse);
509  ::avro::decode(d, v.hasMoreRecords);
510  ::avro::decode(d, v.info);
511  }
512  }
513  };
514 }
515 
516 namespace gpudb
517 {
518 
556  {
557 
563  tableName(std::string()),
564  responseSchemaStr(std::string()),
565  data(std::vector<gpudb::GenericRecord>()),
566  hasMoreRecords(bool()),
567  info(std::map<std::string, std::string>()),
568  dataTypePtr((gpudb::Type*)NULL)
569  {
570  }
571 
572  std::string tableName;
573  std::string responseSchemaStr;
574  std::vector<gpudb::GenericRecord> data;
576  std::map<std::string, std::string> info;
578  };
579 }
580 
581 #endif
AggregateUniqueRequest()
Constructs an AggregateUniqueRequest object with default parameter values.
boost::shared_ptr< Type > gpudb_type_ptr_t
std::vector< gpudb::GenericRecord > data
std::map< std::string, std::string > info
A set of input parameters for const.
A set of output parameters for const.
AggregateUniqueResponse()
Constructs an AggregateUniqueResponse object with default parameter values.
RawAggregateUniqueResponse()
Constructs a RawAggregateUniqueResponse object with default parameter values.
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
std::vector< uint8_t > binaryEncodedResponse
std::map< std::string, std::string > info
A set of output parameters for const.
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.