ClickHouse/src/Storages/StorageInput.h

34 lines
750 B
C++
Raw Normal View History

2019-05-28 18:27:00 +00:00
#pragma once
2021-10-16 14:03:50 +00:00
#include <QueryPipeline/Pipe.h>
#include <Storages/IStorage.h>
2019-05-28 18:27:00 +00:00
namespace DB
{
2019-05-29 21:38:28 +00:00
/** Internal temporary storage for table function input(...)
2019-05-29 20:59:03 +00:00
*/
2019-05-28 18:27:00 +00:00
class StorageInput final : public IStorage
2019-05-28 18:27:00 +00:00
{
public:
StorageInput(const StorageID & table_id, const ColumnsDescription & columns_);
2019-05-28 18:27:00 +00:00
String getName() const override { return "Input"; }
2019-05-29 21:38:28 +00:00
/// A table will read from this stream.
2021-07-20 18:18:43 +00:00
void setPipe(Pipe pipe_);
2019-05-28 18:27:00 +00:00
2020-08-03 13:54:14 +00:00
Pipe read(
2019-05-28 18:27:00 +00:00
const Names & column_names,
const StorageSnapshotPtr & storage_snapshot,
SelectQueryInfo & query_info,
ContextPtr context,
2019-05-28 18:27:00 +00:00
QueryProcessingStage::Enum processed_stage,
size_t max_block_size,
size_t num_streams) override;
2019-05-28 18:27:00 +00:00
private:
2021-07-20 18:18:43 +00:00
Pipe pipe;
2019-05-28 18:27:00 +00:00
};
}