什么是喷气机 是一个开源的,内存中的,分布式批处理和流处理引擎。 您可以使用它来处理大量的实时事件或大量的静态数据集。 为了提供一种规模感,Jet的单个节点已被证明可而延迟小于10毫秒。 它提供了Java API,可通过使用来构建流和批处理应用。 将应用程序部署到Jet群集后,Jet将自动使用群集上的所有计算资源来运行您的应用程序。 如果在应用程序运行时将更多节点添加到群集,Jet会自动扩展应用程序以在新节点上运行。 如果您从群集中删除节点,它将无缝地对其进行缩减,而不会丢失当前的计算状态,从而提供保证。 例如,您可以表示经典的单词计数问题,该问题使用以下API读取一些本地文件并将每个单
2022-07-26 10:32:06 65.6MB java kafka big-data stream-processing
1
SQL Server的Tabular Data Stream (TDS)协议是SQL Server的数据传输协议。 英文版 TDS 详细协议说明文档.
2022-07-23 17:41:27 5.2MB tds协议
1
python-stream 说明 数据流式框架, 可用作数据清洗, 数据预处理, 数据迁移等应用场景 更优雅的流式数据处理方式 安装 pip install git+https://github.com/sandabuliu/python-stream.git or git clone https://github.com/sandabuliu/python-stream.git cd python-agent python setup.py install QuickStart Examples Word Count from pystream.executor.source import Memory from pystream.executor.executor import Map, Iterator, ReducebyKey data = Memory([ 'W
2022-05-20 20:44:43 28KB data stream log structure
1
使用区分性分类器(D3)的无监督概念漂移检测 ÖmerGözüaçık,AlicanBüyükçakır,Hamed Bonab和Fazli Can。 2019。具有区分性分类器的无监督概念漂移检测。 在第28届ACM国际信息和知识管理国际会议论文集中,中国北京,2019年11月3日至7日,(CIKM'2019),4页。 D3在河包中的实施 D3现在在river中得到支持,它是creme和scikit-multiflow之间的合并。 它是用于对流数据进行机器学习的最全面的python库之一。 目前,该软件包中不包含D3,但是您可以下载并安装该软件包的开发版本以访问D3。 由于代码是根据库标准重构的,因此结果可能与原始实现不同。 有关河的更多详细信息,请访问: : 具有D3的河的分叉版本: : 安装包括D3的river开发版本。 pip install git+https
2021-09-16 22:17:48 4KB unsupervised data-stream concept drift
1