Package index • stream

Package overview

stream stream-package: stream: Infrastructure for Data Stream Mining
DST_Runner(): Create a Data Stream Pipeline

Data stream sources

DSD() DSD_R(): Data Stream Data Generator Base Classes
DSD_Memory(): A Data Stream Interface for Data Stored in Memory
DSD_Gaussians(): Mixture of Gaussians Data Stream Generator
DSD_BarsAndGaussians(): Data Stream Generator for Bars and Gaussians
DSD_Cubes(): Static Cubes Data Stream Generator
DSD_MG() add_cluster() get_clusters() remove_cluster(): DSD Moving Generator
DSD_Mixture(): Mixes Data Points from Several Streams into a Single Stream
DSD_NULL(): Placeholder for a DSD Stream
DSD_Target(): Target Data Stream Generator
DSD_UniformNoise(): Uniform Noise Data Stream Generator
DSD_Benchmark(): Data Stream Generator for Dynamic Data Stream Benchmarks
DSD_mlbenchData(): Stream Interface for Data Sets From mlbench
DSD_mlbenchGenerator(): mlbench Data Stream Generator
DSD_ReadDB() close_stream(<DSD_ReadDB>): Read a Data Stream from an open DB Query
DSD_ReadStream() DSD_ReadCSV() close_stream(<DSD_ReadStream>) close_stream(<DSD_ReadCSV>): Read a Data Stream from a File or a Connection
DSD_ScaleStream(): Deprecated DSD_ScaleStream
MGC() MGC_Function() MGC_Linear() keyframe() add_keyframe() get_keyframes() remove_keyframe() MGC_Noise() MGC_Random() Shape_Gaussian() Shape_Block() MGC_Static(): Moving Generator Cluster
get_points() remove_info(): Get Points from a Data Stream Generator
reset_stream(): Reset a Data Stream to its Beginning
close_stream(): Close a Data Stream

Stream filters

DSF() reset_stream(<DSF>) get_points(<DSF>) update(<DSF>) close_stream(<DSF>): Data Stream Filter Base Classes
DSF_Downsample(): Downsample a Data Stream
DSF_Convolve() filter_MA() filter_Hamming() filter_diff() filter_Sinc() pow2(): Apply a Filter to a Data Stream
DSF_ExponentialMA(): Exponential Moving Average over a Data Stream
DSF_FeatureSelection(): Select Features for a Data Stream
DSF_Func(): Apply a Function to Transform a Data Stream
DSF_Scale(): Scale a Data Stream
DSF_dplyr(): Apply a dplyr Transformation to a Data Stream

Stream tasks and operators

DST() description() get_model(): Conceptual Base Class for All Data Stream Mining Tasks
DST_Multi(): Apply Multiple Task to the Same Data Stream
DST_SlidingWindow() update(<DST_SlidingWindow>) predict(<DST_SlidingWindow>): DST_SlidingWindow – Call R Functions on a Sliding Window
DST_WriteStream() close_stream(<DST_WriteStream>): Task to Write a Stream to a File or a Connection
DSFP(): Abstract Class for Frequent Pattern Mining Algorithms for Data Streams
DSAggregate() update(<DSAggregate>) get_points(<DSAggregate>) get_weights(<DSAggregate>): Data Stream Aggregator Base Classes
DSAggregate_Sample(): Sampling from a Data Stream (Data Stream Operator)
DSAggregate_Window(): Sliding Window (Data Stream Operator)
DSClassifier(): Abstract Class for Data Stream Classifiers
DSClassifier_SlidingWindow(): DSClassifier_SlidingWindow – Data Stream Classifier Using a Sliding Window
DSRegressor(): Abstract Class for Data Stream Regressors
DSRegressor_SlidingWindow(): DSRegressor_SlidingWindow – Data Stream Regressor Using a Sliding Window
DSOutlier(): Abstract Class for Data Stream Outlier Detectors

Clustering

DSC() get_centers() get_weights() get_copy() nclusters() get_microclusters() get_microweights() get_macroclusters() get_macroweights(): Data Stream Clustering Base Class
DSC_Micro(): Abstract Class for Micro Clusterers (Online Component)
DSC_Macro() microToMacro(): Abstract Class for Macro Clusterers (Offline Component)
DSC_TwoStage(): TwoStage Clustering Process
DSC_Static(): Create as Static Copy of a Clustering
DSC_Window(): A sliding window from a Data Stream
DSC_SlidingWindow(): DSC_SlidingWindow – Data Stream Clusterer Using a Sliding Window
DSC_BICO(): BICO - Fast computation of k-means coresets in a data stream
DSC_BIRCH(): Balanced Iterative Reducing Clustering using Hierarchies
DSC_DBSTREAM() get_shared_density() change_alpha() plot(<DSC_DBSTREAM>) DSOutlier_DBSTREAM(): DBSTREAM Clustering Algorithm
DSC_DStream() get_attraction() plot(<DSC_DStream>) DSOutlier_DStream(): D-Stream Data Stream Clustering Algorithm
DSC_evoStream(): evoStream - Evolutionary Stream Clustering
DSC_Sample(): Extract a Fixed-size Sample from a Data Stream
DSC_DBSCAN(): DBSCAN Macro-clusterer
DSC_EA(): Reclustering using an Evolutionary Algorithm
DSC_Hierarchical(): Hierarchical Micro-Cluster Reclusterer
DSC_Kmeans(): Kmeans Macro-clusterer
DSC_Reachability(): Reachability Micro-Cluster Reclusterer
DSC_R() update(<DSC_R>): Abstract Class for Implementing R-based Clusterers
get_assignment(): Assignment Data Points to Clusters deprecated
prune_clusters(): Prune Clusters from a Clustering
recluster(): Re-clustering micro-clusters
predict(<DST>) predict(<DSC>): Make a Prediction for a Data Stream Mining Task
update(<DST>): Update a Data Stream Mining Task Model with Points from a Stream

Evaluation and visualization

evaluate_static() evaluate_stream(): Evaluate a Data Stream Mining Task
evaluate_static(<DSC>) evaluate_stream(<DSC>): Evaluate a Stream Clustering Task
agreement(): Agreement-based Measures for Clustering
plot(<DSD>): Plot Data Stream Data
plot(<DSC>): Plot Results of a Data Stream Clustering
animate_data(): Animates the Plotting of a Data Streams
animate_cluster(): Animates Plots of the Clustering Process

Stream I/O and utilities

write_stream(): Write a Data Stream to a File
saveDSC() readDSC(): Save and Read DSC Objects
`%>%`: Pipe operator