Class NativeScanner

java.lang.Object
org.apache.arrow.dataset.jni.NativeScanner
All Implemented Interfaces:
AutoCloseable, Scanner

public class NativeScanner extends Object implements Scanner
Native implementation of Scanner. Note that it currently emits only a single scan task of type NativeScanTask, which is internally a combination of all scan task instances returned by the native scanner.
  • Constructor Details

    • NativeScanner

      public NativeScanner(NativeContext context, long scannerId)
  • Method Details

    • scanBatches

      public ArrowReader scanBatches()
      Description copied from interface: Scanner
      Read the dataset as a stream of record batches.
      Specified by:
      scanBatches in interface Scanner
      Returns:
      a ArrowReader.
    • scan

      @Deprecated public Iterable<? extends NativeScanTask> scan()
      Deprecated.
      Description copied from interface: Scanner
      Perform the scan operation.
      Specified by:
      scan in interface Scanner
      Returns:
      a iterable set of ScanTasks. Each task is considered independent and it is allowed to execute the tasks concurrently to gain better performance.
    • schema

      public Schema schema()
      Description copied from interface: Scanner
      Get the schema of this Scanner.
      Specified by:
      schema in interface Scanner
      Returns:
      the schema instance
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable