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

Class AbstractSourceNativeInfo<K extends Comparable<K>,N>

java.lang.Object

io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo<K,N>

Type Parameters:

K - the native key type.

N - the native data type.

All Implemented Interfaces:

Comparable<AbstractSourceNativeInfo<K,N>>

public abstract class AbstractSourceNativeInfo<K extends Comparable<K>,N>
extends Object
implements Comparable<AbstractSourceNativeInfo<K,N>>

An abstract implementation of NativeInfo handling for Source.

Field Summary

Fields

Modifier and Type	Field	Description
protected final NativeInfo<K,N>	nativeInfo	Package protected for NativeSourceData use
static final long	UNKNOWN_STREAM_LENGTH	Value to be returned when the length of the stream is unknown.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractSourceNativeInfo(NativeInfo<K,N> nativeInfo)	Constructor.

Method Summary

Modifier and Type	Method	Description
int	compareTo(AbstractSourceNativeInfo<K,N> other)
abstract long	estimateInputStreamLength()	Gets an estimate of the input stream length.
abstract Context	getContext()	Creates the context for the native info.
protected abstract InputStream	getInputStream()	Read the input data from the nativeInfo.
org.apache.commons.io.function.IOSupplier<InputStream>	getInputStreamSupplier()	Gets an InputStream supplier.
K	nativeKey()	Gets the native key.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

UNKNOWN_STREAM_LENGTH

public static final long UNKNOWN_STREAM_LENGTH

Value to be returned when the length of the stream is unknown.

See Also:

• Constant Field Values

nativeInfo

protected final NativeInfo<K extends Comparable<K>,N> nativeInfo

Package protected for NativeSourceData use

Constructor Details

AbstractSourceNativeInfo

protected AbstractSourceNativeInfo(NativeInfo<K,N> nativeInfo)

Constructor.

Parameters:

nativeInfo - the native info to process.

Method Details

nativeKey

public K nativeKey()

Gets the native key.

Returns:

the native key.

compareTo

public int compareTo(AbstractSourceNativeInfo<K,N> other)

Specified by:

compareTo in interface Comparable<K extends Comparable<K>>

getContext

public abstract Context getContext()

Creates the context for the native info.

Returns:

the context for the native Info.

toString

public String toString()

Overrides:

toString in class Object

getInputStreamSupplier

public org.apache.commons.io.function.IOSupplier<InputStream> getInputStreamSupplier()
                                                                              throws UnsupportedOperationException

Gets an InputStream supplier.

Returns:

the InputStream supplier.

Throws:

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

getInputStream

protected abstract InputStream getInputStream()
                                       throws IOException,
UnsupportedOperationException

Read the input data from the nativeInfo.

Returns:

the input stream

Throws:

IOException - on IO error.

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

estimateInputStreamLength

public abstract long estimateInputStreamLength()
                                        throws UnsupportedOperationException

Gets an estimate of the input stream length.

Returns:

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

Throws:

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