mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-27 01:51:59 +00:00
dbms: tiny fixes [#CONV-2944].
This commit is contained in:
parent
b664e10a37
commit
686878a5fb
@ -6,7 +6,7 @@
|
|||||||
namespace DB
|
namespace DB
|
||||||
{
|
{
|
||||||
|
|
||||||
/** Интерфейс потока для вывода данных в формате tsv, но без эскейпинга отдельных значений.
|
/** Поток для вывода данных в формате tsv, но без эскейпинга отдельных значений.
|
||||||
* (То есть - вывод необратимый.)
|
* (То есть - вывод необратимый.)
|
||||||
*/
|
*/
|
||||||
class TabSeparatedRawRowOutputStream : public TabSeparatedRowOutputStream
|
class TabSeparatedRawRowOutputStream : public TabSeparatedRowOutputStream
|
||||||
|
@ -10,10 +10,7 @@
|
|||||||
namespace DB
|
namespace DB
|
||||||
{
|
{
|
||||||
|
|
||||||
using Poco::SharedPtr;
|
/** Поток для ввода данных в формате tsv.
|
||||||
|
|
||||||
|
|
||||||
/** Интерфейс потока для ввода данных в формате tsv.
|
|
||||||
*/
|
*/
|
||||||
class TabSeparatedRowInputStream : public IRowInputStream
|
class TabSeparatedRowInputStream : public IRowInputStream
|
||||||
{
|
{
|
||||||
@ -26,7 +23,7 @@ public:
|
|||||||
Row read();
|
Row read();
|
||||||
void readPrefix();
|
void readPrefix();
|
||||||
|
|
||||||
RowInputStreamPtr clone() { return new TabSeparatedRowInputStream(istr, sample); }
|
RowInputStreamPtr clone() { return new TabSeparatedRowInputStream(istr, sample, with_names, with_types); }
|
||||||
|
|
||||||
private:
|
private:
|
||||||
ReadBuffer & istr;
|
ReadBuffer & istr;
|
||||||
|
@ -10,10 +10,7 @@
|
|||||||
namespace DB
|
namespace DB
|
||||||
{
|
{
|
||||||
|
|
||||||
using Poco::SharedPtr;
|
/** Поток для вывода данных в формате tsv.
|
||||||
|
|
||||||
|
|
||||||
/** Интерфейс потока для вывода данных в формате tsv.
|
|
||||||
*/
|
*/
|
||||||
class TabSeparatedRowOutputStream : public IRowOutputStream
|
class TabSeparatedRowOutputStream : public IRowOutputStream
|
||||||
{
|
{
|
||||||
|
@ -13,7 +13,7 @@ namespace DB
|
|||||||
using Poco::SharedPtr;
|
using Poco::SharedPtr;
|
||||||
|
|
||||||
|
|
||||||
/** Интерфейс потока для чтения данных в формате VALUES (как в INSERT запросе).
|
/** Поток для чтения данных в формате VALUES (как в INSERT запросе).
|
||||||
*/
|
*/
|
||||||
class ValuesRowInputStream : public IRowInputStream
|
class ValuesRowInputStream : public IRowInputStream
|
||||||
{
|
{
|
||||||
|
@ -13,7 +13,7 @@ namespace DB
|
|||||||
using Poco::SharedPtr;
|
using Poco::SharedPtr;
|
||||||
|
|
||||||
|
|
||||||
/** Интерфейс потока для вывода данных в формате VALUES (как в INSERT запросе).
|
/** Поток для вывода данных в формате VALUES (как в INSERT запросе).
|
||||||
*/
|
*/
|
||||||
class ValuesRowOutputStream : public IRowOutputStream
|
class ValuesRowOutputStream : public IRowOutputStream
|
||||||
{
|
{
|
||||||
|
@ -14,7 +14,7 @@ namespace DB
|
|||||||
using Poco::SharedPtr;
|
using Poco::SharedPtr;
|
||||||
|
|
||||||
|
|
||||||
/** Интерфейс потока для вывода данных в формате "каждое значение на своей строке".
|
/** Поток для вывода данных в формате "каждое значение на своей строке".
|
||||||
*/
|
*/
|
||||||
class VerticalRowOutputStream : public IRowOutputStream
|
class VerticalRowOutputStream : public IRowOutputStream
|
||||||
{
|
{
|
||||||
|
Loading…
Reference in New Issue
Block a user