DataTask

All Superinterfaces:: ContentScanTask<DataFile>, FileScanTask, PartitionScanTask, ScanTask, Serializable, SplittableScanTask<FileScanTask>

public interface DataTask extends FileScanTask

A task that returns data as rows instead of where to read data.

Method Summary

Modifier and Type

Method

Description

default DataTask

asDataTask()

Returns this cast to DataTask if it is one

default boolean

isDataTask()

Returns true if this is a DataTask, false otherwise.

CloseableIterable<StructLike>

rows()

Returns an iterable of StructLike rows.

Methods inherited from interface org.apache.iceberg.ContentScanTask
estimatedRowsCount, file, length, partition, residual, start

Methods inherited from interface org.apache.iceberg.FileScanTask
asFileScanTask, deletes, filesCount, isFileScanTask, schema, sizeBytes

Methods inherited from interface org.apache.iceberg.PartitionScanTask
spec

Methods inherited from interface org.apache.iceberg.ScanTask
asCombinedScanTask

Methods inherited from interface org.apache.iceberg.SplittableScanTask
split

Method Details
- isDataTask
  
  default boolean isDataTask()
  
  Description copied from interface: ScanTask
  
  Returns true if this is a DataTask, false otherwise.
  
  Specified by:
  
  isDataTask in interface ScanTask
- asDataTask
  
  default DataTask asDataTask()
  
  Description copied from interface: ScanTask
  
  Returns this cast to DataTask if it is one
  
  Specified by:
  
  asDataTask in interface ScanTask
  
  Returns:
  
  this cast to DataTask if it is one
- rows
  
  CloseableIterable<StructLike> rows()
  
  Returns an iterable of StructLike rows.