![]() |
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.
1.7.6.1