diff --git druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidSerDe.java druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidSerDe.java index 4235e89..bbe29b6 100644 --- druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidSerDe.java +++ druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidSerDe.java @@ -100,18 +100,21 @@ protected static final Logger LOG = LoggerFactory.getLogger(DruidSerDe.class); - private String[] columns; - - private PrimitiveTypeInfo[] types; - private int numConnection; - private Period readTimeout; + private String[] columns; + private PrimitiveTypeInfo[] types; private ObjectInspector inspector; @Override public void initialize(Configuration configuration, Properties properties) throws SerDeException { + // Init connection properties + numConnection = HiveConf + .getIntVar(configuration, HiveConf.ConfVars.HIVE_DRUID_NUM_HTTP_CONNECTION); + readTimeout = new Period( + HiveConf.getVar(configuration, HiveConf.ConfVars.HIVE_DRUID_HTTP_READ_TIMEOUT)); + final List columnNames = new ArrayList<>(); final List columnTypes = new ArrayList<>(); List inspectors = new ArrayList<>(); @@ -173,11 +176,6 @@ public ObjectInspector apply(PrimitiveTypeInfo type) { throw new SerDeException("Druid broker address not specified in configuration"); } - numConnection = HiveConf - .getIntVar(configuration, HiveConf.ConfVars.HIVE_DRUID_NUM_HTTP_CONNECTION); - readTimeout = new Period( - HiveConf.getVar(configuration, HiveConf.ConfVars.HIVE_DRUID_HTTP_READ_TIMEOUT)); - // Infer schema SegmentAnalysis schemaInfo; try {