blob: 7de5764d2a246735c6586eab96361612055f9a18 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
|
#include <Storages/registerStorages.h>
#include <Storages/StorageFactory.h>
#include "clickhouse_config.h"
namespace DB
{
void registerStorageLog(StorageFactory & factory);
void registerStorageStripeLog(StorageFactory & factory);
void registerStorageMergeTree(StorageFactory & factory);
void registerStorageNull(StorageFactory & factory);
void registerStorageMerge(StorageFactory & factory);
void registerStorageBuffer(StorageFactory & factory);
void registerStorageDistributed(StorageFactory & factory);
void registerStorageMemory(StorageFactory & factory);
void registerStorageFile(StorageFactory & factory);
void registerStorageURL(StorageFactory & factory);
void registerStorageDictionary(StorageFactory & factory);
void registerStorageSet(StorageFactory & factory);
void registerStorageJoin(StorageFactory & factory);
void registerStorageView(StorageFactory & factory);
void registerStorageMaterializedView(StorageFactory & factory);
void registerStorageLiveView(StorageFactory & factory);
void registerStorageGenerateRandom(StorageFactory & factory);
void registerStorageExecutable(StorageFactory & factory);
void registerStorageWindowView(StorageFactory & factory);
// MEILISEARCH
void registerStorageMeiliSearch(StorageFactory& factory);
#if USE_AWS_S3
void registerStorageS3(StorageFactory & factory);
void registerStorageCOS(StorageFactory & factory);
void registerStorageOSS(StorageFactory & factory);
void registerStorageHudi(StorageFactory & factory);
void registerStorageS3Queue(StorageFactory & factory);
#if USE_PARQUET
void registerStorageDeltaLake(StorageFactory & factory);
#endif
#if USE_AVRO
void registerStorageIceberg(StorageFactory & factory);
#endif
#endif
#if USE_HDFS
void registerStorageHDFS(StorageFactory & factory);
#if USE_HIVE
void registerStorageHive(StorageFactory & factory);
#endif
#endif
void registerStorageODBC(StorageFactory & factory);
void registerStorageJDBC(StorageFactory & factory);
#if USE_MYSQL
void registerStorageMySQL(StorageFactory & factory);
#endif
void registerStorageMongoDB(StorageFactory & factory);
void registerStorageRedis(StorageFactory & factory);
#if USE_RDKAFKA
void registerStorageKafka(StorageFactory & factory);
#endif
#if USE_AMQPCPP
void registerStorageRabbitMQ(StorageFactory & factory);
#endif
#if USE_NATSIO
void registerStorageNATS(StorageFactory & factory);
#endif
#if USE_ROCKSDB
void registerStorageEmbeddedRocksDB(StorageFactory & factory);
#endif
#if USE_LIBPQXX
void registerStoragePostgreSQL(StorageFactory & factory);
void registerStorageMaterializedPostgreSQL(StorageFactory & factory);
#endif
#if USE_MYSQL || USE_LIBPQXX
void registerStorageExternalDistributed(StorageFactory & factory);
#endif
#if USE_FILELOG
void registerStorageFileLog(StorageFactory & factory);
#endif
#if USE_SQLITE
void registerStorageSQLite(StorageFactory & factory);
#endif
void registerStorageKeeperMap(StorageFactory & factory);
#if USE_AZURE_BLOB_STORAGE
void registerStorageAzureBlob(StorageFactory & factory);
#endif
void registerStorages()
{
auto & factory = StorageFactory::instance();
registerStorageLog(factory);
registerStorageStripeLog(factory);
registerStorageMergeTree(factory);
registerStorageNull(factory);
registerStorageMerge(factory);
registerStorageBuffer(factory);
registerStorageDistributed(factory);
registerStorageMemory(factory);
registerStorageFile(factory);
registerStorageURL(factory);
registerStorageDictionary(factory);
registerStorageSet(factory);
registerStorageJoin(factory);
registerStorageView(factory);
registerStorageMaterializedView(factory);
registerStorageLiveView(factory);
registerStorageGenerateRandom(factory);
registerStorageExecutable(factory);
registerStorageWindowView(factory);
// MEILISEARCH
registerStorageMeiliSearch(factory);
#if USE_AWS_S3
registerStorageS3(factory);
registerStorageCOS(factory);
registerStorageOSS(factory);
registerStorageHudi(factory);
registerStorageS3Queue(factory);
#if USE_PARQUET
registerStorageDeltaLake(factory);
#endif
#if USE_AVRO
registerStorageIceberg(factory);
#endif
#endif
#if USE_HDFS
registerStorageHDFS(factory);
#if USE_HIVE
registerStorageHive(factory);
#endif
#endif
registerStorageODBC(factory);
registerStorageJDBC(factory);
#if USE_MYSQL
registerStorageMySQL(factory);
#endif
// registerStorageMongoDB(factory);
registerStorageRedis(factory);
#if USE_RDKAFKA
registerStorageKafka(factory);
#endif
#if USE_FILELOG
registerStorageFileLog(factory);
#endif
#if USE_AMQPCPP
registerStorageRabbitMQ(factory);
#endif
#if USE_NATSIO
registerStorageNATS(factory);
#endif
#if USE_ROCKSDB
registerStorageEmbeddedRocksDB(factory);
#endif
#if USE_LIBPQXX
registerStoragePostgreSQL(factory);
registerStorageMaterializedPostgreSQL(factory);
#endif
#if USE_MYSQL || USE_LIBPQXX
registerStorageExternalDistributed(factory);
#endif
#if USE_SQLITE
registerStorageSQLite(factory);
#endif
registerStorageKeeperMap(factory);
#if USE_AZURE_BLOB_STORAGE
registerStorageAzureBlob(factory);
#endif
}
}
|
