mirror of
https://github.com/elastic/eland.git
synced 2025-07-11 00:02:14 +08:00
instantiates column as series with specified dtype
This commit is contained in:
parent
9c9ca90c0d
commit
9c03d5a0d4
@ -219,8 +219,7 @@ class ElandQueryCompiler:
|
||||
|
||||
for missing in missing_columns:
|
||||
is_source_field, pd_dtype = self._mappings.source_field_pd_dtype(missing)
|
||||
df[missing] = None
|
||||
df[missing].astype(pd_dtype)
|
||||
df[missing] = pd.Series(dtype=pd_dtype)
|
||||
|
||||
# Sort columns in mapping order
|
||||
df = df[self.columns]
|
||||
|
Loading…
x
Reference in New Issue
Block a user