private DeepRecordReader initRecordReader ( final DeepPartition dp , CassandraDeepJobConfig < T > config ) { DeepRecordReader recordReader = new DeepRecordReader ( config , dp . splitWrapper ( ) ) ; return recordReader ; }
Instantiates a new deep record reader object associated to the provided partition .