PROCESSING DELETED EDGES IN GRAPH DATABASES
Granted: May 24, 2018
Application Number:
20180144060
The disclosed embodiments provide a system for processing queries of a graph database. During operation, the system executes one or more processes for processing queries of a graph database storing a graph, wherein the graph comprises a set of nodes, a set of edges between pairs of nodes in the set of nodes, and a set of predicates. When a query of the graph database is received, the system processes the query by matching a query time of the query to a virtual time in a log-based…
SECURE VIRTUALIZATION OF REMOTE STORAGE SYSTEMS
Granted: May 17, 2018
Application Number:
20180139208
The disclosed embodiments provide a system for managing access to a remote storage system. During operation, the system receives a request from a user to access a remote storage system. Next, the system matches one or more parameters in the request to metadata in a virtual filesystem in the remote storage system. The system then processes the request by using the metadata to access one or more files in a file store that is physically separate from the virtual filesystem
SECURING FILES AT REST IN REMOTE STORAGE SYSTEMS
Granted: May 17, 2018
Application Number:
20180137291
The disclosed embodiments provide a system for managing access to a remote storage system. During operation, the system receives a first request from a user to write a file to a remote storage system. Next, the system receives a first encrypted version of the file from a client associated with the first request. The system then decrypts the first encrypted version to obtain an unencrypted version of the file and uses the unencrypted version to generate a second encrypted version of the…
AUTOMATICALLY DETECTING LATENCY BOTTLENECKS IN ASYNCHRONOUS WORKFLOWS
Granted: May 3, 2018
Application Number:
20180123918
The disclosed embodiments provide a system for processing data. During operation, the system generates, from a set of traces of an asynchronous workflow, a graph-based representation of the asynchronous workflow. Next, the system uses a set of causal relationships in the asynchronous workflow to update the graph-based representation. The system then analyzes the updated graph-based representation to identify a set of high-latency paths in the asynchronous workflow. Finally, the system…
FACTOR-BASED PROCESSING OF PERFORMANCE METRICS
Granted: May 3, 2018
Application Number:
20180121856
The disclosed embodiments provide a system for processing data. During operation, the system obtains, for a time interval, a set of performance metrics for one or more monitored systems. Next, the system aggregates the performance metrics by a processing factor associated with execution of the monitored system(s). The system then uses the aggregated performance metrics to calculate a performance score associated with the processing factor. Finally, the system outputs the performance…
ENCODING EDGES IN GRAPH DATABASES
Granted: May 3, 2018
Application Number:
20180121512
The disclosed embodiments provide a system for processing data. During operation, the system obtains a group of two or more integer values. Next, the system sets, for each integer value in the two or more integer values, a delta encoding tag that represents a delta encoding of the integer value with respect to at least one other integer value in the group and uses a delta encoding state represented by the delta encoding tag to calculate an encoded value from the integer value. The system…
IDENTIFYING REQUEST-LEVEL CRITICAL PATHS IN MULTI-PHASE PARALLEL TASKS
Granted: May 3, 2018
Application Number:
20180121311
The disclosed embodiments provide a system for processing data. During operation, the system obtains a set of latencies for a set of requests in a multi-phase parallel task. Next, the system includes the latencies in a graph-based representation of the multi-phase parallel task. The system then analyzes the graph-based representation to identify a set of high-latency paths in the multi-phase parallel task. Finally, the system uses the set of high-latency paths to output an execution…
REDUCING FLOODING OF LINK STATE CHANGES IN NETWORKS
Granted: April 26, 2018
Application Number:
20180115481
The disclosed embodiments provide a system for transmitting a link state message in a network. During operation, the system obtains a network topology for the network. Next, the system uses the network topology to identify a reflood set of neighbors of the flooding node for reaching a set of two-hop neighbors of the flooding node. The system then transmits a link state message with an indication to reflood the link state message to the reflood set of neighbors. Finally, the system…
TRANSFORMING AND EVALUATING MISSING VALUES IN GRAPH DATABASES
Granted: April 26, 2018
Application Number:
20180113908
The disclosed embodiments provide a system for processing queries of a graph database. During operation, the system executes one or more processes for providing the graph database storing a graph, wherein the graph includes a set of nodes, a set of edges between pairs of nodes in the set of nodes, and a set of predicates. Next, the system receives a query containing a missing value parameter, wherein the missing value parameter designates an attribute in the graph database with a…
PERFORMING UPDATES ON VARIABLE-LENGTH DATA SEQUENTIALLY STORED AND INDEXED TO FACILITATE REVERSE READING
Granted: April 19, 2018
Application Number:
20180107419
A system, method, and apparatus are provided for performing update operations on variable-length data records stored and indexed to facilitate reverse reading. Each record contains a key offset for each key field, and the key offset stores a reference (e.g., an offset) to the next most recently stored record that has the same value for the key. Key offsets of a new set of records are configured based on the data index and an assumed write location (e.g., an end offset of the data). The…
BALANCING WORKLOAD ACROSS NODES IN A MESSAGE BROKERING CLUSTER
Granted: March 29, 2018
Application Number:
20180091588
A system, apparatus, and methods are provided for balancing partition distribution across nodes within a message broker cluster so as to balance the broker nodes' workloads. During operation, the system receives a stream of messages at the cluster, wherein the message stream is divided into topics, the topics are divided into partitions, and replicas for each partition are distributed among the nodes of the message brokering cluster. Upon detection of an imbalance in the nodes' workloads…
SELF-HEALING A MESSAGE BROKERING CLUSTER
Granted: March 29, 2018
Application Number:
20180091586
A system, apparatus, and methods are provided for self-healing and balancing partition distribution across nodes within a message broker cluster. During operation, the system receives a stream of messages at the message brokering cluster, wherein the message stream is divided into partitions and replicas for each partition are distributed among a set of nodes within the message brokering cluster. Responsive to a change in the number of nodes within the message brokering cluster, the…
PATTERN-BASED SEARCHING OF LOG-BASED REPRESENTATIONS OF GRAPH DATABASES
Granted: March 29, 2018
Application Number:
20180089331
The disclosed embodiments provide a system that searches a graph database. During operation, the system obtains a log-based representation of a graph database storing a graph, wherein the graph comprises a set of nodes, a set of edges between pairs of nodes in the set of nodes, and a set of predicates. Next, the system obtains a first query containing a first search pattern for searching the log-based representation. The system then matches the first search pattern to one or more records…
TWO-SIDED NETWORK GROWTH OPTIMIZATION IN SOCIAL NETWORKS
Granted: March 29, 2018
Application Number:
20180089318
The disclosed embodiments provide a system for facilitating interaction within a social network. During operation, the system identifies a first member of a social network with a first activity level that is lower than a threshold. Next, the system uses the first activity level to boost a score associated with recommending an interaction with the first member to a second member of the social network. The system then uses the boosted score to generate output for modulating subsequent…
VERIFYING CORRECTNESS IN GRAPH DATABASES
Granted: March 29, 2018
Application Number:
20180089252
The disclosed embodiments provide a system that verifies correctness in a graph database. During operation, the system obtains a set of records from a source of truth for a graph database storing a graph, wherein the graph includes a set of nodes, a set of edges between pairs of nodes in the set of nodes, and a set of predicates. Next, the system uses the records to automatically generate a set of test cases containing a set of queries of the graph database. The system then transmits the…
USING POTENTIAL INTERACTIONS TO IMPROVE SUBSEQUENT SOCIAL NETWORK ACTIVITY
Granted: March 29, 2018
Application Number:
20180089192
The disclosed embodiments provide a system for facilitating interaction within a social network. During operation, the system obtains a set of features associated with two members of a social network, wherein the features comprise a member feature and an activity feature. Next, the system analyzes the features to predict an effect of a potential interaction between the two members on subsequent interactions between the two members in the social network. The system then uses the predicted…
DISTRIBUTED COMPUTATION OF PERCENTILE STATISTICS FOR MULTIDIMENSIONAL DATA SETS
Granted: March 8, 2018
Application Number:
20180068005
The disclosed embodiments provide a system for processing data. During operation, the system obtains a set of partitions containing a set of records, wherein the records include a set of values for a measure and a set of dimensions associated with the values. Next, the system reorganizes the records across the partitions by performing a distributed sort of the records by the measure. For each dimensional subset in the records, the system counts occurrences of the dimensional subset in…
SCHEMA ABSTRACTION IN DATA ECOSYSTEMS
Granted: March 1, 2018
Application Number:
20180060404
The disclosed embodiments provide a system for performing data management. During operation, the system obtains a first schema with a first syntax for describing a first data set and a second schema with a second syntax for describing a second data set. Next, the system converts the first schema into a first standardized form with a standardized syntax and the second schema into a second standardized form with the standardized syntax. The system then outputs the first and second…
MEASURING MEMBER VALUE IN SOCIAL NETWORKS
Granted: March 1, 2018
Application Number:
20180060434
The disclosed embodiments provide a system for processing data. During operation, the system obtains a count of actions associated with a member of a social network, wherein the count comprises a set of action types and a number of actions associated with the member for each of the action types. Next, the system uses the count to calculate a set of scores for measuring the value of the social network to the member, wherein the set of scores is associated with researching and contacting…
DATA-DEPENDENCY-DRIVEN FLOW EXECUTION
Granted: March 1, 2018
Application Number:
20180060407
The disclosed embodiments provide a system for managing execution of a data flow. During operation, the system obtains a data dependency description for a data flow, wherein the data dependency description includes data sources to be consumed by the data flow, data targets to be produced by the data flow, and one or more data ranges associated with the data sources and the data targets. Next, the system uses the data dependency description to determine an availability of the data sources…
