JP7038740B2 - キャッシュ最適化及び効率的な処理のためのデータ集約の方法 - Google Patents
キャッシュ最適化及び効率的な処理のためのデータ集約の方法 Download PDFInfo
- Publication number
- JP7038740B2 JP7038740B2 JP2019563891A JP2019563891A JP7038740B2 JP 7038740 B2 JP7038740 B2 JP 7038740B2 JP 2019563891 A JP2019563891 A JP 2019563891A JP 2019563891 A JP2019563891 A JP 2019563891A JP 7038740 B2 JP7038740 B2 JP 7038740B2
- Authority
- JP
- Japan
- Prior art keywords
- data
- record
- packet
- packets
- record packet
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000012545 processing Methods 0.000 title claims description 148
- 238000000034 method Methods 0.000 title claims description 77
- 230000002776 aggregation Effects 0.000 title claims description 39
- 238000004220 aggregation Methods 0.000 title claims description 39
- 238000005457 optimization Methods 0.000 title description 4
- 238000007405 data analysis Methods 0.000 claims description 119
- 230000015654 memory Effects 0.000 claims description 74
- 230000006870 function Effects 0.000 claims description 24
- 230000004931 aggregating effect Effects 0.000 claims description 19
- 238000004590 computer program Methods 0.000 claims description 19
- 230000008569 process Effects 0.000 description 26
- 238000003860 storage Methods 0.000 description 24
- 238000005516 engineering process Methods 0.000 description 18
- 238000004458 analytical method Methods 0.000 description 17
- 238000004891 communication Methods 0.000 description 11
- 238000005304 joining Methods 0.000 description 7
- 230000008901 benefit Effects 0.000 description 5
- 238000010586 diagram Methods 0.000 description 5
- 230000006855 networking Effects 0.000 description 5
- 230000003287 optical effect Effects 0.000 description 5
- 238000004364 calculation method Methods 0.000 description 4
- 238000007726 management method Methods 0.000 description 4
- 238000013515 script Methods 0.000 description 4
- 238000012546 transfer Methods 0.000 description 4
- 230000000007 visual effect Effects 0.000 description 4
- 238000013461 design Methods 0.000 description 3
- 230000003993 interaction Effects 0.000 description 3
- 238000002360 preparation method Methods 0.000 description 3
- 230000003068 static effect Effects 0.000 description 3
- 230000006399 behavior Effects 0.000 description 2
- 238000013500 data storage Methods 0.000 description 2
- 239000000284 extract Substances 0.000 description 2
- 230000007246 mechanism Effects 0.000 description 2
- 239000007787 solid Substances 0.000 description 2
- 230000009466 transformation Effects 0.000 description 2
- 241000473391 Archosargus rhomboidalis Species 0.000 description 1
- 241000699666 Mus <mouse, genus> Species 0.000 description 1
- 241000699670 Mus sp. Species 0.000 description 1
- 230000000712 assembly Effects 0.000 description 1
- 238000000429 assembly Methods 0.000 description 1
- 230000005540 biological transmission Effects 0.000 description 1
- 238000004422 calculation algorithm Methods 0.000 description 1
- 230000001413 cellular effect Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 238000007418 data mining Methods 0.000 description 1
- 238000009826 distribution Methods 0.000 description 1
- 230000004927 fusion Effects 0.000 description 1
- 230000010354 integration Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 230000007774 longterm Effects 0.000 description 1
- 238000010801 machine learning Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012544 monitoring process Methods 0.000 description 1
- 230000009467 reduction Effects 0.000 description 1
- 238000011160 research Methods 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 230000001953 sensory effect Effects 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
- 238000011144 upstream manufacturing Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F12/00—Accessing, addressing or allocating within memory systems or architectures
- G06F12/02—Addressing or allocation; Relocation
- G06F12/08—Addressing or allocation; Relocation in hierarchically structured memory systems, e.g. virtual memory systems
- G06F12/0802—Addressing of a memory level in which the access to the desired data or data block requires associative addressing means, e.g. caches
- G06F12/0875—Addressing of a memory level in which the access to the desired data or data block requires associative addressing means, e.g. caches with dedicated cache, e.g. instruction or stack
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q10/00—Administration; Management
- G06Q10/06—Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling
- G06Q10/063—Operations research, analysis or management
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F12/00—Accessing, addressing or allocating within memory systems or architectures
- G06F12/02—Addressing or allocation; Relocation
- G06F12/08—Addressing or allocation; Relocation in hierarchically structured memory systems, e.g. virtual memory systems
- G06F12/0802—Addressing of a memory level in which the access to the desired data or data block requires associative addressing means, e.g. caches
- G06F12/0862—Addressing of a memory level in which the access to the desired data or data block requires associative addressing means, e.g. caches with prefetch
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2212/00—Indexing scheme relating to accessing, addressing or allocation within memory systems or architectures
- G06F2212/10—Providing a specific technical effect
- G06F2212/1016—Performance improvement
- G06F2212/1021—Hit rate improvement
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2212/00—Indexing scheme relating to accessing, addressing or allocation within memory systems or architectures
- G06F2212/10—Providing a specific technical effect
- G06F2212/1041—Resource optimization
- G06F2212/1044—Space efficiency improvement
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2212/00—Indexing scheme relating to accessing, addressing or allocation within memory systems or architectures
- G06F2212/60—Details of cache memory
- G06F2212/6022—Using a prefetch buffer or dedicated prefetch cache
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Business, Economics & Management (AREA)
- Human Resources & Organizations (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Economics (AREA)
- Entrepreneurship & Innovation (AREA)
- Strategic Management (AREA)
- General Engineering & Computer Science (AREA)
- Educational Administration (AREA)
- Quality & Reliability (AREA)
- Tourism & Hospitality (AREA)
- Operations Research (AREA)
- General Business, Economics & Management (AREA)
- Marketing (AREA)
- Game Theory and Decision Science (AREA)
- Development Economics (AREA)
- Software Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Debugging And Monitoring (AREA)
- Memory System Of A Hierarchy Structure (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Description
Claims (20)
- データ処理装置によって実行される方法であって、
複数のデータレコードを含むデータストリームを取り出すステップと、
前記データストリームの前記複数のデータレコードを集約して複数のレコードパケットを形成するステップであって、前記複数のレコードパケットのそれぞれは、前記データ処理装置に関連付けられたキャッシュメモリのメモリサイズに基づいて決定される所定のサイズ容量を有し、前記所定のサイズ容量は、レコードパケットの最大サイズであり、前記データストリームの前記複数のデータレコードを集約して複数のレコードパケットを形成することは、前記複数のレコードパケットの第1のレコードパケットについて、前記第1のレコードパケットのサイズを、前記所定のサイズ容量に基づいて決定することと、前記第1のレコードパケットを形成するための第1の数のデータレコードを、前記第1のレコードパケットの前記サイズに基づいて決定することと、前記第1の数のデータレコードを集約して前記第1のレコードパケットを形成することと、前記複数のレコードパケットの第2のレコードパケットについて、前記第2のレコードパケットを形成するための第2の数のデータレコードを決定することであって、前記第2のレコードパケットが処理される前に前記第2の数のデータレコードを集約して前記第2のレコードパケットを形成するための待ち時間が、前記第1のレコードパケットが処理される前に前記第1の数のデータレコードを集約して前記第1のレコードパケットを形成するための待ち時間より小さくなるように、前記第2の数は前記第1の数より小さい、ことと、前記第2の数のデータレコードを集約して前記第2のレコードパケットを形成することと、を含む、ステップと、
前記複数のレコードパケットを、前記データ処理装置の1つ以上の処理オペレーションに関連付けられた複数のスレッドのそれぞれに転送するステップと、
を含む、方法。 - 前記1つ以上の処理オペレーションは、前記データ処理装置上で実行しているデータ解析ワークフローに関連付けられる、
請求項1に記載の方法。 - 前記1つ以上の処理オペレーションのそれぞれを実行して、線形順序で前記複数のレコードパケットについての対応するデータ解析機能を実行するステップをさらに含み、前記線形順序は、前記データ解析ワークフローにおけるオペレーションのシーケンスセットに従っている、
請求項2に記載の方法。 - 前記1つ以上の処理オペレーションのそれぞれを実行することは、前記データ処理装置に関連付けられた複数のコンピュータプロセッサのプロセッサ上で、前記複数のスレッドのそれぞれを実行することによって行われる並列処理を含む、
請求項3に記載の方法。 - 前記所定のサイズ容量は、前記キャッシュメモリの前記メモリサイズを取り出すことによって、オペレーティングシステム又は中央処理ユニット(CPU)から動的に決定される、
請求項1に記載の方法。 - 前記所定のサイズ容量は、前記キャッシュメモリの前記メモリサイズの大きさのオーダーである、
請求項1に記載の方法。 - 前記複数のレコードパケットのそれぞれのレコードパケットについて、前記それぞれのレコードパケットに集約されるデータレコードの数は、前記所定のサイズ容量に基づいて決定される変数である、
請求項1に記載の方法。 - 前記集約することは、前記データストリームの全体を取り出すときに実行される、
請求項1に記載の方法。 - 前記集約することは、前記データストリームを取り出すことと並行して実行される、
請求項1に記載の方法。 - 前記複数のレコードパケットのうちの2つ以上のレコードパケットに関連付けられたデータレコードを、前記2つ以上のレコードパケットのそれぞれが所定の最小数より少ないデータレコードを集約することによって形成され、かつ追加レコードパケットが前記所定のサイズ容量より小さいサイズを有すると決定したときに、前記追加レコードパケットに再集約するステップをさらに含む、
さらに含む、
請求項1に記載の方法。 - 複数のコンピュータプロセッサが実行可能なコンピュータプログラムコードを格納する非一時的なメモリと、キャッシュメモリを有し、且つ前記メモリと通信可能に接続された前記複数のコンピュータプロセッサと、を備えるデータ処理装置であって、
前記複数のコンピュータプロセッサは、前記コンピュータプログラムコードを実行して、
複数のデータレコードを含むデータストリームを取り出すステップと、
前記データストリームの前記複数のデータレコードを集約して複数のレコードパケットを形成するステップであって、前記複数のレコードパケットのそれぞれは、前記データ処理装置に関連付けられたキャッシュメモリのメモリサイズに基づいて決定される所定のサイズ容量を有し、前記所定のサイズ容量は、レコードパケットの最大サイズであり、前記データストリームの前記複数のデータレコードを集約して複数のレコードパケットを形成することは、前記複数のレコードパケットの第1のレコードパケットについて、前記第1のレコードパケットのサイズを、前記所定のサイズ容量に基づいて決定することと、前記第1のレコードパケットを形成するための第1の数のデータレコードを、前記第1のレコードパケットの前記サイズに基づいて決定することと、前記第1の数のデータレコードを集約して前記第1のレコードパケットを形成することと、前記複数のレコードパケットの第2のレコードパケットについて、前記第2のレコードパケットを形成するための第2の数のデータレコードを決定することであって、前記第2のレコードパケットが処理される前に前記第2の数のデータレコードを集約して前記第2のレコードパケットを形成するための待ち時間が、前記第1のレコードパケットが処理される前に前記第1の数のデータレコードを集約して前記第1のレコードパケットを形成するための待ち時間より小さくなるように、前記第2の数は前記第1の数より小さい、ことと、前記第2の数のデータレコードを集約して前記第2のレコードパケットを形成することと、を含む、ステップと、
前記複数のレコードパケットを、前記複数のコンピュータプロセッサの1つ以上の処理オペレーションに関連付けられた複数のスレッドのそれぞれに転送するステップと、
を含むオペレーションを実行する、データ処理装置。 - 前記1つ以上の処理オペレーションは、前記複数のコンピュータプロセッサ上で実行しているデータ解析ワークフローに関連付けられる、
請求項11に記載のデータ処理装置。 - 前記1つ以上の処理オペレーションのそれぞれを実行して、線形順序で前記複数のレコードパケットについての対応するデータ解析機能を実行するステップをさらに含み、前記線形順序は、前記データ解析ワークフローにおけるオペレーションのシーケンスセットに従っている、
請求項12に記載のデータ処理装置。 - 前記1つ以上の処理オペレーションのそれぞれを実行することは、前記複数のコンピュータプロセッサのプロセッサ上で複数のスレッドのそれぞれを実行することによって行われる並列処理を含む、
請求項13に記載のデータ処理装置。 - 前記所定のサイズ容量は、前記キャッシュメモリの前記メモリサイズの大きさのオーダーである、
請求項11に記載のデータ処理装置。 - 複数のコンピュータプロセッサにオペレーションを実行させるためのコンピュータプログラムコードを格納している非一時的なコンピュータ可読メモリであって、前記複数のコンピュータプロセッサは、キャッシュメモリを有し、前記オペレーションは、
複数のデータレコードを含むデータストリームを取り出すステップと、
前記データストリームの前記複数のデータレコードを集約して複数のレコードパケットを形成するステップであって、前記複数のレコードパケットのそれぞれは、データ処理装置に関連付けられたキャッシュメモリのメモリサイズに基づいて決定される所定のサイズ容量を有し、前記所定のサイズ容量は、レコードパケットの最大サイズであり、前記データストリームの前記複数のデータレコードを集約して複数のレコードパケットを形成することは、前記複数のレコードパケットの第1のレコードパケットについて、前記第1のレコードパケットのサイズを、前記所定のサイズ容量に基づいて決定することと、前記第1のレコードパケットを形成するための第1の数のデータレコードを、前記第1のレコードパケットの前記サイズに基づいて決定することと、前記第1の数のデータレコードを集約して前記第1のレコードパケットを形成することと、前記複数のレコードパケットの第2のレコードパケットについて、前記第2のレコードパケットを形成するための第2の数のデータレコードを決定することであって、前記第2のレコードパケットが処理される前に前記第2の数のデータレコードを集約して前記第2のレコードパケットを形成するための待ち時間が、前記第1のレコードパケットが処理される前に前記第1の数のデータレコードを集約して前記第1のレコードパケットを形成するための待ち時間より小さくなるように、前記第2の数は前記第1の数より小さい、ことと、前記第2の数のデータレコードを集約して前記第2のレコードパケットを形成することと、を含む、ステップと、
前記複数のレコードパケットを、前記複数のコンピュータプロセッサについての1つ以上の処理オペレーションに関連付けられた複数のスレッドのそれぞれに転送するステップと、
を含む、非一時的なコンピュータ可読メモリ。 - 前記1つ以上の処理オペレーションは、前記複数のコンピュータプロセッサ上で実行しているデータ解析ワークフローに関連付けられる、
請求項16に記載のメモリ。 - 前記1つ以上の処理オペレーションのそれぞれを実行して、線形順序で前記複数のレコードパケットについての対応するデータ解析機能を実行するステップをさらに含み、前記線形順序は、前記データ解析ワークフローにおけるオペレーションのシーケンスセットに従っている、
請求項17に記載のメモリ。 - 前記1つ以上の処理オペレーションのそれぞれを実行することは、前記複数のコンピュータプロセッサのプロセッサ上で前記複数のスレッドのそれぞれを実行することによって行われる並列処理を含む、
請求項18に記載のメモリ。 - 前記所定のサイズ容量は、前記キャッシュメモリの前記メモリサイズの大きさのオーダーである、
請求項16に記載のメモリ。
Applications Claiming Priority (3)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
US15/595,880 | 2017-05-15 | ||
US15/595,880 US20180330288A1 (en) | 2017-05-15 | 2017-05-15 | Method of data aggregation for cache optimization and efficient processing |
PCT/US2018/032557 WO2018213184A1 (en) | 2017-05-15 | 2018-05-14 | Method of data aggregation for cache optimization and efficient processing |
Publications (2)
Publication Number | Publication Date |
---|---|
JP2020521238A JP2020521238A (ja) | 2020-07-16 |
JP7038740B2 true JP7038740B2 (ja) | 2022-03-18 |
Family
ID=64097311
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
JP2019563891A Active JP7038740B2 (ja) | 2017-05-15 | 2018-05-14 | キャッシュ最適化及び効率的な処理のためのデータ集約の方法 |
Country Status (9)
Country | Link |
---|---|
US (1) | US20180330288A1 (ja) |
EP (1) | EP3625688A4 (ja) |
JP (1) | JP7038740B2 (ja) |
KR (1) | KR20200029387A (ja) |
CN (1) | CN110914812A (ja) |
AU (1) | AU2018268991B2 (ja) |
CA (1) | CA3063731A1 (ja) |
SG (1) | SG11201909732QA (ja) |
WO (1) | WO2018213184A1 (ja) |
Families Citing this family (8)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US10831485B1 (en) * | 2017-09-01 | 2020-11-10 | Workday, Inc. | Flexible modular pipelined analytics |
US10649812B1 (en) | 2017-09-01 | 2020-05-12 | Workday, Inc. | Computation using tenant and commingling processors |
US10715459B2 (en) * | 2017-10-27 | 2020-07-14 | Salesforce.Com, Inc. | Orchestration in a multi-layer network |
GB2575292B (en) * | 2018-07-04 | 2020-07-08 | Graphcore Ltd | Code Compilation for Scaling Accelerators |
CN113114787A (zh) * | 2020-11-11 | 2021-07-13 | 周金华 | 基于数字化和云计算的业务资源共享方法及云服务器 |
KR20220083227A (ko) * | 2020-12-11 | 2022-06-20 | 삼성전자주식회사 | 패킷을 처리하기 위한 upf의 전자 장치 및 그의 동작 방법 |
CN113176911B (zh) * | 2021-04-29 | 2024-07-12 | 上海阵量智能科技有限公司 | 一种配置方法、数据处理方法、芯片和电子设备 |
US11762874B2 (en) * | 2021-07-28 | 2023-09-19 | Alteryx, Inc. | Interactive workflow for data analytics |
Citations (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2008054740A1 (en) | 2006-10-31 | 2008-05-08 | Hewlett-Packard Development Company, L.P. | Middleware framework |
US20090144304A1 (en) | 2007-11-30 | 2009-06-04 | Josh Stephens | Method for summarizing flow information of network devices |
US20120096223A1 (en) | 2010-10-15 | 2012-04-19 | Qualcomm Incorporated | Low-power audio decoding and playback using cached images |
US20130339473A1 (en) | 2012-06-15 | 2013-12-19 | Zynga Inc. | Real time analytics via stream processing |
US20140297652A1 (en) | 2013-03-15 | 2014-10-02 | Akuda Labs Llc | Hierarchical, Parallel Models for Extracting in Real-Time High-Value Information from Data Streams and System and Method for Creation of Same |
JP2015052977A (ja) | 2013-09-09 | 2015-03-19 | 日本電信電話株式会社 | 負荷分散装置、負荷分散方法および負荷分散プログラム |
US20150134626A1 (en) | 2013-11-11 | 2015-05-14 | Amazon Technologies, Inc. | Partition-based data stream processing framework |
Family Cites Families (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US6606704B1 (en) * | 1999-08-31 | 2003-08-12 | Intel Corporation | Parallel multithreaded processor with plural microengines executing multiple threads each microengine having loadable microcode |
US6564274B1 (en) * | 1999-12-17 | 2003-05-13 | Omnicluster Technologies, Inc. | Modular architecture for small computer networks |
US9552299B2 (en) * | 2010-06-11 | 2017-01-24 | California Institute Of Technology | Systems and methods for rapid processing and storage of data |
EP2692092B1 (en) * | 2011-03-28 | 2014-12-17 | Citrix Systems Inc. | Systems and methods for tracking application layer flow via a multi-connection intermediary device |
EP2946296A4 (en) * | 2013-01-17 | 2016-11-16 | Xockets Ip Llc | DELIBRATION PROCESSOR MODULES FOR CONNECTING TO A SYSTEM MEMORY |
US10069766B2 (en) * | 2015-07-07 | 2018-09-04 | TransferSoft, Inc. | Accelerated data transfer using thread pool for parallel operations |
US10198298B2 (en) * | 2015-09-16 | 2019-02-05 | Salesforce.Com, Inc. | Handling multiple task sequences in a stream processing framework |
-
2017
- 2017-05-15 US US15/595,880 patent/US20180330288A1/en not_active Abandoned
-
2018
- 2018-05-14 KR KR1020197034449A patent/KR20200029387A/ko not_active Application Discontinuation
- 2018-05-14 JP JP2019563891A patent/JP7038740B2/ja active Active
- 2018-05-14 CN CN201880032232.1A patent/CN110914812A/zh active Pending
- 2018-05-14 EP EP18803151.2A patent/EP3625688A4/en not_active Withdrawn
- 2018-05-14 SG SG11201909732Q patent/SG11201909732QA/en unknown
- 2018-05-14 WO PCT/US2018/032557 patent/WO2018213184A1/en unknown
- 2018-05-14 AU AU2018268991A patent/AU2018268991B2/en active Active
- 2018-05-14 CA CA3063731A patent/CA3063731A1/en active Pending
Patent Citations (12)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2008054740A1 (en) | 2006-10-31 | 2008-05-08 | Hewlett-Packard Development Company, L.P. | Middleware framework |
US20080120592A1 (en) | 2006-10-31 | 2008-05-22 | Tanguay Donald O | Middleware framework |
JP2010508574A (ja) | 2006-10-31 | 2010-03-18 | ヒューレット−パッカード デベロップメント カンパニー エル.ピー. | ミドルウェアフレームワーク |
US20090144304A1 (en) | 2007-11-30 | 2009-06-04 | Josh Stephens | Method for summarizing flow information of network devices |
US20120096223A1 (en) | 2010-10-15 | 2012-04-19 | Qualcomm Incorporated | Low-power audio decoding and playback using cached images |
WO2012051579A1 (en) | 2010-10-15 | 2012-04-19 | Qualcomm Incorporated | Low-power audio decoding and playback using cached images |
JP2013539892A (ja) | 2010-10-15 | 2013-10-28 | クゥアルコム・インコーポレイテッド | キャッシュされたイメージを用いた低電力のオーディオのデコーディングおよび再生 |
US20130339473A1 (en) | 2012-06-15 | 2013-12-19 | Zynga Inc. | Real time analytics via stream processing |
US20140297652A1 (en) | 2013-03-15 | 2014-10-02 | Akuda Labs Llc | Hierarchical, Parallel Models for Extracting in Real-Time High-Value Information from Data Streams and System and Method for Creation of Same |
JP2015052977A (ja) | 2013-09-09 | 2015-03-19 | 日本電信電話株式会社 | 負荷分散装置、負荷分散方法および負荷分散プログラム |
US20150134626A1 (en) | 2013-11-11 | 2015-05-14 | Amazon Technologies, Inc. | Partition-based data stream processing framework |
JP2016536690A (ja) | 2013-11-11 | 2016-11-24 | アマゾン・テクノロジーズ・インコーポレーテッド | パーティションベースのデータストリーム処理フレームワーク |
Also Published As
Publication number | Publication date |
---|---|
AU2018268991A1 (en) | 2019-10-31 |
JP2020521238A (ja) | 2020-07-16 |
AU2018268991B2 (en) | 2020-10-15 |
EP3625688A1 (en) | 2020-03-25 |
US20180330288A1 (en) | 2018-11-15 |
CN110914812A (zh) | 2020-03-24 |
EP3625688A4 (en) | 2020-12-30 |
WO2018213184A1 (en) | 2018-11-22 |
KR20200029387A (ko) | 2020-03-18 |
SG11201909732QA (en) | 2019-11-28 |
CA3063731A1 (en) | 2018-11-22 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
JP7038740B2 (ja) | キャッシュ最適化及び効率的な処理のためのデータ集約の方法 | |
JP6750137B1 (ja) | 並列処理を使用したハッシュ結合の実行 | |
US10447772B2 (en) | Managed function execution for processing data streams in real time | |
CN109643312B (zh) | 托管查询服务 | |
CN109997126B (zh) | 事件驱动提取、变换、加载(etl)处理 | |
US10078843B2 (en) | Systems and methods for analyzing consumer sentiment with social perspective insight | |
TW201820165A (zh) | 用於雲端巨量資料運算架構之伺服器及其雲端運算資源最佳化方法 | |
CN109726004B (zh) | 一种数据处理方法及装置 | |
US20150195344A1 (en) | Method and System for a Scheduled Map Executor | |
CN109614227A (zh) | 任务资源调配方法、装置、电子设备及计算机可读介质 | |
US10326824B2 (en) | Method and system for iterative pipeline | |
US11042530B2 (en) | Data processing with nullable schema information | |
JP2023544904A (ja) | 機械学習パイプラインの分散型リソースアウェアトレーニング | |
Roy et al. | A proposal for optimization of horizontal scaling in big data environment | |
US9772877B2 (en) | Managing I/O operations in a shared file system | |
Al-Obeidat et al. | A microservices persistence technique for cloud-based online social data analysis | |
Singh et al. | MCC and Big Data Integration for Various Technological Frameworks | |
Guide | Getting Started with Big Data | |
Selvi et al. | An improved Hadoop performance model with automated resource provisioning and scalable data chunk similarity compression within constrained deadline |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20191113 |
|
A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20201111 |
|
A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20210105 |
|
A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20210323 |
|
A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20210907 |
|
A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20211203 |
|
TRDD | Decision of grant or rejection written | ||
A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20220208 |
|
A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20220308 |
|
R150 | Certificate of patent or registration of utility model |
Ref document number: 7038740 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |