#include #include #include #include #include namespace DB { namespace { class FunctionTid : public IFunction { public: static constexpr auto name = "tid"; static FunctionPtr create(const Context &) { return std::make_shared(); } String getName() const override { return name; } size_t getNumberOfArguments() const override { return 0; } DataTypePtr getReturnTypeImpl(const DataTypes &) const override { return std::make_shared(); } void executeImpl(Block & block, const ColumnNumbers &, size_t result, size_t) const override { UInt64 current_tid = std::hash{}(std::this_thread::get_id()); block.getByPosition(result).column = DataTypeUInt64().createColumnConst(1, current_tid); } }; } void registerFunctionTid(FunctionFactory & factory) { factory.registerFunction(); } }