Package org.apache.flink.connector.base.source.reader

Class SourceReaderOptions

java.lang.Object

org.apache.flink.connector.base.source.reader.SourceReaderOptions

@PublicEvolving
public class SourceReaderOptions
extends Object

The options that can be set for the SourceReaderBase.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<Integer>	ELEMENT_QUEUE_CAPACITY
int	elementQueueCapacity
static ConfigOption<Long>	SOURCE_READER_CLOSE_TIMEOUT
long	sourceReaderCloseTimeout

Constructor Summary

Constructors

Constructor	Description
SourceReaderOptions(Configuration config)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

SOURCE_READER_CLOSE_TIMEOUT

public static final ConfigOption<Long> SOURCE_READER_CLOSE_TIMEOUT

ELEMENT_QUEUE_CAPACITY

public static final ConfigOption<Integer> ELEMENT_QUEUE_CAPACITY

sourceReaderCloseTimeout

public final long sourceReaderCloseTimeout

elementQueueCapacity

public final int elementQueueCapacity

Constructor Detail

SourceReaderOptions

public SourceReaderOptions(Configuration config)