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

Merge branch 'feature/randomASKII-function' of github.com:BayoNet/ClickHouse into feature/randomASKII-function

Browse Source
This commit is contained in:
Sergey Shtykov 2019-11-15 17:31:20 +03:00
commit feb68bc513
1 changed files with 75 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
dbms/src/Functions/randomASKII.cpp
View File

@ -13,35 +13,94 @@ class FunctionRandomASKII : public IFunction
public:
static constexpr auto name = "randomASKII";
static FunctionPtr create(const Context &)
{
return std::make_shared<FunctionRandomASKII>();
}
explicit FunctionRandomASKII()
{
}
static FunctionPtr create(const Context &){ return std::make_shared<FunctionRandomASKII>(); }
String getName() const override
{
return name;
}
size_t getNumberOfArguments() const override
size_t getNumberOfArguments() const override { return 1; }
DataTypePtr getReturnTypeImpl(const DataTypes & arguments) const override
{
return 0;
return std::make_shared<DataTypeString>()
}
DataTypePtr getReturnTypeImpl(const DataTypes & /*arguments*/) const override
void executeImpl(Block & block, const ColumnNumbers & arguments, size_t result, size_t /*input_rows_count*/) override
{
return std::make_shared<DataTypeString>();
if (!(executeType<UInt8>(block, arguments, result)
|| executeType<UInt16>(block, arguments, result)
|| executeType<UInt32>(block, arguments, result)
|| executeType<UInt64>(block, arguments, result)
|| executeType<Int8>(block, arguments, result)
|| executeType<Int16>(block, arguments, result)
|| executeType<Int32>(block, arguments, result)
|| executeType<Int64>(block, arguments, result)
|| executeType<Float32>(block, arguments, result)
|| executeType<Float64>(block, arguments, result)))
throw Exception("Illegal column " + block.getByPosition(arguments[0]).column->getName()
+ " of argument of function " + getName(),
ErrorCodes::ILLEGAL_COLUMN);
}
bool isDeterministic() const override { return false; }
void executeImpl(Block & block, const ColumnNumbers &, size_t result, size_t input_rows_count) override
private:
template <typename T>
bool executeType(Block & block, const ColumnNumbers & arguments, size_t result)
{
block.getByPosition(result).column = DataTypeString().createColumnConst(input_rows_count, "randomASKII");
if (const ColumnVector<T> * col_from = checkAndGetColumn<ColumnVector<T>>(block.getByPosition(arguments[0]).column.get()))
{
auto col_to = ColumnString::create();
const typename ColumnVector<T>::Container & vec_from = col_from->getData();
ColumnString::Chars & data_to = col_to->getChars();
ColumnString::Offsets & offsets_to = col_to->getOffsets();
size_t size = vec_from.size();
data_to.resize(size * 2);
offsets_to.resize(size);
WriteBufferFromVector<ColumnString::Chars> buf_to(data_to);
for (size_t i = 0; i < size; ++i)
{
// formatReadableSizeWithBinarySuffix(static_cast<double>(vec_from[i]), buf_to);
// writeChar(0, buf_to);
// offsets_to[i] = buf_to.count();
}
buf_to.finish();
// block.getByPosition(result).column = std::move(col_to);
block.getByPosition(result).column = DataTypeString().createColumnConst(input_rows_count, "randomASKII");
return true;
}
return false;
}
// explicit FunctionRandomASKII()
// {
// }
// size_t getNumberOfArguments() const override
// {
// return 0;
// }
// DataTypePtr getReturnTypeImpl(const DataTypes & /*arguments*/) const override
// {
// return std::make_shared<DataTypeString>();
// }
// bool isDeterministic() const override { return false; }
// void executeImpl(Block & block, const ColumnNumbers &, size_t result, size_t input_rows_count) override
// {
// block.getByPosition(result).column = DataTypeString().createColumnConst(input_rows_count, "randomASKII");
// }
};