fiftyone.server.lightning

module documentation
(source)

FiftyOne Server lightning queries

Copyright 2017-2025, Voxel51, Inc.
voxel51.com

Class BooleanLightningResult Undocumented
Class DateLightningResult Undocumented
Class DateTimeLightningResult Undocumented
Class DistinctQuery Undocumented
Class FloatLightningResult Undocumented
Class IntLightningResult Undocumented
Class LightningInput Undocumented
Class LightningPathInput Undocumented
Class LightningResult Undocumented
Class ObjectIdLightningResult Undocumented
Class StringLightningResult Undocumented
Async Function lightning_resolver Undocumented
Constant INT_CLS Undocumented
Variable LightningResults Undocumented
Function _add_search Undocumented
Async Function _do_async_pooled_queries Undocumented
Async Function _do_async_query Undocumented
Async Function _do_distinct_grouped_pipeline Undocumented
Async Function _do_distinct_lazy_pipeline Undocumented
Async Function _do_distinct_queries Undocumented
Async Function _do_list_distinct_query Undocumented
Function _first Undocumented
Function _handle_nonfinites Undocumented
Async Function _handle_pipeline Undocumented
Function _has_list Undocumented
Function _match Undocumented
Function _match_arrays Undocumented
Function _parse_result Undocumented
Function _resolve_lightning_path_queries Undocumented
Function _unwind Undocumented
Constant _TWENTY_FOUR Undocumented
async def lightning_resolver(input: LightningInput, info: Info) -> list[LightningResults]: (source)

Undocumented

INT_CLS = (source)

Undocumented

Value
{fof.DateField: DateLightningResult,
 fof.DateTimeField: DateTimeLightningResult,
 fof.FrameNumberField: IntLightningResult,
 fof.IntField: IntLightningResult}
LightningResults = (source)

Undocumented

def _add_search(query: DistinctQuery): (source)

Undocumented

async def _do_async_pooled_queries(dataset: fo.Dataset, queries: list[tuple[AsyncIOMotorCollection, DistinctQuery | list[dict], bool]], filter: t.Mapping[str, str] | None): (source)

Undocumented

async def _do_async_query(dataset: fo.Dataset, collection: AsyncIOMotorCollection, query: DistinctQuery | list[dict], filter: t.Mapping[str, str] | None, is_frames: bool): (source)

Undocumented

async def _do_distinct_grouped_pipeline(dataset: fo.Dataset, collection: AsyncIOMotorCollection, query: DistinctQuery, is_frames: bool): (source)

Undocumented

async def _do_distinct_lazy_pipeline(dataset: fo.Dataset, collection: AsyncIOMotorCollection, query: DistinctQuery, filter: t.Mapping[str, str] | None, is_frames: bool): (source)

Undocumented

async def _do_distinct_queries(dataset: fo.Dataset, collection: AsyncIOMotorCollection, query: DistinctQuery | list[dict], filter: t.Mapping[str, str] | None, is_frames: bool): (source)

Undocumented

async def _do_list_distinct_query(collection: AsyncIOMotorCollection, query: DistinctQuery | list[dict]): (source)

Undocumented

def _first(path: str, dataset: fo.Dataset, sort: t.Literal[-1] | t.Literal[1], is_frame_field: bool, floats=False, limit=None): (source)

Undocumented

def _handle_nonfinites(sort: t.Literal[-1] | t.Literal[1]): (source)

Undocumented

async def _handle_pipeline(pipeline, dataset: fo.Dataset, collection: AsyncIOMotorCollection, query: DistinctQuery, is_frames: bool, disable_limit=False): (source)

Undocumented

def _has_list(dataset: fo.Dataset, path: str, is_frame_field: bool): (source)

Undocumented

def _match(path: str, value: str | float | int | bool, limit=None): (source)

Undocumented

def _match_arrays(dataset: fo.Dataset, path: str, is_frame_field: bool): (source)

Undocumented

def _parse_result(data): (source)

Undocumented

def _resolve_lightning_path_queries(path: LightningPathInput, dataset: fo.Dataset, info: Info) -> tuple[AsyncIOMotorCollection, DistinctQuery | list[dict], t.Callable]: (source)

Undocumented

def _unwind(dataset: fo.Dataset, path: str, is_frame_field: bool): (source)

Undocumented

_TWENTY_FOUR: int = (source)

Undocumented

Value
24