Class ReadersInitializer

java.lang.Object
org.apache.drill.exec.store.hive.readers.ReadersInitializer

public class ReadersInitializer extends Object
Factory for creation of Hive record readers used by HiveScanBatchCreator.
  • Constructor Details

    • ReadersInitializer

      public ReadersInitializer()
  • Method Details

    • init

      public static List<RecordReader> init(ExecutorFragmentContext ctx, HiveSubScan config)
      Selects reader constructor reference as ReadersInitializer.HiveReaderFactory readerFactory. Then check if input splits are empty creates empty record reader, or one reader per split otherwise.
      Parameters:
      ctx - context related to fragment
      config - context which holds different Hive configurations
      Returns:
      list containing one or more readers