2022-08-08 14:10:50 +00:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include "config_core.h"
|
|
|
|
|
|
|
|
#include <Storages/IStorage.h>
|
2022-08-22 09:37:20 +00:00
|
|
|
#include <Storages/StorageS3.h>
|
|
|
|
|
|
|
|
namespace Poco {
|
|
|
|
class Logger;
|
|
|
|
}
|
|
|
|
|
|
|
|
namespace Aws::S3
|
|
|
|
{
|
|
|
|
class S3Client;
|
|
|
|
}
|
2022-08-08 14:10:50 +00:00
|
|
|
|
|
|
|
namespace DB
|
|
|
|
{
|
|
|
|
|
|
|
|
class StorageHudi final : public IStorage {
|
|
|
|
public:
|
|
|
|
StorageHudi(
|
2022-08-22 09:37:20 +00:00
|
|
|
const S3::URI& uri_,
|
|
|
|
const String& access_key_,
|
|
|
|
const String& secret_access_key_,
|
2022-08-08 14:10:50 +00:00
|
|
|
const StorageID & table_id_,
|
|
|
|
ColumnsDescription columns_description_,
|
|
|
|
ConstraintsDescription constraints_description_,
|
2022-08-22 09:37:20 +00:00
|
|
|
const String & comment,
|
|
|
|
ContextPtr context_
|
|
|
|
);
|
2022-08-08 14:10:50 +00:00
|
|
|
|
|
|
|
String getName() const override { return "Hudi"; }
|
2022-08-22 09:37:20 +00:00
|
|
|
|
|
|
|
private:
|
|
|
|
static void updateS3Configuration(ContextPtr, StorageS3::S3Configuration &);
|
|
|
|
|
|
|
|
private:
|
|
|
|
StorageS3::S3Configuration s3_configuration;
|
|
|
|
Poco::Logger * log;
|
2022-08-08 14:10:50 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
}
|