Uses of Class
com.amazonaws.athena.connectors.kafka.dto.TopicResultSet

Packages that use TopicResultSet

Package	Description
com.amazonaws.athena.connectors.kafka
com.amazonaws.athena.connectors.kafka.serde

Uses of TopicResultSet in com.amazonaws.athena.connectors.kafka

Methods in com.amazonaws.athena.connectors.kafka that return types with arguments of type TopicResultSet

Modifier and Type	Method	Description
static org.apache.kafka.clients.consumer.Consumer<String,TopicResultSet>	KafkaUtils.getKafkaConsumer(org.apache.arrow.vector.types.pojo.Schema schema, Map<String,String> configOptions)	Creates instance of Kafka consumer.

Uses of TopicResultSet in com.amazonaws.athena.connectors.kafka.serde

Methods in com.amazonaws.athena.connectors.kafka.serde that return TopicResultSet

Modifier and Type	Method	Description
TopicResultSet	KafkaCsvDeserializer.deserialize(String topic, byte[] data)
TopicResultSet	KafkaJsonDeserializer.deserialize(String topic, byte[] data)