6 #ifndef __CREATE_JOB_H__ 7 #define __CREATE_JOB_H__ 28 data(std::vector<uint8_t>()),
30 options(std::map<std::string, std::string>())
82 CreateJobRequest(
const std::string& endpoint_,
const std::string& requestEncoding_,
const std::vector<uint8_t>& data_,
const std::string& dataStr_,
const std::map<std::string, std::string>& options_):
146 template<>
struct codec_traits<
gpudb::CreateJobRequest>
152 ::avro::encode(e, v.
data);
159 if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
161 const std::vector<size_t> fo = rd->fieldOrder();
163 for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
176 ::avro::decode(d, v.
data);
196 ::avro::decode(d, v.
data);
217 info(std::map<std::string, std::string>())
238 std::map<std::string, std::string>
info;
244 template<>
struct codec_traits<
gpudb::CreateJobResponse>
248 ::avro::encode(e, v.
jobId);
249 ::avro::encode(e, v.
info);
254 if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
256 const std::vector<size_t> fo = rd->fieldOrder();
258 for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
263 ::avro::decode(d, v.
jobId);
267 ::avro::decode(d, v.
info);
277 ::avro::decode(d, v.
jobId);
278 ::avro::decode(d, v.
info);
284 #endif // __CREATE_JOB_H__
std::string dataStr
JSON-encoded payload for the job to be run asynchronously.
CreateJobRequest(const std::string &endpoint_, const std::string &requestEncoding_, const std::vector< uint8_t > &data_, const std::string &dataStr_, const std::map< std::string, std::string > &options_)
Constructs a CreateJobRequest object with the specified parameters.
A set of parameters for GPUdb::createJob.
CreateJobResponse()
Constructs a CreateJobResponse object with default parameters.
std::map< std::string, std::string > info
Additional information.
int64_t jobId
An identifier for the job created by this call.
std::string requestEncoding
The encoding of the request payload for the job.
CreateJobRequest()
Constructs a CreateJobRequest object with default parameters.
std::string endpoint
Indicates which endpoint to execute, e.g. '/alter/table'.
std::map< std::string, std::string > options
Optional parameters.
std::vector< uint8_t > data
Binary-encoded payload for the job to be run asynchronously.
A set of results returned by GPUdb::createJob.