2727import org .apache .drill .exec .physical .impl .scan .framework .ManagedReader ;
2828import org .apache .drill .exec .physical .impl .scan .framework .SchemaNegotiator ;
2929import org .apache .drill .exec .physical .resultSet .ResultSetLoader ;
30- import org .apache .drill .exec .record .metadata .TupleMetadata ;
3130import org .apache .drill .exec .store .druid .DruidSubScan .DruidSubScanSpec ;
3231import org .apache .drill .exec .store .druid .common .DruidFilter ;
3332import org .apache .drill .exec .store .druid .druid .DruidScanResponse ;
3433import org .apache .drill .exec .store .druid .druid .ScanQuery ;
3534import org .apache .drill .exec .store .druid .druid .ScanQueryBuilder ;
3635import org .apache .drill .exec .store .druid .rest .DruidQueryClient ;
37- import org .apache .drill .exec .store .easy .json .loader .JsonLoader ;
36+ import org .apache .drill .exec .store .easy .json .loader .JsonLoaderImpl ;
3837import org .apache .drill .exec .store .easy .json .loader .JsonLoaderImpl .JsonLoaderBuilder ;
3938import org .apache .drill .exec .vector .BaseValueVector ;
4039import org .slf4j .Logger ;
@@ -56,7 +55,7 @@ public class DruidBatchRecordReader implements ManagedReader<SchemaNegotiator> {
5655 private BigInteger nextOffset = BigInteger .ZERO ;
5756 private int maxRecordsToRead = -1 ;
5857 private JsonLoaderBuilder jsonBuilder ;
59- private JsonLoader jsonLoader ;
58+ private JsonLoaderImpl jsonLoader ;
6059 private ResultSetLoader resultSetLoader ;
6160 private CustomErrorContext errorContext ;
6261
@@ -97,7 +96,7 @@ public boolean next() {
9796 setNextOffset (druidScanResponse );
9897
9998 for (ObjectNode eventNode : druidScanResponse .getEvents ()) {
100- JsonLoader jsonLoader = jsonBuilder
99+ jsonLoader = ( JsonLoaderImpl ) jsonBuilder
101100 .fromString (eventNode .toString ())
102101 .build ();
103102
0 commit comments