greenplumn s3common_writer 源码

  • 2022-08-18
  • 浏览 (506)

greenplumn s3common_writer 代码

文件路径:/gpcontrib/gpcloud/src/s3common_writer.cpp

#include "s3common_writer.h"

void S3CommonWriter::open(const S3Params& params) {
    this->keyWriter.setS3InterfaceService(this->s3InterfaceService);

    if (params.isAutoCompress()) {
        this->upstreamWriter = &this->compressWriter;
        this->compressWriter.setWriter(&this->keyWriter);
    } else {
        this->upstreamWriter = &this->keyWriter;
    }

    this->upstreamWriter->open(params);
}

uint64_t S3CommonWriter::write(const char* buf, uint64_t count) {
    return this->upstreamWriter->write(buf, count);
}

void S3CommonWriter::close() {
    if (this->upstreamWriter != NULL) {
        this->upstreamWriter->close();
    }
}

相关信息

greenplumn 源码目录

相关文章

greenplumn compress_writer 源码

greenplumn decompress_reader 源码

greenplumn gpcloud 源码

greenplumn gpreader 源码

greenplumn gpwriter 源码

greenplumn s3bucket_reader 源码

greenplumn s3common_reader 源码

greenplumn s3conf 源码

greenplumn s3http_headers 源码

greenplumn s3interface 源码

0  赞