公开(公告)号：US09684666B1

公开(公告)日：2017-06-20

申请号：US14194401

申请日：2014-02-28

申请人： Pivotal Software, Inc.

发明人： Dov Yaron Dorin ,  Alon Goldshuv

IPC分类号： G06F17/30

CPC分类号： G06F17/30153 ,  G06F17/30498 ,  G06F17/30557

摘要： Methods, systems, and apparatus, including computer programs encoded on computer storage media, for streaming external data in parallel from a second distributed system to a first distributed system. One of the methods includes receiving a query that requests a join of first rows of a first table in a first distributed system with second rows of an external table, the external table representing data in a second distributed system. Each of the segment nodes communicates with a respective extension service that obtains fragments from one or more data nodes of the second distributed system according to location information for the respective fragments, and provides to the segment node a stream of data corresponding to second rows of the external table. Each of the segment nodes computes joined rows between the first rows of the first table and the stream of data corresponding to second rows of the external table.

公开(公告)号：US09898469B1

公开(公告)日：2018-02-20

申请号：US14468089

申请日：2014-08-25

申请人： Pivotal Software, Inc.

发明人： Dov Yaron Dorin ,  Alon Goldshuv ,  Alex Shacked ,  Luke Lonergan

IPC分类号： G06F17/30 ,  H04L29/08

CPC分类号： G06F17/30076 ,  G06F17/30091 ,  G06F17/30194 ,  G06F17/30498 ,  G06F17/30545 ,  G06F17/30634 ,  H04L67/1097

摘要： Methods, systems, and apparatus, including computer programs encoded on computer storage media, for streaming external data in parallel from a second distributed system to a first distributed system. One of the methods includes receiving a query that requests a join of first rows of a first table in a first distributed system with second rows of an external table, the external table representing data in a second distributed system. Each of the segment nodes communicates with a respective extension service that obtains fragments from one or more data nodes of the second distributed system according to location information for the respective fragments, and provides to the segment node a stream of data corresponding to second rows of the external table. Each of the segment nodes computes joined rows between the first rows of the first table and the stream of data corresponding to second rows of the external table.

公开(公告)号：US09684671B1

公开(公告)日：2017-06-20

申请号：US14194444

申请日：2014-02-28

申请人： Pivotal Software, Inc.

发明人： Dov Yaron Dorin ,  Alon Goldshuv ,  Alex Shacked

IPC分类号： G06F17/30

CPC分类号： G06F17/30076 ,  G06F17/30091 ,  G06F17/30194 ,  G06F17/30498 ,  G06F17/30545 ,  G06F17/30634 ,  H04L67/1097

摘要： Methods, systems, and apparatus, including computer programs encoded on computer storage media, for streaming external data in parallel from a second distributed system to a first distributed system. One of the methods includes receiving a query that requests a join of first rows of a first table in a first distributed system with second rows of an external table, the external table representing data in a second distributed system. Each of the segment nodes communicates with a respective extension service that obtains fragments from one or more data nodes of the second distributed system according to location information for the respective fragments, and provides to the segment node a stream of data corresponding to second rows of the external table. Each of the segment nodes computes joined rows between the first rows of the first table and the stream of data corresponding to second rows of the external table.

公开(公告)号：US09679012B1

公开(公告)日：2017-06-13

申请号：US14194451

申请日：2014-02-28

申请人： Pivotal Software, Inc.

发明人： Dov Yaron Dorin ,  Alon Goldshuv ,  Noa Horn ,  Alex Shacked

IPC分类号： G06F17/30

CPC分类号： G06F17/30469 ,  G06F17/30445 ,  G06F17/30463

摘要： Methods, systems, and apparatus, including computer programs encoded on computer storage media, for streaming external data in parallel from a second distributed system to a first distributed system. One of the methods includes receiving a query that requests a join of first rows of a first table in a first distributed system with second rows of an external table, the external table representing data in a second distributed system. Each of the segment nodes communicates with a respective extension service that obtains fragments from one or more data nodes of the second distributed system according to location information for the respective fragments, and provides to the segment node a stream of data corresponding to second rows of the external table. Each of the segment nodes computes joined rows between the first rows of the first table and the stream of data corresponding to second rows of the external table.