Skip to content

Commit d9d1ff6

Browse files
committed
Support Scripted aggregations and Add type hints to field_mappings.py and refactor/improve capability_matrix usage
1 parent 5678525 commit d9d1ff6

File tree

10 files changed

+392
-1162
lines changed

10 files changed

+392
-1162
lines changed

eland/dataframe.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -617,11 +617,11 @@ def es_info(self):
617617
is_source_field: False
618618
Mappings:
619619
capabilities:
620-
es_field_name is_source es_dtype es_date_format pd_dtype is_searchable is_aggregatable is_scripted aggregatable_es_field_name
621-
timestamp timestamp True date strict_date_hour_minute_second datetime64[ns] True True False timestamp
622-
OriginAirportID OriginAirportID True keyword None object True True False OriginAirportID
623-
DestAirportID DestAirportID True keyword None object True True False DestAirportID
624-
FlightDelayMin FlightDelayMin True integer None int64 True True False FlightDelayMin
620+
display_name es_field_name is_source es_dtype es_date_format pd_dtype is_searchable is_aggregatable is_scripted aggregatable_es_field_name
621+
0 timestamp timestamp True date strict_date_hour_minute_second datetime64[ns] True True False timestamp
622+
1 OriginAirportID OriginAirportID True keyword None object True True False OriginAirportID
623+
2 DestAirportID DestAirportID True keyword None object True True False DestAirportID
624+
3 FlightDelayMin FlightDelayMin True integer None int64 True True False FlightDelayMin
625625
Operations:
626626
tasks: [('boolean_filter': ('boolean_filter': {'bool': {'must': [{'term': {'OriginAirportID': 'AMS'}}, {'range': {'FlightDelayMin': {'gt': 60}}}]}})), ('tail': ('sort_field': '_doc', 'count': 5))]
627627
size: 5

0 commit comments

Comments
 (0)