窗口是无限循环的,我在处理后打印数据流,但看起来根本没有达到那个点。 下面是我的伪代码。 Datastream env = StreamExecutionEnvironment.getExecutionEnvironment()
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
Datastream stream = env.addSource() .map(mapping to java object)
.filter(filter for specific type of events)
我想通过Java连接到历史数据库。在.net中,我们可以通过OleDb provider连接它。我的connectionString是:
"Provider=ihOLEDB.iHistorian;Data Source= IpAddress; user id= abc;password= xyz"
我尝试使用上面的字符串和JdbcDriverManager进行连接,但它给出了以下错误:
java.sql.SQLException: No suitable driver found for Provider=IhOLEDB.iHistorian.1:Data Source= IP
在输出中,我希望从q/kdb历史数据库中的表中选择除两列之外的所有列。我试着在查询下面运行,但是它不适用于hdb。
delete colid,coltime from table where date=.z.d-1
但是它失败了,下面是错误。
ERROR: 'par
(trying to update a physically partitioned table)
我提到了,但没有帮助。
如何在kdb历史数据库中显示除两列之外的所有列?
我正在研究一个模型,它将使我能够根据历史数据预测完成一项“工作”需要多长时间。每一项工作都有一些分类特征(都是独立的),一些历史数据看起来可能如下:
JobID Manager City Design ClientType TaskDuration
a1 George Brisbane BigKahuna Personal 10
a2 George Brisbane SmallKahuna Business 15
a3 George
我有一个需求,我需要从作为web服务公开的第三方系统获取历史数据,并在这些数据上训练模型。我可以通过使用“执行python脚本”节点和使用Python调用web服务来实现上述要求。
当我需要在每次调用Azure ML web服务时从第三方系统获取数据时,主要问题就出现了,因为第三方系统中的数据一直在变化,因此我的Azure ML模型应该总是针对新数据进行训练。
我已经浏览了链接(),但我不确定我们如何才能满足我的需求,因为对我来说,每次调用Azure ML web服务时都应该获得新的历史数据集。
请提个建议。
谢谢。