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

Class MskAvroConsumer

java.lang.Object

com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer<org.apache.avro.generic.GenericRecord>

com.amazonaws.athena.connectors.msk.consumer.MskAvroConsumer

All Implemented Interfaces:

MskConsumer

public class MskAvroConsumer
extends BaseMskConsumer<org.apache.avro.generic.GenericRecord>

Field Summary

Fields inherited from class com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer

MAX_EMPTY_RESULT_FOUND_COUNT

Constructor Summary

Constructors

Constructor	Description
MskAvroConsumer()

Method Summary

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

Methods inherited from class com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer

consume

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MskAvroConsumer

public MskAvroConsumer()

Method Detail

processRecord

protected void processRecord(BlockSpiller spiller,
                             SplitParameters splitParameters,
                             org.apache.kafka.clients.consumer.ConsumerRecord<String,org.apache.avro.generic.GenericRecord> record)

Specified by:

processRecord in class BaseMskConsumer<org.apache.avro.generic.GenericRecord>