diff --git a/dbms/src/Processors/Formats/Impl/BinaryRowOutputFormat.h b/dbms/src/Processors/Formats/Impl/BinaryRowOutputFormat.h index 626553a0eb3..35b8a7b734e 100644 --- a/dbms/src/Processors/Formats/Impl/BinaryRowOutputFormat.h +++ b/dbms/src/Processors/Formats/Impl/BinaryRowOutputFormat.h @@ -24,8 +24,6 @@ public: void writeField(const IColumn & column, const IDataType & type, size_t row_num) override; void writePrefix() override; - void flush() override; - String getContentType() const override { return "application/octet-stream"; } protected: diff --git a/dbms/src/Processors/Formats/Impl/CapnProtoRowInputFormat.cpp b/dbms/src/Processors/Formats/Impl/CapnProtoRowInputFormat.cpp index 8466cd99a5a..f0b093870f0 100644 --- a/dbms/src/Processors/Formats/Impl/CapnProtoRowInputFormat.cpp +++ b/dbms/src/Processors/Formats/Impl/CapnProtoRowInputFormat.cpp @@ -308,7 +308,7 @@ void registerInputFormatProcessorCapnProto(FormatFactory & factory) namespace DB { class FormatFactory; - void registerInputFormatCapnProto(FormatFactory &) {} + void registerInputFormatProcessorCapnProto(FormatFactory &) {} } #endif // USE_CAPNP diff --git a/dbms/src/Processors/Formats/Impl/JSONRowOutputFormat.cpp b/dbms/src/Processors/Formats/Impl/JSONRowOutputFormat.cpp index 3d210d4fc86..93f8cf19786 100644 --- a/dbms/src/Processors/Formats/Impl/JSONRowOutputFormat.cpp +++ b/dbms/src/Processors/Formats/Impl/JSONRowOutputFormat.cpp @@ -242,7 +242,7 @@ void JSONRowOutputFormat::onProgress(const Progress & value) } -void registerOutputFormatProcessorProcessorJSON(FormatFactory & factory) +void registerOutputFormatProcessorJSON(FormatFactory & factory) { factory.registerOutputFormatProcessor("JSON", []( WriteBuffer & buf, diff --git a/dbms/src/Processors/Formats/Impl/NativeFormat.cpp b/dbms/src/Processors/Formats/Impl/NativeFormat.cpp index 8ff0d7e5724..aab081afbdc 100644 --- a/dbms/src/Processors/Formats/Impl/NativeFormat.cpp +++ b/dbms/src/Processors/Formats/Impl/NativeFormat.cpp @@ -142,7 +142,7 @@ private: } }; -void registerInputFormatNativeProcessor(FormatFactory & factory) +void registerInputFormatProcessorNative(FormatFactory & factory) { factory.registerInputFormatProcessor("Native", []( ReadBuffer & buf, @@ -155,7 +155,7 @@ void registerInputFormatNativeProcessor(FormatFactory & factory) }); } -void registerOutputFormatNativeProcessor(FormatFactory & factory) +void registerOutputFormatProcessorNative(FormatFactory & factory) { factory.registerOutputFormatProcessor("Native", []( WriteBuffer & buf, diff --git a/dbms/src/Processors/Formats/Impl/ODBCDriver2BlockOutputFormat.cpp b/dbms/src/Processors/Formats/Impl/ODBCDriver2BlockOutputFormat.cpp index a81838ce64a..916b9038781 100644 --- a/dbms/src/Processors/Formats/Impl/ODBCDriver2BlockOutputFormat.cpp +++ b/dbms/src/Processors/Formats/Impl/ODBCDriver2BlockOutputFormat.cpp @@ -16,7 +16,7 @@ ODBCDriver2BlockOutputFormat::ODBCDriver2BlockOutputFormat( { } -void writeODBCString(WriteBuffer & out, const std::string & str) +static void writeODBCString(WriteBuffer & out, const std::string & str) { writeIntBinary(Int32(str.size()), out); out.write(str.data(), str.size());