GetSplitResult

java.lang.Object

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

@Internal public class GetSplitResult extends Object

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static enum

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 Details
- 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)