SparkWriteRequirements

java.lang.Object

org.apache.iceberg.spark.SparkWriteRequirements

public class SparkWriteRequirements extends Object

A set of requirements such as distribution and ordering reported to Spark during writes.

Field Summary

Fields

Modifier and Type

Field

Description

static final SparkWriteRequirements

EMPTY
Method Summary

Modifier and Type

Method

Description

long

advisoryPartitionSize()

org.apache.spark.sql.connector.distributions.Distribution

distribution()

boolean

hasOrdering()

org.apache.spark.sql.connector.expressions.SortOrder[]

ordering()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- EMPTY
  
  public static final SparkWriteRequirements EMPTY
Method Details
- distribution
  
  public org.apache.spark.sql.connector.distributions.Distribution distribution()
- ordering
  
  public org.apache.spark.sql.connector.expressions.SortOrder[] ordering()
- hasOrdering
  
  public boolean hasOrdering()
- advisoryPartitionSize
  
  public long advisoryPartitionSize()