Package com.amazonaws.athena.connectors.kafka.dto

Class SplitParameters

java.lang.Object

com.amazonaws.athena.connectors.kafka.dto.SplitParameters

public class SplitParameters
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	END_OFFSET
long	endOffset
String	info
int	partition
static String	PARTITION
long	pulled
long	spilled
static String	START_OFFSET
long	startOffset
String	topic
static String	TOPIC

Constructor Summary

Constructors

Constructor	Description
SplitParameters(String topic, int partition, long startOffset, long endOffset)	These parameters need to be set while creating the split and will be used when retrieving records in RecordHandler class.

Method Summary

Modifier and Type	Method	Description
String	debug()	For debug insight.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

TOPIC

public static final String TOPIC

See Also:

Constant Field Values

PARTITION

public static final String PARTITION

See Also:

Constant Field Values

START_OFFSET

public static final String START_OFFSET

See Also:

Constant Field Values

END_OFFSET

public static final String END_OFFSET

See Also:

Constant Field Values

topic

public final String topic

partition

public final int partition

startOffset

public final long startOffset

endOffset

public final long endOffset

pulled

public long pulled

spilled

public long spilled

info

public String info

Constructor Detail

SplitParameters

public SplitParameters(String topic,
                       int partition,
                       long startOffset,
                       long endOffset)

These parameters need to be set while creating the split and will be used when retrieving records in RecordHandler class.

Parameters:

topic -

partition -

startOffset -

endOffset -

Method Detail

toString

public String toString()

Overrides:

toString in class Object

debug

public String debug()

For debug insight. To know what happens in the RecordHandler across in all the splits. We write log message as comma separated value with intention to create a csv. Simply in the Cloudwatch log we will search by SplitParameters then we will get these related log messages in once place and download as csv, great! The header of the csv file is: debug,topic,partition,start_offset,end_offset,pulled,spilled,missing,info Note that the header missing means - we should not spill these