ClickHouse/dbms/src/Storages/Kafka
2020-01-30 20:30:45 +01:00
..
Buffer_fwd.h Don't push to MVs when inserting into Kafka table (#7265) 2019-10-22 13:31:28 +03:00
KafkaBlockInputStream.cpp Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
KafkaBlockInputStream.h Test for flushing by time and by block size (+fix), one extra test for virual columns 2020-01-28 14:24:37 +01:00
KafkaBlockOutputStream.cpp Don't push to MVs when inserting into Kafka table (#7265) 2019-10-22 13:31:28 +03:00
KafkaBlockOutputStream.h Implement support for insertion into Kafka tables (#6012) 2019-08-20 14:17:57 +03:00
KafkaSettings.cpp Do not include Field.h everywhere through SettingsCommon.h. 2019-10-07 20:23:05 +03:00
KafkaSettings.h Add the ignorable flag for the settings. 2019-11-17 03:56:18 +03:00
ReadBufferFromKafkaConsumer.cpp Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
ReadBufferFromKafkaConsumer.h Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
StorageKafka.cpp Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
StorageKafka.h Merge branch 'master' into table_name_in_istorage 2019-12-30 14:08:09 +03:00
WriteBufferToKafkaProducer.cpp Implement support for insertion into Kafka tables (#6012) 2019-08-20 14:17:57 +03:00
WriteBufferToKafkaProducer.h Don't push to MVs when inserting into Kafka table (#7265) 2019-10-22 13:31:28 +03:00