Certain aspects of the disclosure are directed to providing aggregated context information in a data communications network. According to a specific example, a data communications server can operate to provide user-data communications sessions each involving a client-specific endpoint device and another participating endpoint device, where the client-specific endpoint device is associated with a client-entity among a plurality of remotely-situated client entities. User-data communications between the client-specific endpoint device and the other participating endpoint device can be retrieved from a plurality of disparate interconnected data communications systems, where the data communications systems each provide at least one data communications service to the client entity on a subscription basis. Context information for each respective user-data communication between the client-specific endpoint device and the other participating endpoint device can be aggregated and displayed in a disparate-system data room, where the aggregated context information includes an indication of the context for each user-data communication.

A computing system includes a first camera, a second camera, a microphone, and a display. The computing system is configured to independently activate the first camera and/or the second camera. The computing system first receives a user input initiating a two-way camera operation using both the first camera and the second camera. In response to the user input, the computing system activates the first camera and generates a first visualization, displaying a first image generated by the first camera, and activates the second camera and generates a second visualization, displaying a second image generated by the second camera. Both the first visualization and the second visualization are simultaneously displayed on the display of the computing system, while functions of each of the first camera and second camera can be started, stopped paused unpaused or modified individually.

A system for querying a graph model and methods for making and using same. An initial vertex set can be received for one or more query blocks. The one or more query blocks can be executed to generate respective output vertex sets. The output vertex sets and the initial vertex set can be enabled to interconnect in a vertex-set-flow graph based on the query blocks. The vertex-set-flow graph can have a Directed Acyclic Graph shape. A selected query block can generate an output vertex set based on an input vertex set with or without traversal over an edge. A selected query block can calculate a runtime attribute. Edges and/or vertices of the graph model can be updated during querying. A selected block can call a graph query as a generic function. Functions for querying the graph model are powerful and can advantageously meet various graph query needs.

Systems and methods are described for unified processing of indexed and streaming data. A system enables users to query indexed data or specify processing pipelines to be applied to streaming data. In some instances, a user may specify a query intended to be run against indexed data, but may specify criteria that includes not-yet-indexed data (e.g., a future time frame). The system may convert the query into a data processing pipeline applied to not-yet-indexed data, thus increasing the efficiency of the system. Similarly, in some instances, a user may specify a data processing pipeline to be applied to a data stream, but specify criteria including data items outside the data stream. For example, a user may wish to apply the pipeline retroactively, to data items that have already exited the data stream. The system can convert the pipeline into a query against indexed data to satisfy the users processing requirements.

A computer-implemented method and a media acquisition system (MAS) for accessing media from attendees of an event are provided. The MAS receives registration and event details from an organizer of the event and generates an online portal with media request elements. The MAS generates a shareable link to the online portal in multiple formats for rendering the shareable link to the attendees. The MAS displays the online portal on electronic devices of the attendees that access the online portal through the shareable link in one of the formats. The MAS acquires media from the electronic devices of the attendees agreeing to share the media with the organizer through a live media capture or an access of stored media. The MAS analyzes the acquired media according to organizer preferences and shares a selection of the analyzed media on preselected social media platforms on receiving a corresponding request from the organizer.

Provided is an aggregation index structure and an aggregation index method for improving aggregation query efficiency. The aggregation index partitions streaming data through two dimensions of grouping and slicing, and then aggregates the partitioned data. The structure includes index metadata, a sliced data list and a detailed data store; the aggregation index method includes three parts: aggregation index definition, aggregation index creation and aggregation index query. The aggregation index structure and method provided by the present disclosure can greatly improve the efficiency of aggregation query, support the ad hoc aggregation query of PB-level data, complete the aggregation query of a large amount of data in seconds, support the insertion of new data at any time, and return the query results in minutes or even seconds latency in the event of changes of the query range conditions.

Present embodiments include an agent automation framework having a similarity scoring subsystem that performs meaning representation similarity scoring to facilitate extraction of artifacts to address an utterance. The similarity scoring subsystem identifies a CCG form of an utterance-based meaning representation and queries a database to retrieve a comparison function list that enables quantifications of similarities between the meaning representation and candidates within a search space. The comparison functions enable the similarity scoring subsystem to perform computationally-cheapest and/or most efficient comparisons before other comparisons. The similarity scoring subsystem may determine an initial similarity score between the particular meaning representation and the candidates of the search space, then prune non-similar candidates from the search space. Selective search space pruning enables the similarity scoring subsystem to iteratively compare more data of the meaning representation to the search space via increasingly-complex comparison functions, while narrowing the search space to potentially-matching candidates.

A method for data ingestion for a data visualization platform comprises receiving a plurality of data sets, generating and storing a merged data set based on the plurality of received data sets, and, receiving, via a graphical user interface, a first input comprising an instruction to perform a data standardization operation. The method comprises, in response to receiving the first input, applying a data standardization operation to the merged data set to process the merged data set to generate a standardized data set. The method comprises receiving, via the interface, a second input comprising an instruction to perform a data analytics operation, and responsively applying the data analytics operation to the standardized data set to generate insights data. The method includes receiving, via the interface, a third input comprising an instruction to perform a data visualization operation, and responsively generating one or more data visualizations based on the insights data.

In an example embodiment, a solution is provided that aggregates records as they are submitted to a third party (on the write path) rather than performing a real-time aggregation when a request is processed that needs the aggregation (read path). More particularly, in an example embodiment, a caching layer is introduced that avoids having to read all usage events to compute an aggregation when a request is received for aggregated data. The caching layer maintains values for various metrics that require aggregation.

A system for spilling comprises an interface and a processor. The interface is configured to receive an indication to perform a GROUP BY operation, wherein the indication comprises an input table and a grouping column. The processor is configured to: for each input table entry of the input table, determine a key, wherein the key is based at least in part on the input table entry and the grouping column; add the key to a grouping hash table, wherein adding the key to the grouping hash table comprises last-in, first-out (LIFO) spilling when necessary; create an output table based at least in part on the grouping hash table; and provide the output table.