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

Packages that use SplitParameters

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

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

Methods in com.amazonaws.athena.connectors.msk that return SplitParameters

Modifier and Type	Method	Description
static SplitParameters	AmazonMskUtils.createSplitParam(Map<String,String> params)	Translates Split parameters as readable pojo format.

Uses of SplitParameters in com.amazonaws.athena.connectors.msk.consumer

Methods in com.amazonaws.athena.connectors.msk.consumer with parameters of type SplitParameters

Modifier and Type	Method	Description
void	BaseMskConsumer.consume(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, SplitParameters splitParameters, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	MskConsumer.consume(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, SplitParameters splitParameters, org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer)	Consume topic data as batch.
protected abstract void	BaseMskConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)
protected void	MskAvroConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,org.apache.avro.generic.GenericRecord> record)
protected void	MskDefaultConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,TopicResultSet> record)
protected void	MskProtobufConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,com.google.protobuf.DynamicMessage> record)
void	MskRecordProcessor.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)