org.apache.flink.connector.testframe.source.split

Class FromElementsSplit

java.lang.Object

org.apache.flink.connector.testframe.source.split.FromElementsSplit

All Implemented Interfaces:

SourceSplit

public class FromElementsSplit
extends Object
implements SourceSplit

The split of the FromElementsSource.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPLIT_ID

Constructor Summary

Constructors

Constructor and Description
FromElementsSplit(int emitNum)

Method Summary

Modifier and Type	Method and Description
int	getEmitNum()
void	setEmitNum(int emitNum)
String	splitId() Get the split id of this source split.

Methods inherited from class java.lang.Object

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

Field Detail

SPLIT_ID

public static final String SPLIT_ID

See Also:

Constant Field Values

Constructor Detail

FromElementsSplit

public FromElementsSplit(int emitNum)

Method Detail

getEmitNum

public int getEmitNum()

setEmitNum

public void setEmitNum(int emitNum)

splitId

public String splitId()

Description copied from interface: SourceSplit

Get the split id of this source split.

Specified by:

splitId in interface SourceSplit

Returns:

id of this source split.