27
27
import org .apache .drill .exec .physical .impl .scan .framework .ManagedReader ;
28
28
import org .apache .drill .exec .physical .impl .scan .framework .SchemaNegotiator ;
29
29
import org .apache .drill .exec .physical .resultSet .ResultSetLoader ;
30
- import org .apache .drill .exec .record .metadata .TupleMetadata ;
31
30
import org .apache .drill .exec .store .druid .DruidSubScan .DruidSubScanSpec ;
32
31
import org .apache .drill .exec .store .druid .common .DruidFilter ;
33
32
import org .apache .drill .exec .store .druid .druid .DruidScanResponse ;
34
33
import org .apache .drill .exec .store .druid .druid .ScanQuery ;
35
34
import org .apache .drill .exec .store .druid .druid .ScanQueryBuilder ;
36
35
import 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 ;
38
37
import org .apache .drill .exec .store .easy .json .loader .JsonLoaderImpl .JsonLoaderBuilder ;
39
38
import org .apache .drill .exec .vector .BaseValueVector ;
40
39
import org .slf4j .Logger ;
@@ -56,7 +55,7 @@ public class DruidBatchRecordReader implements ManagedReader<SchemaNegotiator> {
56
55
private BigInteger nextOffset = BigInteger .ZERO ;
57
56
private int maxRecordsToRead = -1 ;
58
57
private JsonLoaderBuilder jsonBuilder ;
59
- private JsonLoader jsonLoader ;
58
+ private JsonLoaderImpl jsonLoader ;
60
59
private ResultSetLoader resultSetLoader ;
61
60
private CustomErrorContext errorContext ;
62
61
@@ -97,7 +96,7 @@ public boolean next() {
97
96
setNextOffset (druidScanResponse );
98
97
99
98
for (ObjectNode eventNode : druidScanResponse .getEvents ()) {
100
- JsonLoader jsonLoader = jsonBuilder
99
+ jsonLoader = ( JsonLoaderImpl ) jsonBuilder
101
100
.fromString (eventNode .toString ())
102
101
.build ();
103
102
0 commit comments