diff --git a/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.cpp b/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.cpp index 59a8d176f32..0b3fb3d58ed 100644 --- a/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.cpp +++ b/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.cpp @@ -165,14 +165,16 @@ bool MsgPackRowInputFormat::readRow(MutableColumns & columns, RowReadExtension & return true; } -void registerInputFormatProcessorMsgPack(FormatFactory & factory) { +void registerInputFormatProcessorMsgPack(FormatFactory & factory) +{ factory.registerInputFormatProcessor("MsgPack", []( ReadBuffer &buf, const Block &sample, const RowInputFormatParams ¶ms, - const FormatSettings &) { + const FormatSettings &) + { return std::make_shared(sample, buf, params); }); } -} \ No newline at end of file +} diff --git a/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.h b/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.h index b2f14fca6f6..7daac811374 100644 --- a/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.h +++ b/dbms/src/Processors/Formats/Impl/MsgPackRowInputFormat.h @@ -25,4 +25,4 @@ private: msgpack::object_handle object_handle; }; -} \ No newline at end of file +} diff --git a/dbms/src/Processors/Formats/Impl/MsgPackRowOutputFormat.cpp b/dbms/src/Processors/Formats/Impl/MsgPackRowOutputFormat.cpp index b4cb7185406..7c5e2c5b522 100644 --- a/dbms/src/Processors/Formats/Impl/MsgPackRowOutputFormat.cpp +++ b/dbms/src/Processors/Formats/Impl/MsgPackRowOutputFormat.cpp @@ -150,4 +150,4 @@ void registerOutputFormatProcessorMsgPack(FormatFactory & factory) }); } -} \ No newline at end of file +}