private synchronized void initialize(KuduInputSplit split, Configuration conf)
        throws IOException {
      if (!initialized) {
        byte[] serializedScanToken = split.getSerializedScanToken();
        client = KuduHiveUtils.getKuduClient(conf);
        scanner = KuduScanToken.deserializeIntoScanner(serializedScanToken, client);
        iterator = scanner.iterator();
        currentValue = null;
        currentWritable = new KuduWritable(scanner.getProjectionSchema().newPartialRow());
        pos = 0;
        initialized = true;
      }
    }
A RecordReader that reads the Kudu rows from a KuduInputSplit.
kudu-handler/src/java/org/apache/hadoop/hive/kudu/KuduInputFormat.java