会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 4. 发明申请
    • MANAGING DATA SET OBJECTS
    • 管理数据集对象
    • US20120102029A1
    • 2012-04-26
    • US13281039
    • 2011-10-25
    • Brond LarsonRichard A. ShapiroCraig W. StanfillAdam Weiss
    • Brond LarsonRichard A. ShapiroCraig W. StanfillAdam Weiss
    • G06F17/30
    • G06F8/34
    • Managing data set objects for graph-based data processing includes: storing a group of one or more data set objects in a data storage system, the data set objects each representing a respective data set; and generating an association between at least a first data set object in the group and at least a first node of a dataflow graph for processing data in a data processing system, the first node representing a source or sink of data in a flow of data represented by a link in the dataflow graph, and the first data set object including a plurality of modes in which different transformational logic is applied to data processed by the first node.
    • 管理用于基于图形的数据处理的数据集对象包括:将一组一个或多个数据集对象存储在数据存储系统中,每个数据集对象表示相应的数据集; 以及在所述组中的至少第一数据集对象与用于处理数据处理系统中的数据的数据流图的至少第一节点之间生成关联,所述第一节点表示数据流中的数据的源或汇点 通过数据流图中的链接,并且第一数据集对象包括多个模式,其中不同的转换逻辑被应用于由第一节点处理的数据。
    • 5. 发明授权
    • Continuous flow compute point based data processing
    • 基于连续流计算点的数据处理
    • US06654907B2
    • 2003-11-25
    • US09731234
    • 2000-12-05
    • Craig W. StanfillRichard A. ShapiroStephen A. Kukolich
    • Craig W. StanfillRichard A. ShapiroStephen A. Kukolich
    • G06F1100
    • G06F11/1458G06F2201/82
    • A data processing system and method that provides two processes, checkpointing and compute point propagation, and permits a continuous flow of data processing by allowing each process to (1) return to normal operation after checkpointing or (2) respond to receipt of a compute point indicator, independently of the time required by other processes for similar responsive actions. Checkpointing makes use of a command message from a checkpoint processor that sequentially propagates through a process stage from data sources through processes to data sinks, triggering each process to checkpoint its state and then pass on a checkpointing message to connected “downstream” processes. A compute point indicator marks blocks of records that should be processed as a group within each process. A compute point indicator is triggered and sequentially propagates through a process stage from data sources through processes to data sinks without external control. Compute point indicators also effectively self-synchronize multiple data flows without external control. Use of compute point indicators rather than checkpoints avoids the time delay that saving state imposes, while permitting a continuous flow of data processing, including outputting results.
    • 提供两个过程,检查点和计算点传播的数据处理系统和方法,并允许数据处理的连续流程,允许每个进程(1)在检查点之后返回到正常操作,或(2)响应接收计算点 指标,独立于其他过程对类似回应行动所需的时间。 检查点使用来自检查点处理器的命令消息,其顺序地通过进程阶段从数据源通过进程传播到数据宿,触发每个进程检查其状态,然后将检查点消息传递到连接的“下游”进程。 计算点指示符标记应在每个进程中作为组处理的记录块。 一个计算点指示器被触发,并且从数据源通过进程顺序传播到数据接收器,而无需外部控制。 计算点指标也能有效地自动同步多个数据流而无需外部控制。 使用计算点指示器而不是检查点避免了保存状态强加的时间延迟,同时允许连续的数据处理流程,包括输出结果。