Skip to content

voiage.factory.create_streaming_analysis

create_streaming_analysis([positional or keyword] nb_array: np.ndarray | ValueArray = None, [positional or keyword] parameter_samples: np.ndarray | ParameterSet | dict[str, np.ndarray] | None = None, [positional or keyword] window_size: int = 1000, [positional or keyword] update_frequency: int = 100, [positional or keyword] use_jit: bool = False, [positional or keyword] backend: str = 'numpy') -> FluentDecisionAnalysis

Create a streaming VOI analysis for continuous data updates.

This factory method creates a FluentDecisionAnalysis object configured for streaming data analysis with windowed processing.

Args: nb_array: Initial net benefit array parameter_samples: Initial parameter samples window_size: Size of the streaming window update_frequency: Frequency of updates use_jit: Whether to use JIT compilation backend: Computational backend

FluentDecisionAnalysis: Configured streaming analysis object

Parameters:

  • nb_array np.ndarray | ValueArray
  • parameter_samples np.ndarray | ParameterSet | dict[str, np.ndarray] | None (default: None)
  • window_size int (default: 1000)
  • update_frequency int (default: 100)
  • use_jit bool (default: False)
  • backend str (default: 'numpy')

Returns: FluentDecisionAnalysis