aligned.data_source.batch_data_source

module documentation
(source)

Undocumented

Class BatchDataSource No class docstring; 5/19 methods, 0/1 class method documented
Class BatchDataSourceFactory Undocumented
Class BatchSourceModification Undocumented
Class CodableBatchDataSource A definition to where a specific piece of data can be found. E.g: A database table, a file, a web service, etc.
Class CodableFunction Undocumented
Class ColumnFeatureMappable Undocumented
Class FilteredDataSource Undocumented
Class FunctionReference Undocumented
Class JoinAsofDataSource Undocumented
Class JoinDataSource Undocumented
Class LoadedAtSource Undocumented
Class StackSource Undocumented
Class UnknownDataSource Undocumented
Function join_asof_source Undocumented
Function join_source Undocumented
Function make_async Undocumented
Function model_prediction_instance_source Undocumented
Function request_without_event_timestamp Undocumented
Function resolve_keys Undocumented
Function view_wrapper_instance_source Undocumented
Type Variable T Undocumented
Variable logger Undocumented
def join_asof_source(source: CodableBatchDataSource, left_request: RetrievalRequest, view: Any, left_on: list[str] | None = None, right_on: list[str] | None = None) -> JoinAsofDataSource: (source)

Undocumented

def join_source(source: CodableBatchDataSource, view: Any, on_left: str | FeatureFactory | list[str] | list[FeatureFactory] | None = None, on_right: str | FeatureFactory | list[str] | list[FeatureFactory] | None = None, how: Literal['inner', 'left', 'outer'] = 'inner', left_request: RetrievalRequest | None = None) -> JoinDataSource: (source)

Undocumented

def make_async(function: Callable): (source)

Undocumented

def model_prediction_instance_source(model: Any) -> tuple[CodableBatchDataSource, RetrievalRequest] | Exception: (source)

Undocumented

def request_without_event_timestamp(request: RetrievalRequest) -> RetrievalRequest: (source)

Undocumented

def resolve_keys(keys: str | FeatureFactory | list[str] | list[FeatureFactory]) -> list[str]: (source)

Undocumented

def view_wrapper_instance_source(view: Any) -> tuple[CodableBatchDataSource, RetrievalRequest] | Exception: (source)

Undocumented

T = (source)

Undocumented

Value
TypeVar('T')
logger = (source)

Undocumented