thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-30 05:30:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

removed test index

Browse Source
This commit is contained in:
Nikita Vasilev 2019-01-09 17:30:25 +03:00
parent 1e8fa5d9ea
commit d8f8b6352b
3 changed files with 0 additions and 101 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Storages/MergeTree/MergeTreeTestIndex.cpp
View File

@ -1,2 +0,0 @@
#include <Storages/MergeTree/MergeTreeTestIndex.h>

97
dbms/src/Storages/MergeTree/MergeTreeTestIndex.h
View File

@ -1,97 +0,0 @@
#pragma once
#include <Storages/MergeTree/MergeTreeIndexes.h>
#include <Storages/MergeTree/MergeTreeDataPart.h>
#include <Storages/MergeTree/MergeTreeData.h>
#include <IO/WriteHelpers.h>
#include <IO/ReadHelpers.h>
#include <iostream>
#include <random>
namespace DB {
namespace ErrorCodes
{
extern const int FILE_DOESNT_EXIST;
}
class MergeTreeTestIndex;
struct MergeTreeTestGranule : public MergeTreeIndexGranule {
~MergeTreeTestGranule() override = default;;
void serializeBinary(WriteBuffer &ostr) const override {
//std::cerr << "TESTINDEX: written " << emp << "\n";
writeIntBinary(emp, ostr);
}
void deserializeBinary(ReadBuffer &istr) override {
readIntBinary(emp, istr);
if (emp != 10) {
throw Exception("kek bad read", ErrorCodes::FILE_DOESNT_EXIST);
}
//std::cerr << "TESTINDEX: read " << emp << "\n";
}
String toString() const override {
return "test_index";
}
bool empty() const override {
return emp == 0;
}
void update(const Block &block, size_t *pos, size_t limit) override {
*pos += std::min(limit, block.rows() - *pos);
emp = 10;
};
Int32 emp = 0;
};
class IndexTestCondition : public IndexCondition{
public:
IndexTestCondition(int) {};
~IndexTestCondition() override = default;
/// Checks if this index is useful for query.
bool alwaysUnknownOrTrue() const override { return false; };
bool mayBeTrueOnGranule(MergeTreeIndexGranulePtr) const override {
return true;
}
};
class MergeTreeTestIndex : public MergeTreeIndex
{
public:
MergeTreeTestIndex(String name, ExpressionActionsPtr expr, size_t granularity)
: MergeTreeIndex(name, expr, granularity) {}
~MergeTreeTestIndex() override = default;
/// gets filename without extension
MergeTreeIndexGranulePtr createIndexGranule() const override {
return std::make_shared<MergeTreeTestGranule>();
}
IndexConditionPtr createIndexCondition(
const SelectQueryInfo & , const Context & ) const override {
return std::make_shared<IndexTestCondition>(4);
};
};
std::unique_ptr<MergeTreeIndex> MTItestCreator(
const MergeTreeData & data, std::shared_ptr<ASTIndexDeclaration> node, const Context & ) {
return std::make_unique<MergeTreeTestIndex>(
node->name, data.primary_key_expr, node->granularity.get<size_t>());
}
}

2
dbms/src/Storages/MergeTree/registerStorageMergeTree.cpp
View File

@ -2,7 +2,6 @@
#include <Storages/StorageMergeTree.h>
#include <Storages/StorageReplicatedMergeTree.h>
#include <Storages/MergeTree/MergeTreeIndexes.h>
#include <Storages/MergeTree/MergeTreeTestIndex.h>
#include <Storages/MergeTree/MergeTreeMinMaxIndex.h>
#include <Common/typeid_cast.h>
@ -638,7 +637,6 @@ static StoragePtr create(const StorageFactory::Arguments & args)
static void registerMergeTreeSkipIndexes() {
auto & factory = MergeTreeIndexFactory::instance();
factory.registerIndex("test", MTItestCreator);
factory.registerIndex("minmax", MergeTreeMinMaxIndexCreator);
}