![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
#include <cloud_output.h>
Public Member Functions | |
CloudSink (const std::string &uri="", bool append=true, bool disambiguate=true) | |
void | open (const std::string &uri, bool append, bool disambiguate) |
virtual void | close () |
virtual size_t | write (const char *data, size_t size) |
virtual size_t | flush (FileFlushLevel flushLevel) |
Public Attributes | |
std::string | currentUri_ |
Uri of cloud we're writing to. | |
std::string | tmpFileDir_ |
ML::filter_ostream | cloudStream |
Current stream to the cloud (TM) | |
ML::filter_ostream | fileStream |
Class that writes to a cloud.
Definition at line 28 of file cloud_output.h.
void Datacratic::CloudSink::close | ( | ) | [virtual] |
Function that closes the given sink.
Implements Datacratic::CompressingOutput::Sink.
Definition at line 50 of file cloud_output.cc.
size_t Datacratic::CloudSink::flush | ( | FileFlushLevel | flushLevel | ) | [virtual] |
Function that should be overwritten when the stream needs to be flushed to make sure that the data gets to disk.
Implements Datacratic::CompressingOutput::Sink.
Definition at line 71 of file cloud_output.cc.
size_t Datacratic::CloudSink::write | ( | const char * | data, |
size_t | size | ||
) | [virtual] |
Function that should be overwritten to write data when it's output by the compressor.
Implements Datacratic::CompressingOutput::Sink.
Definition at line 61 of file cloud_output.cc.