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

Packages that use TopicResultSet

Package	Description
com.amazonaws.athena.connectors.msk
com.amazonaws.athena.connectors.msk.consumer
com.amazonaws.athena.connectors.msk.serde

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

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

Modifier and Type	Method	Description
static org.apache.kafka.clients.consumer.Consumer<String,TopicResultSet>	AmazonMskUtils.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.msk.consumer

Method parameters in com.amazonaws.athena.connectors.msk.consumer with type arguments of type TopicResultSet

Modifier and Type	Method	Description
protected void	MskDefaultConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,TopicResultSet> record)

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

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

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