Package org.apache.iceberg.flink.source.assigner

Class GetSplitResult

java.lang.Object

org.apache.iceberg.flink.source.assigner.GetSplitResult

@Internal
public class GetSplitResult
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GetSplitResult.Status

Method Summary

Modifier and Type	Method	Description
static GetSplitResult	constrained()
static GetSplitResult	forSplit(IcebergSourceSplit split)
IcebergSourceSplit	split()
GetSplitResult.Status	status()
static GetSplitResult	unavailable()

Methods inherited from class java.lang.Object

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

Method Detail

status

public GetSplitResult.Status status()

split

public IcebergSourceSplit split()

unavailable

public static GetSplitResult unavailable()

constrained

public static GetSplitResult constrained()

forSplit

public static GetSplitResult forSplit(IcebergSourceSplit split)