cudf::io::external::kafka::kafka_consumer Member List

This is the complete list of members for cudf::io::external::kafka::kafka_consumer, including all inherited members.

close(int timeout)	cudf::io::external::kafka::kafka_consumer
commit_offset(std::string const &topic, int partition, int64_t offset)	cudf::io::external::kafka::kafka_consumer
create(std::string const &filepath, size_t offset=0, size_t max_size_estimate=0)	cudf::io::datasource	static
create(host_buffer const &buffer)	cudf::io::datasource	static
create(cudf::host_span< std::byte const > buffer)	cudf::io::datasource	static
create(cudf::device_span< std::byte const > buffer)	cudf::io::datasource	static
create(datasource *source)	cudf::io::datasource	static
create(std::vector< T > const &args)	cudf::io::datasource	inlinestatic
current_configs()	cudf::io::external::kafka::kafka_consumer
device_read(size_t offset, size_t size, rmm::cuda_stream_view stream)	cudf::io::datasource	inlinevirtual
device_read(size_t offset, size_t size, uint8_t *dst, rmm::cuda_stream_view stream)	cudf::io::datasource	inlinevirtual
device_read_async(size_t offset, size_t size, uint8_t *dst, rmm::cuda_stream_view stream)	cudf::io::datasource	inlinevirtual
get_committed_offset(std::string const &topic, int partition)	cudf::io::external::kafka::kafka_consumer
get_watermark_offset(std::string const &topic, int partition, int timeout, bool cached)	cudf::io::external::kafka::kafka_consumer
host_read(size_t offset, size_t size) override	cudf::io::external::kafka::kafka_consumer	virtual
host_read(size_t offset, size_t size, uint8_t *dst) override	cudf::io::external::kafka::kafka_consumer	virtual
is_device_read_preferred(size_t size) const	cudf::io::datasource	inlinevirtual
is_empty() const	cudf::io::datasource	inlinevirtual
kafka_consumer(std::map< std::string, std::string > configs, python_callable_type python_callable, kafka_oauth_callback_wrapper_type callable_wrapper)	cudf::io::external::kafka::kafka_consumer
kafka_consumer(std::map< std::string, std::string > configs, python_callable_type python_callable, kafka_oauth_callback_wrapper_type callable_wrapper, std::string const &topic_name, int partition, int64_t start_offset, int64_t end_offset, int batch_timeout, std::string const &delimiter)	cudf::io::external::kafka::kafka_consumer
list_topics(std::string specific_topic)	cudf::io::external::kafka::kafka_consumer
size() const override	cudf::io::external::kafka::kafka_consumer	virtual
supports_device_read() const	cudf::io::datasource	inlinevirtual
unsubscribe()	cudf::io::external::kafka::kafka_consumer
~datasource()	cudf::io::datasource	inlinevirtual
~kafka_consumer() (defined in cudf::io::external::kafka::kafka_consumer)	cudf::io::external::kafka::kafka_consumer	inlinevirtual