Publication Information

{'id': 'https://openalex.org/W3091112164', 'doi': None, 'title': 'Efficient Stateful Computations in Distributed Stream Processing', 'display_name': 'Efficient Stateful Computations in Distributed Stream Processing', 'publication_year': 2020, 'publication_date': '2020-01-01', 'ids': {'openalex': 'https://openalex.org/W3091112164', 'mag': '3091112164'}, 'language': 'en', 'primary_location': {'is_oa': False, 'landing_page_url': 'https://minerva-access.unimelb.edu.au/bitstream/handle/11343/244125/352ad0f6-0a85-ea11-94bd-0050568d7800_sachini_thesis.pdf', 'pdf_url': None, 'source': None, 'license': None, 'license_id': None, 'version': None, 'is_accepted': False, 'is_published': False}, 'type': 'dissertation', 'type_crossref': 'dissertation', 'indexed_in': [], 'open_access': {'is_oa': False, 'oa_status': 'closed', 'oa_url': None, 'any_repository_has_fulltext': False}, 'authorships': [{'author_position': 'first', 'author': {'id': 'https://openalex.org/A5053796991', 'display_name': 'Weragoda Achchillage Sachini Jayasekara', 'orcid': None}, 'institutions': [], 'countries': [], 'is_corresponding': True, 'raw_author_name': 'Weragoda Achchillage Sachini Jayasekara', 'raw_affiliation_strings': [], 'affiliations': []}], 'institution_assertions': [], 'countries_distinct_count': 0, 'institutions_distinct_count': 0, 'corresponding_author_ids': ['https://openalex.org/A5053796991'], 'corresponding_institution_ids': [], 'apc_list': None, 'apc_paid': None, 'fwci': None, 'has_fulltext': False, 'cited_by_count': 0, 'citation_normalized_percentile': {'value': 0.0, 'is_in_top_1_percent': False, 'is_in_top_10_percent': False}, 'cited_by_percentile_year': {'min': 0, 'max': 60}, 'biblio': {'volume': None, 'issue': None, 'first_page': None, 'last_page': None}, 'is_retracted': False, 'is_paratext': False, 'primary_topic': {'id': 'https://openalex.org/T10772', 'display_name': 'Distributed systems and fault tolerance', 'score': 0.9995, 'subfield': {'id': 'https://openalex.org/subfields/1705', 'display_name': 'Computer Networks and Communications'}, 'field': {'id': 'https://openalex.org/fields/17', 'display_name': 'Computer Science'}, 'domain': {'id': 'https://openalex.org/domains/3', 'display_name': 'Physical Sciences'}}, 'topics': [{'id': 'https://openalex.org/T10772', 'display_name': 'Distributed systems and fault tolerance', 'score': 0.9995, 'subfield': {'id': 'https://openalex.org/subfields/1705', 'display_name': 'Computer Networks and Communications'}, 'field': {'id': 'https://openalex.org/fields/17', 'display_name': 'Computer Science'}, 'domain': {'id': 'https://openalex.org/domains/3', 'display_name': 'Physical Sciences'}}, {'id': 'https://openalex.org/T10317', 'display_name': 'Advanced Database Systems and Queries', 'score': 0.9984, 'subfield': {'id': 'https://openalex.org/subfields/1705', 'display_name': 'Computer Networks and Communications'}, 'field': {'id': 'https://openalex.org/fields/17', 'display_name': 'Computer Science'}, 'domain': {'id': 'https://openalex.org/domains/3', 'display_name': 'Physical Sciences'}}, {'id': 'https://openalex.org/T11181', 'display_name': 'Advanced Data Storage Technologies', 'score': 0.9939, 'subfield': {'id': 'https://openalex.org/subfields/1705', 'display_name': 'Computer Networks and Communications'}, 'field': {'id': 'https://openalex.org/fields/17', 'display_name': 'Computer Science'}, 'domain': {'id': 'https://openalex.org/domains/3', 'display_name': 'Physical Sciences'}}], 'keywords': [{'id': 'https://openalex.org/keywords/stream-processing', 'display_name': 'Stream Processing', 'score': 0.79642665}], 'concepts': [{'id': 'https://openalex.org/C22927095', 'wikidata': 'https://www.wikidata.org/wiki/Q1784206', 'display_name': 'Stateful firewall', 'level': 3, 'score': 0.9781671}, {'id': 'https://openalex.org/C41008148', 'wikidata': 'https://www.wikidata.org/wiki/Q21198', 'display_name': 'Computer science', 'level': 0, 'score': 0.8224448}, {'id': 'https://openalex.org/C107027933', 'wikidata': 'https://www.wikidata.org/wiki/Q2006448', 'display_name': 'Stream processing', 'level': 2, 'score': 0.79642665}, {'id': 'https://openalex.org/C103613024', 'wikidata': 'https://www.wikidata.org/wiki/Q230924', 'display_name': 'Stateless protocol', 'level': 3, 'score': 0.7146975}, {'id': 'https://openalex.org/C120314980', 'wikidata': 'https://www.wikidata.org/wiki/Q180634', 'display_name': 'Distributed computing', 'level': 1, 'score': 0.7116994}, {'id': 'https://openalex.org/C48044578', 'wikidata': 'https://www.wikidata.org/wiki/Q727490', 'display_name': 'Scalability', 'level': 2, 'score': 0.6891643}, {'id': 'https://openalex.org/C55439883', 'wikidata': 'https://www.wikidata.org/wiki/Q360812', 'display_name': 'Correctness', 'level': 2, 'score': 0.6552832}, {'id': 'https://openalex.org/C45374587', 'wikidata': 'https://www.wikidata.org/wiki/Q12525525', 'display_name': 'Computation', 'level': 2, 'score': 0.44786823}, {'id': 'https://openalex.org/C48103436', 'wikidata': 'https://www.wikidata.org/wiki/Q599031', 'display_name': 'State (computer science)', 'level': 2, 'score': 0.32065946}, {'id': 'https://openalex.org/C31258907', 'wikidata': 'https://www.wikidata.org/wiki/Q1301371', 'display_name': 'Computer network', 'level': 1, 'score': 0.22401863}, {'id': 'https://openalex.org/C111919701', 'wikidata': 'https://www.wikidata.org/wiki/Q9135', 'display_name': 'Operating system', 'level': 1, 'score': 0.13056403}, {'id': 'https://openalex.org/C11413529', 'wikidata': 'https://www.wikidata.org/wiki/Q8366', 'display_name': 'Algorithm', 'level': 1, 'score': 0.119761765}, {'id': 'https://openalex.org/C158379750', 'wikidata': 'https://www.wikidata.org/wiki/Q214111', 'display_name': 'Network packet', 'level': 2, 'score': 0.0}], 'mesh': [], 'locations_count': 1, 'locations': [{'is_oa': False, 'landing_page_url': 'https://minerva-access.unimelb.edu.au/bitstream/handle/11343/244125/352ad0f6-0a85-ea11-94bd-0050568d7800_sachini_thesis.pdf', 'pdf_url': None, 'source': None, 'license': None, 'license_id': None, 'version': None, 'is_accepted': False, 'is_published': False}], 'best_oa_location': None, 'sustainable_development_goals': [{'display_name': 'Peace, justice, and strong institutions', 'score': 0.73, 'id': 'https://metadata.un.org/sdg/16'}], 'grants': [], 'datasets': [], 'versions': [], 'referenced_works_count': 0, 'referenced_works': [], 'related_works': ['https://openalex.org/W3206912480', 'https://openalex.org/W3202350487', 'https://openalex.org/W3194568002', 'https://openalex.org/W3178996643', 'https://openalex.org/W3118604016', 'https://openalex.org/W3011543501', 'https://openalex.org/W2995753792', 'https://openalex.org/W2983211454', 'https://openalex.org/W2887332955', 'https://openalex.org/W2788706845', 'https://openalex.org/W2783620277', 'https://openalex.org/W2605844966', 'https://openalex.org/W2521836998', 'https://openalex.org/W2165022815', 'https://openalex.org/W2097244736', 'https://openalex.org/W2078349455', 'https://openalex.org/W2048784665', 'https://openalex.org/W1951329152', 'https://openalex.org/W1870609547', 'https://openalex.org/W1546275500'], 'abstract_inverted_index': {'Stream': [0], 'processing': [1, 25, 51, 76, 153, 221, 251, 459], 'is': [2, 164, 182, 271, 451, 601, 627], 'used': [3, 204, 297, 363, 398, 564], 'in': [4, 78, 101, 212, 304, 327, 378, 384, 388, 506, 577, 639, 662, 671], 'a': [5, 70, 102, 156, 216, 237, 246, 254, 262, 328, 432, 440, 463, 632, 640, 647], 'plethora': [6], 'of': [7, 16, 35, 63, 73, 122, 140, 151, 219, 239, 273, 292, 306, 324, 354, 380, 386, 442, 447, 496, 521, 542, 561, 607, 620, 664], 'applications': [8, 37, 77, 214, 509], 'that': [9, 44, 113, 128, 202, 226, 235, 252, 284, 333, 342, 425, 461, 512, 526, 572, 616, 645, 654], 'deal': [10], 'with': [11, 186, 583], 'high': [12, 352], 'volumes': [13], 'and': [14, 22, 96, 134, 173, 242, 308, 315, 347, 351, 382, 403, 435, 492, 510, 580, 587, 610], 'varieties': [15], 'data.': [17], 'The': [18, 223], 'focus': [19], 'towards': [20], 'scalable': [21, 131], 'efficient': [23, 126, 318], 'stream': [24, 50, 75, 152, 220, 250, 458], 'solutions': [26, 376], 'has': [27, 66], 'been': [28], 'increasing': [29], 'due': [30], 'to': [31, 56, 68, 93, 115, 118, 145, 159, 169, 195, 205, 257, 265, 281, 288, 298, 320, 359, 484, 550, 556, 603, 630], 'the': [32, 61, 120, 123, 141, 147, 175, 179, 207, 274, 286, 290, 322, 349, 355, 360, 393, 409, 413, 421, 427, 437, 445, 452, 474, 480, 489, 493, 497, 501, 513, 519, 557, 573, 596, 605, 612, 618, 621, 628], 'vast': [33], 'number': [34], 'time-sensitive': [36], 'such': [38], 'as': [39, 667, 669], 'electronic': [40], 'trading,': [41], 'fraud': [42], 'detection': [43], 'have': [45, 110, 236, 302, 343], 'low': [46, 148], 'latency': [47, 149, 387, 579, 589], 'requirements.': [48], 'While': [49], 'systems': [52, 460], 'were': [53], 'originally': [54], 'envisaged': [55], 'use': [57, 62, 199, 233, 462, 500], 'only': [58, 487], 'stateless': [59, 81], 'computations,': [60, 82, 294], 'stateful': [64, 84, 108, 171, 187, 198, 277], 'computations': [65, 85, 109, 172, 269, 301, 326], 'grown': [67], 'accommodate': [69], 'greater': [71], 'range': [72, 541], 'complex': [74, 197, 344], 'various': [79], 'domains.\n\nUnlike': [80], 'supporting': [83], 'requires': [86], 'addressing': [87], 'new': [88], 'challenges': [89], 'including': [90], 'state': [91, 97, 132, 135, 161, 291, 323], 'distribution': [92, 133], 'achieve': [94, 533], 'scalability': [95, 307, 313, 350], 'sharing': [98, 136], 'among': [99], 'resources': [100], 'distributed': [103, 329], 'environment.': [104, 330], 'For': [105, 369], 'instance,': [106], 'most': [107, 275, 394, 566], 'synchronization': [111], 'requirements': [112], 'need': [114], 'be': [116, 485], 'satisfied': [117], 'guarantee': [119], 'correctness': [121, 139], 'results.': [124], 'Therefore,': [125], 'mechanisms': [127], 'can': [129, 336, 407, 517, 532], 'support': [130, 170, 196, 266, 338], 'while': [137], 'ensuring': [138], 'results': [142, 576], 'are': [143, 203, 215], 'needed': [144], 'satisfy': [146], 'requirement': [150], 'applications.': [154, 368, 523], 'Moreover,': [155, 568], 'fault-tolerance': [157, 180, 396], 'mechanism': [158, 181], 'recover': [160], 'after': [162], 'failures': [163, 547, 552], 'an': [165, 317, 418, 470], 'essential': [166], 'functionality': [167], 'required': [168], 'minimizing': [174], 'overhead': [176, 410, 619], 'imposed': [177, 411], 'by': [178, 399, 412, 565, 666], 'another': [183], 'challenge': [184], 'associated': [185], 'computations.\n\nThis': [188], 'thesis': [189], 'first': [190, 453, 629], 'focuses': [191], 'on': [192, 488], 'providing': [193], 'models': [194, 225], 'cases.': [200, 673], 'Windows': [201], 'partition': [206], 'continuous': [208], 'input': [209], 'streams': [210], 'expected': [211], 'streaming': [213, 367, 508], 'main': [217], 'component': [218], 'systems.': [222, 567], 'existing': [224, 295, 374, 400, 658], 'define': [227], 'window': [228, 240], 'semantics': [229], 'do': [230], 'not': [231], 'represent': [232, 299], 'cases': [234], 'hierarchy': [238], 'stages': [241], 'therefore,': [243], 'we': [244, 260, 391, 406, 499, 570, 594], 'propose': [245, 261], 'generic': [247], 'model': [248, 264, 335, 357, 372, 434, 438, 468], 'for': [249, 364, 420, 457, 473, 591], 'supports': [253], 'hierarchical': [255], 'approach': [256, 397, 599], 'windowing.': [258], 'Then': [259], 'communication': [263, 282, 345], 'iterative': [268, 293, 300, 325, 340, 366], 'which': [270, 600], 'one': [272], 'common': [276, 395], 'computation': [278], 'types.': [279], 'Due': [280], 'restrictions': [283], 'limit': [285], 'ways': [287], 'share': [289, 321], 'approaches': [296, 362], 'limitations': [303], 'terms': [305, 379, 385, 663], 'efficiency.': [309], 'We': [310, 331, 416, 524, 652], 'address': [311, 404, 604], 'these': [312], 'issues': [314], 'provide': [316], 'way': [319], 'demonstrate': [332, 511, 525, 653], 'our': [334, 371, 448, 527, 655], 'different': [339], 'algorithms': [341], 'patterns': [346], 'show': [348, 571], 'performance': [353, 520], 'proposed': [356], 'compared': [358, 555], 'traditional': [361], 'constructing': [365], 'example,': [370], 'outperforms': [373, 657], 'state-of-the-art': [375], '72%': [377], 'throughput': [381, 585], '65%': [383], 'some': [389, 592, 672], 'cases.\n\nNext,': [390], 'investigate': [392, 595], 'systems,': [401], 'checkpointing': [402, 414, 465, 598, 609, 614, 623, 643], 'how': [405], 'minimize': [408, 617], 'process.': [415, 624], 'derive': [417, 611], 'expression': [419, 472], 'optimal': [422, 475, 481, 503, 515, 529, 574, 613, 636], 'checkpoint': [423, 476, 482, 490, 504, 530, 559, 650], 'interval': [424, 483, 505, 516, 531, 560, 575], 'gives': [426], 'maximum': [428], 'system': [429, 644], 'utilization': [430, 534, 665], 'using': [431, 439], 'theoretical': [433, 454, 514, 528, 633], 'validate': [436], 'set': [441], 'simulations.': [443], 'To': [444], 'best': [446], 'knowledge,': [449], 'this': [450], 'optimization': [455], 'framework': [456], 'global': [464, 642], 'approach.': [466], 'Our': [467], 'yields': [469], 'elegant': [471], 'interval,': [477], 'interestingly': [478], 'showing': [479], 'dependent': [486], 'cost': [491], 'failure': [494, 543], 'rate': [495], 'system.\n\nNext,': [498], 'derived': [502], 'real-world': [507], 'improve': [518], 'practical': [522], 'improvements': [535], 'from': [536, 545], '10%': [537], '-': [538], '200%': [539], 'for\na': [540], 'rates': [544], '0.3': [546], 'per': [548, 553], 'hour': [549], '0.075': [551], 'minute': [554], 'default': [558], '30': [562], 'minutes': [563], 'lower': [578], 'higher': [581], 'throughput,': [582], '54%': [584], 'increase': [586], '58%': [588], 'decrease': [590], 'cases.\n\nThen': [593], 'multi-level': [597, 622, 641], 'introduced': [602], 'inefficiencies': [606], 'single-level': [608], 'parameters': [615], 'This': [625], 'work': [626], 'present': [631], 'framework\nfor': [634], 'determining': [635], 'parameter': [637], 'settings': [638], 'uses': [646], 'single': [648, 659], 'periodic': [649], 'interval.': [651], 'solution': [656], 'level': [660], 'optimizations': [661], 'much': [668], '36%': [670]}, 'cited_by_api_url': 'https://api.openalex.org/works?filter=cites:W3091112164', 'counts_by_year': [], 'updated_date': '2024-12-30T21:09:27.250118', 'created_date': '2020-10-08'}