Package io.aiven.commons.kafka.connector.source.impl.csv

Class ExampleCsvSourceNativeInfo

java.lang.Object

io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo<String,ByteBuffer>

io.aiven.commons.kafka.connector.source.impl.csv.ExampleCsvSourceNativeInfo

All Implemented Interfaces:

Comparable<AbstractSourceNativeInfo<String,ByteBuffer>>

public class ExampleCsvSourceNativeInfo
extends AbstractSourceNativeInfo<String,ByteBuffer>

This example data object has a String key and a byte buffer as its data object.

Field Summary

Fields inherited from class io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo

nativeInfo, UNKNOWN_STREAM_LENGTH

Constructor Summary

Constructors

Constructor	Description
ExampleCsvSourceNativeInfo(ExampleNativeItem item)	Constructor.

Method Summary

Modifier and Type	Method	Description
long	estimateInputStreamLength()	Gets an estimate of the input stream length.
Context	getContext()	Creates the context for the native info.
protected InputStream	getInputStream()	Read the input data from the nativeInfo.

Methods inherited from class io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo

compareTo, getInputStreamSupplier, nativeKey, toString

Methods inherited from class java.lang.Object

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

Constructor Details

ExampleCsvSourceNativeInfo

public ExampleCsvSourceNativeInfo(ExampleNativeItem item)

Constructor.

Parameters:

item - the ExampleNativeItem comprising a key of String and a data item of ByteBuffer.

Method Details

getContext

public Context getContext()

Description copied from class: AbstractSourceNativeInfo

Creates the context for the native info.

Specified by:

getContext in class AbstractSourceNativeInfo<String,ByteBuffer>

Returns:

the context for the native Info.

getInputStream

protected InputStream getInputStream()
                              throws IOException

Description copied from class: AbstractSourceNativeInfo

Read the input data from the nativeInfo.

Specified by:

getInputStream in class AbstractSourceNativeInfo<String,ByteBuffer>

Returns:

the input stream

Throws:

IOException - on IO error.

estimateInputStreamLength

public long estimateInputStreamLength()
                               throws UnsupportedOperationException

Description copied from class: AbstractSourceNativeInfo

Gets an estimate of the input stream length.

Specified by:

estimateInputStreamLength in class AbstractSourceNativeInfo<String,ByteBuffer>

Returns:

an estimate of the input stream length, or AbstractSourceNativeInfo.UNKNOWN_STREAM_LENGTH if not known.

Throws:

UnsupportedOperationException - if the underlying NativeInfo does not support input streams.