Abstract: A continuous query identified by an archived relation of an application may be received. A physical query plan may be generated for the continuous query and/or a child operator plan may be identified. A buffer operator may be inserted between the child operator and its parent operator and/or the event information from the child operator may be stored in the buffer operator. A query operator may be identified in the physical query plan. It may be determined that the query operator identified in the physical query plan is a same type as a second query operator in a second continuous query concurrently executing. Further, a combined query plan may be generated based at least in part on the query operator identified in the physical query plan being the same type as the second query operator in the second continuous query.

Abstract: Some embodiments optimize a local, pending transaction queue of transactions locally executed by a client application to be synchronized with a server. Multiple transactions, which may be executed by the client application for a same local object, need to be synchronized with a server. The transactions, in queue for synchronization with the server, may include transactions to add, delete, or modify objects. Each set of transactions for a particular object in queue for synchronization with the server corresponds to a particular net effect on the server if synchronized individually to the server. The client application may replace the set of transactions for the particular object with a reduced set of transactions corresponding to the net effect, or entirely removed without replacement if there is no net effect of the set of transactions on the server.

Abstract: In implementations, a schema generation utility is configured to allow a user to abstract and generate a schema, such as a JSON schema, from a base schema instance according to schema configuration data, other data inputs, and schema configuration models. In an implementation, a user provides parameters, configuration objects, etc. for a desired final output schema. The schema generation utility may be configured to receive and parse the base schema instance into a plurality of configurable data objects, also referred to as “schema chunks,” that are extracted from the base schema instance. A set of schema chunks may be assembled into a desired output schema based on, at least in part, configuration data and assembly data contained in the schema chunks. In other implementations, input parameters may include error tolerance thresholds processed by the schema generator to discern between errors that lead to schema failure and benign errors.

Abstract: Techniques are provided for cross-region replication of block volume data. The techniques include a method wherein a computer system implements operations including creating a first snapshot of a block volume at a first geographic region and at a first logical time, the block volume including a plurality of partitions, transmitting first snapshot data to an object storage system at a second geographic region, creating a second snapshot of the block volume at the first geographic region and at a second logical time, generating a plurality of deltas, transmitting a plurality of delta data sets corresponding to the plurality of deltas to the object storage system at the second geographic region, generating a checkpoint at least in part by aggregating object metadata associated with the plurality of deltas and the first snapshot, receiving a restore request to generate a restore volume, and generating the restore volume from the checkpoint.

Abstract: Techniques are disclosed for efficient utilization worker threads in a workflow-as-a-service (WFaaS) environment. A client device may request a workflow for execution by the client device. The client device may receive the requested workflow and initialize a set of worker threads to execute the workflow and a set of heartbeater threads to monitor the set of worker threads. Upon receiving an indication of a processing delay, the client device may capture the state of the workflow, suspend execution of the workflow, and store the workflow in a temporary queue. While the processing delay persists, the client device may use the set of worker threads to execute other tasks. When the processing delay terminates, the client device may resume execution of the workflow.

Abstract: A method creates a data grid component in a GUI. The data grid includes data cells, header cells, corner cells, and may further include footer cells. The data grid component may have headers or footers that contain a scale and/or a ruler that relates to graphs shown in a row or column associated with the header or footer. The scale and/or ruler may be horizontal or vertical. The GUI component may allow for multilevel navigation. One level allows for navigating from component to component in the GUI, including the data grid and any other components. Another level allows for navigating within a component, including in the data grid. Available user navigation inputs include level change commands, for example tied to specific keys.

Abstract: Systems, devices, and methods discussed herein are directed to intelligently adjusting the set of worker nodes within a computing cluster. By way of example, a computing device (or service) may monitor performance metrics of a set of worker nodes of a computing cluster. When a performance metric is detected that is below a performance threshold, the computing device may perform a first adjustment (e.g., an increase or decrease) to the number of nodes in the cluster. Training data may be obtained based at least in part on the first adjustment and utilized with supervised learning techniques to train a machine-learning model to predict future performance changes in the cluster. Subsequent performance metrics and/or cluster metadata may be provided to the machine-learning model to obtain output indicating a predicted performance change. An additional adjustment to the number of worker nodes may be performed based at least in part on the output.

Abstract: Systems and methods for improving question-answering recall for complex, multi-sentence, convergent questions. More specifically, an autonomous agent accesses an initial answer that partly answers a question received from a user device. The agent represents the question and the initial answer as discourse trees. From the discourse trees, the agent identifies entities in the question that are not addressed by the answer. The agent forms an additional discourse tree from an additional resource such as a corpus of text. The additional discourse tree rhetorically connects a non-addressed entity with the answer. The agent designates this discourse tree as an imaginary discourse tree. When combined with the initial answer discourse tree, the imaginary discourse tree is used to generate an improved answer relative to existing solutions.

Abstract: Techniques for managing database workloads using similarity measures based on queries executed are described. Classical techniques from information retrieval are applied to the domain of database workload management. Specifically, the technique of using document term vectors to compute similarity measures are applied using the conceptual mapping of SQL workloads as “documents” composed of SQL queries as “terms.” The techniques include generating two or more sets of workloads with each workload representing a set of queries executed on at least one database. Based on the sets of workloads, workload term vectors are calculated that represent the set of queries executed on the database. Then, based on the calculated workload vectors, a similarity score is generated between the two or more sets of workloads.

Abstract: A method for HTTP stream tuning during load and overload control includes, at a first NF, determining a load/overload level of the first. The method further includes determining an initial value for an HTTP SETTINGS_MAX_CONCURRENT_STREAMS parameter. The method further includes publishing the initial value of the HTTP SETTINGS_MAX_CONCURRENT_STREAMS parameter to a second NF that sends traffic to the first NF. The method further includes determining that the load/overload level of the first NF has changed. The method further includes, in response to determining that the load/overload level has changed, adjusting the value of the HTTP SETTINGS_MAX_CONCURRENT_STREAMS parameter based on the load/overload level and a direction of change in the load/overload level. The method further includes publishing the adjusted value of the HTTP SETTINGS_MAX_CONCURRENT_STREAMS parameter to the second NF.

Abstract: In accordance with various embodiments, described herein are systems and methods for enabling backup and recovery of cloud services (services) in a cloud computing environment (cloud environment). The techniques described herein can be used, for example, to facilitate restoration of a service that may have been originally provisioned as part of a user system/environment, within the cloud environment, and was subsequently lost due to accident deletion of the service, or cloud account termination. A service archive, created during a backup process, includes an archive file that contains the artifacts that were installed and/or created when the service was provisioned; and a metadata file that contains the current state information for the service when the backup was performed. During a recovery process, a lost service can be provisioned within the user system/environment, using the contents of the service archive, irrespective of whether the service itself still exists within the user system/environment.

Abstract: Techniques are disclosed for efficient utilization worker threads in a workflow-as-a-service (WFaaS) environment. A client device may request a workflow for execution by the client device. The client device may receive the requested workflow and initialize a set of worker threads to execute the workflow and a set of heartbeater threads to monitor the set of worker threads. Upon receiving an indication of a processing delay, the client device may capture the state of the workflow, suspend execution of the workflow, and store the workflow in a temporary queue. While the processing delay persists, the client device may use the set of worker threads to execute other tasks. When the processing delay terminates, the client device may resume execution of the workflow.

Abstract: Techniques related to a server-side extension of client-side caches are provided. A storage server computer receives, from a database server computer, an eviction notification indicating that a data block has been evicted from the database server computer's cache. The storage server computer comprises a memory hierarchy including a volatile cache and a persistent cache. Upon receiving the eviction notification, the storage server computer retrieves the data block from the persistent cache and stores it in the volatile cache. When the storage server computer receives, from the database server computer, a request for the data block, the storage server computer retrieves the data block from the volatile cache. Furthermore, the storage server computer sends the data block to the database server computer, thereby causing the data block to be stored in the database server computer's cache. Still further, the storage server computer evicts the data block from the volatile cache.

Abstract: Techniques for making eventual consistency cache updates deterministic. One technique includes receiving, at a control plane, a request to execute an operation on data, executing the operation on the data, creating a replication event for the operation and a replication identifier associated with the replication event, sending a response that includes a custom header having the replication identifier, receiving, at a data plane, a subsequent request to execute an operation involving the data, the subsequent request includes the replication identifier, retrieving a replication identifier for a latest replication event executed on the data plane, comparing the replication identifier from the subsequent request and the replication identifier for the latest replication event, determining the replication event associated with the replication identifier from the subsequent request has not been executed on the data plane based on the comparison, and sending a deterministic error message to the client device.

Abstract: Embodiments provide techniques for estimating seasonal indices for multiple periods. Some embodiments can receive a signal comprising a plurality of measures sampled over a span of time from an environment in which one or more processes are being executed. Some embodiments may then extract a seasonal effector and a de-seasonalized component from the signal. Next, some embodiments can apply one or more spline functions to the seasonal effector to generate a first model. Some embodiments may then apply a linear regression technique to the de-seasonalized component to generate a second model. Some embodiments may then initiate actions associated with the code. Some embodiments may then generate a forecast of the signal based on the first model and the second model. Next, some embodiments may initiate, based at least in part on the forecast, one or more actions associated with the environment.

Abstract: Provided herein are workload management techniques that asynchronously configure pluggable databases within a compute cloud. In an embodiment, the compute cloud receives an administrative request that indicates configuration details for a pluggable database. The compute cloud generates a configuration descriptor that specifies an asynchronous job based on the configuration details of the request. The compute cloud accesses hosting metadata to detect at least one of: a) a current container database that already hosts the pluggable database, b) a target container database that will host the pluggable database, or c) a particular computer that hosts at least one of: the current container database, or the target container database. The compute cloud executes the asynchronous job to configure the pluggable database based on at least one of: the hosting metadata, or the configuration descriptor.

Abstract: Techniques for persisting user data across secure shell instances are provided. The techniques include a method wherein a computer system receives a request to reserve a block volume, the request being received from a session manager service. The method also includes reserving the block volume, identifying a data center identifier of the block volume, returning the data center identifier of the block volume to the session manager service, attaching the block volume to a volume management fleet machine, receiving an instruction from the session manager service to release the block volume, creating a backup of the block volume comprising the data stored in the block volume, and releasing the block volume.

Abstract: Systems, methods, and machine-readable media to migrate data from source databases to target databases are disclosed. Data may be received, relating to the source databases and the target databases. For each source database, a migration assessment may be generated based on analyzing the data, and a migration method may be selected. A migration plan that specifies a parallel migration of a set of databases to the target databases may be created, with a first migration method to migrate a first subset of the set of databases and a second migration method to migrate a second subset of the set of databases. The parallel migration may be executed according to the migration plan may be caused so that the first subset of the set of databases is migrated with the first migration method while the second subset of the set of databases is migrated with the second migration method.

Abstract: A double-blind comparison is performed between prognostic-surveillance systems, which are located on a local system and a remote system. During operation, the local system inserts random faults into a dataset to produce a locally seeded dataset, wherein the random faults are inserted into random signals at random times with variable fault signatures. Next, the local system exchanges the locally seeded dataset with a remote system, and in return receives a remotely seeded dataset, which was produced by the remote system by inserting different random faults into the same dataset. Next, the local system uses a local prognostic-surveillance system to analyze the remotely seeded dataset to produce locally detected faults. Finally, the local system determines a performance of the local prognostic-surveillance system by comparing the locally detected faults against actual faults in the remotely seeded fault information. The remote system similarly determines a performance of a remote prognostic-surveillance system.

Abstract: An autonomous agent receives a user query comprising the complex question. The agent can obtain, from a corpus of unstructured texts, an answer candidate text corresponding to the user query and comprising text from which the answer is subsequently identified. The agent may generate first linguistic data corresponding to the user query and second linguistic data corresponding to the answer candidate text. Each instance of linguistic data may comprise a combination of respective syntactic data, semantic data, and discourse data generated from the user query and/or answer candidate text. Both instances of linguistic data may be provided to a machine-learning model that has been previously trained to output an answer identified from an instance of unstructured text (e.g., the answer candidate text). The model may output the answer identified from the answer candidate text, which in turn may be provided in response to the user query.

Abstract: The disclosed embodiments relate to a system that trains an inferential model based on selected training vectors. During operation, the system receives training data comprising observations for a set of time-series signals gathered from sensors in a monitored system during normal fault-free operation. Next, the system divides the observations into N subgroups comprising non-overlapping time windows of observations. The system then selects observations with a local minimum value and a local maximum value for all signals from each subgroup to be training vectors for the inferential model. Finally, the system trains the inferential model using the selected training vectors. Note that by selecting observations with local minimum and maximum values to be training vectors, the system maximizes an operational range for the training vectors, which reduces clipping in estimates subsequently produced by the inferential model and thereby reduces false alarms.

Abstract: During operation, the system uses N sensors to sample an electromagnetic interference (EMI) signal emitted by a target asset while the target asset is running a periodic workload, wherein each of the N sensors has a sensor sampling frequency f, and wherein the N sensors perform sampling operations in a round-robin ordering with phase offsets between successive samples. During the sampling operations, the system performs phase adjustments among the N sensors to maximize phase offsets between successive sensors in the round-robin ordering. Next, the system combines samples obtained through the N sensors to produce a target EMI signal having an EMI signal sampling frequency F=f×N. The system then generates a target EMI fingerprint from the target EMI signal. Finally, the system compares the target EMI fingerprint against a reference EMI fingerprint for the target asset to determine whether the target asset contains any unwanted electronic components.

Abstract: Techniques for generating and using reader-friendly policy statements are disclosed. In one or more embodiments, a policy management service receives a request for an authorization policy in a language-localized syntax. The policy management service identifies a syntax graph corresponding to the authorization policy and traverses the syntax graph to obtain at least a requestor variable value associated with the authorization policy, an action variable value associated with the authorization policy, a resource variable value associated with the authorization policy, and a location variable value associated with the authorization policy. The policy authorization service generates a reader-friendly policy statement in the language-localized syntax using the requestor variable value, the action variable value, the resource variable value, and the location variable value. Responsive to the request, the policy authorization service provides the reader-friendly policy statement.

Abstract: Disclosed is an approach for allowing an entity to perform semantic analysis in a SaaS semantic analysis platform upon private data possessed by one or more entities. In one or more embodiments, separate processing pipelines may be provided to the plurality of entities thereby keeping private data secure within the semantic analysis platform. In one or more embodiments, a common processing pipeline is provide with data associated a first entity being assigned a first identification code, and data associated with a second entity being assigned a second identification code.

Abstract: A server can receive a request to subscribe to a data tenancy in an extended region. The server can determine a size of stored data records associated with the data tenancy in a home region to be replicated in the extended region. Based in part on the size of the stored data records, the server can open a new communication channel dedicated to replicating the stored data records from the first server in the home region to the second server in the extended region. The server can pull the stored data records from the first server in the home region, store the pulled data records on the second sever in the extended region. The server can receive updated data records over an established communication channel between the first server in the home region and the second server in the extended region and store the updated data records on the second server.

Abstract: The disclosed embodiments relate to a system that characterizes susceptibility of an inferential model to follow signal degradation. During operation, the system receives a set of time-series signals associated with sensors in a monitored system during normal fault-free operation. Next, the system trains the inferential model using the set of time-series signals. The system then characterizes susceptibility of the inferential model to follow signal degradation. During this process, the system adds degradation to a signal in the set of time-series signals to produce a degraded signal. Next, the system uses the inferential model to perform prognostic-surveillance operations on the set of time-series signals with the degraded signal. Finally, the system characterizes susceptibility of the inferential model to follow degradation in the signal based on results of the prognostic-surveillance operations.

Abstract: The present disclosure relates to systems and methods for providing cloud-based services securely to on-premises networks or other infrastructure. More particularly, the present disclosure relates to systems and methods for enriching first-party data (e.g., data collected directly by an on-premises server) stored within on-premises networks by enabling the on-premises networks to retrieve and process third-party data stored on cloud-based networks. As a technical benefit, cloud-based services can be performed on the first-party data within the on-premises networks.

Abstract: Garbage collection (GC) states are stored within references stored on a heap memory to track a progress of GC operations with respect to the references. GC state may be stored in a non-addressable portion of references. Based on the GC state of a particular reference, a set of GC operations are selected and performed for the reference. However, references stored on a call stack do not include any indication of GC state. Hence, loading a reference from heap to call stack involves removing the indication of GC state. Writing a reference to heap involves adding the indication of GC state. References embedded within a compiled method also do not indicate any GC state. Metadata of the compiled method indicate a GC state, which is implicated to the embedded references. GC operations are selected and performed for each embedded reference based on the GC state of the compiled method.

Abstract: Techniques for processing queries are provided. In one approach, an execution plan for a query includes multiple sub-plans, one or more of which are selected at runtime while one or more other sub-plans are not executed during execution of the execution plan. In another approach, data about misestimate is generated and stored persistently for subsequent queries. In another approach, statistics for a database object are generated automatically and efficiently while the database object is created or data items are added thereto. In another approach, a hybrid histogram is created that includes a feature of frequency histograms and a feature of height-balanced histograms. In another approach, computer jobs are executed in such a way to avoid deadlock. In another approach, changes to a database object trigger a hard parse of a query even though an execution plan already exists for the query.

Abstract: Improved techniques for dialogue management are disclosed. In particular, disclosed systems facilitate improved autonomous agents that can generate a virtual social dialogue from a corpus of text. A virtual social dialogue is a dialogue between autonomous agents and user devices. For example, a virtual social dialogue can include viewpoints, concerns, or questions of various actors on a particular topic. By presenting textual content in this manner, disclosed techniques improve information comprehension and increase the practicality of autonomous agents.

Abstract: The embodiments disclosed herein relate to predictive rate limiting. A workload for completing a request is predicted based on, for example, characteristics of a ruleset to be applied and characteristics of a target set upon which the ruleset is to be applied. The workload is mapped to a set of tokens or credits. If a requestor has sufficient tokens to cover the workload for the request, the request is processed. The request may be processed in accordance with a set of processing queues. Each processing queue is associated with a maximum per-tenant workload. A request may be added to a processing queue as long as adding the request does not result in exceeding the maximum per-tenant workload. Requests within a processing queue may be processed in a First In First Out (FIFO) order.

Abstract: Systems, methods, and other embodiments associated with incrementally swapping items in an assortment are described. In one embodiment, a computing system includes demand logic configured to read data from an electronic data structure that defines an assortment. The assortment defines a subset of items from a product category. The demand logic is configured to generate forecasted changes to an associated metric value by generating demand transference values for (i) individually removing each item presently in the assortment and (ii) individually adding each item of a set of available items of the product category. The computing system includes assortment logic configured to transform the electronic data structure that defines the assortment according to the forecasted changes by incrementally swapping items in the assortment for new items in the available set of items until the forecasted changes between items in the assortment and new items in the set of available items satisfy a predefined condition.

Abstract: Systems, methods, and other embodiments associated with distributed primary identifier management in a multi-master database system are described. One embodiment includes: Receiving a request to add a new master node to a multi-master database environment. Retrieving the next available master node number from a master node counter for the database environment. Generating a numeric base for primary identifiers of data objects of the new master node by deriving high order bits of the numeric base from the retrieved master node number. Configuring the new master node to assign the next unassigned number in a sequence of numbers beginning with the numeric base as the primary identifier for each data object created by the new master node. Add the new master node to the database environment. In one embodiment, the numeric base is generated by replacing the leading bits of the primary identifier range with the reversed the binary equivalent of the node number of the new master node.

Abstract: Embodiments operate a multi-tenant cloud system. At a first data center, embodiments authenticate a first client and store resources that correspond to the first client, the first data center in communication with a second data center that is configured to authenticate the first client. Embodiments divide the resources into base data and regular data, where the base data is a minimum data needed to allow the resources to be available to the first client at the second data center. Embodiments store the base data on a cloud storage in a base data export file and store the regular data on the cloud storage in a regular data export file. Embodiments export the base data export file to the second data center and when the exporting the base data export file has completed, exports the regular data export file to the second data center.

Abstract: A computer system including one or more processors and persistent, word-addressable memory implements a persistent atomic multi-word compare-and-swap operation. On entry, a list of persistent memory locations of words to be updated, respective expected current values contained the persistent memory locations and respective new values to write to the persistent memory locations are provided. The operation atomically performs the process of comparing the existing contents of the persistent memory locations to the respective current values and, should they match, updating the persistent memory locations with the new values and returning a successful status. Should any of the contents of the persistent memory locations not match a respective current value, the operation returns a failed status. The operation is performed such that the system can recover from any failure or interruption by restoring the list of persistent memory locations.

Abstract: Techniques for implementing an infrastructure orchestration service are described. In certain embodiments, a cloud infrastructure orchestration system (CIOS) is disclosed that generates customized flock configurations for services to be deployed to different regions supported by the CIOS. The CIOS receives generic configuration information describing a set of infrastructure assets associated with a service and identifies first portions of the generic configuration information for deploying the set of infrastructure assets associated with the service that are configurable. The CIOS receives region configuration information for configuring the generic configuration information and updates the generic configuration information based on the region configuration information. The CIOS then transmits the updated configuration information to set of regions managed by the CIOS.

Abstract: Embodiments operate a multi-tenant cloud system for a plurality of user accounts. Embodiments receive a create request from a client system to provision a new account for a user. Embodiments determine that the create request has failed and initiates a rollback of the create request. Embodiments determine that the rollback has failed and initiates a new rollback in response to a status request from the client system.

Abstract: Various embodiments provide for a method for creating a customized email that includes an action link generated based on form data. Form data is received from a displayed form. The form data includes an action to perform with respect to a task. The action link for performing the action is generated based on the form data. A string with string data that includes the form data and a layout of the form data is generated. The customized email is generated based on the string. The customized email includes the action link for performing the action with respect to the task. The customized email is transmitted to a client device. Information is received, from the client device, pertaining to a user interaction with respect to the action link in the customized email.

Abstract: Techniques for preventing concurrent execution of an infrastructure orchestration service are described. Worker nodes can receive instructions, or tasks, for deploying infrastructure resources and can provide heartbeat notifications to scheduler nodes, also considered a lease. A signing proxy can track the heartbeat notifications sent from the worker nodes to the scheduler node. The signing proxy can receive requests corresponding to a performance of the tasks assigned to the worker nodes. The signing proxy can determine whether the lease between each worker node and the scheduler is valid. If the lease is valid, the signing proxy may make a call to services on behalf of the worker node, and if the lease is not valid, the signing proxy may not make a call to services on behalf of the worker node. Instead, the signing proxy may cut off all outgoing network traffic, blocking access of the worker node to services.

Abstract: Embodiments relate to configuring artificial-intelligence (AI) decision nodes throughout a communication decision tree. The decision nodes can support successive iteration of AI models to dynamically define iteration data that corresponds to a trajectory through the tree.

Abstract: Disclosed herein are techniques related to automated generation of regular expressions. In some embodiments, a regular expression generator may receive input data comprising one or more character sequences. The regular expression generator may convert character sequences into a sets of regular expression codes and/or span data structures. The regular expression generator may identify a longest common subsequence shared by the sets of regular expression codes and/or spans, and may generate a regular expression based upon the longest common subsequence.

Abstract: A method for discovering and tracking addresses associated with 4G service endpoints includes receiving, from a requesting node, a first domain name system (DNS) resolution or monitoring request including a fully qualified domain name (FQDN) of a 5G service endpoint. The method further includes querying a DNS server using the FQDN from the first DNS resolution request. The method further includes receiving, from the DNS server, a first response including an address associated with the 4G service endpoint and storing the address associated with the 4G service endpoint in a database. The method further includes communicating the address associated with the 4G service endpoint to the requesting node. The method further includes monitoring the FQDN for changes in address associated with the FQDN. The method further includes notifying the requesting node of the changes in address associated with the FQDN.

Abstract: Techniques are described for identifying patterns of memory cells in a memory array that are predictive of non-correctable errors (“corruption patterns”). The techniques described herein identify patterns of cell errors that are likely to generate errors that cannot be corrected by an error correction code (ECC). The identification of non-correctable cells is accomplished by identifying a pattern of cell errors storing bit values that deviate from corresponding expected values. The pattern of these memory cells and various combinations of the cells in the pattern are compared to patterns of cells that are known to be correctable using ECC. If the error pattern or one or more of the combinations of erroneous cells in the pattern are not associated with patterns that are correctable via ECC, the error pattern is identified as predictive of a likely uncorrectable error.

Abstract: Techniques for persisting user data across secure shell instances are provided. The techniques include a method wherein a computer system receives a request to reserve a block volume, the request being received from a session manager service. The method also includes reserving the block volume, identifying a data center identifier of the block volume, returning the data center identifier of the block volume to the session manager service, attaching the block volume to a volume management fleet machine, receiving an instruction from the session manager service to release the block volume, creating a backup of the block volume comprising the data stored in the block volume, and releasing the block volume.

Abstract: A computer system may receive a layout of a data center, the layout of the data center identifying physical locations of a plurality of server racks, electrical distribution feeds, and uninterruptible power supplies. The computer system may receive a fault domain configuration for the datacenter, the fault domain configuration identifying virtual locations of a plurality of logical fault domains for distributing one or more instances so that the instances are stored on independent physical hardware devices within a single availability fault domain. The computer system may determine the configuration for the data center by assigning the plurality of fault domains to a plurality of electrical zones, wherein each electrical zone provides a redundant electrical power supply across the plurality of logical fault domains in an event of a failure of one or more electrical distribution feeds. The computer system may display the configuration for the data center on a display.

Abstract: Techniques are provided for unifying filter operators in exchange, transform, load (ETL) plans. Such a technique includes a method that may include receiving, by a computer system, an ETL plan including a split operator and a plurality of filter operators. The may include identifying, by the computer system, that the plurality of filter operators are configured to act on data output by the split operator in the ETL plan. The method may include generating, by the computer system, a unified filter operator using the plurality of filter operators. The method may include generating, by the computer system, an updated ETL plan comprising the unified filter operator providing filtered data to the split operator. The method may also include storing the updated ETL plan in a data store.

Abstract: The disclosed embodiments relate to a system that automatically selects a prognostic-surveillance technique to analyze a set of time-series signals. During operation, the system receives the set of time-series signals obtained from sensors in a monitored system. Next, the system determines whether the set of time-series signals is univariate or multivariate. When the set of time-series signals is multivariate, the system determines if there exist cross-correlations among signals in the set of time-series signals. If so, the system performs subsequent prognostic-surveillance operations by analyzing the cross-correlations. Otherwise, if the set of time-series signals is univariate, the system performs subsequent prognostic-surveillance operations by analyzing serial correlations for the univariate time-series signal.

Abstract: Described herein are systems and methods for managing reference counted lifecycles of contexts and dependency injection (CDI) components. The systems and methods described herein provide new constructs that allow for managing and monitoring CDI object lifecycles. Put together, these constructs permit specifications (e.g., JPA) to be fully implemented in a lightweight CDI ecosystem without reliance on typical application servers.

Abstract: Techniques for identity management, and more particularly, to techniques for performing universal identity management or governance over a wide variety of applications. In one aspect a computer-implement method is provided that includes receiving a request for a query of data or a CRUD operation on the data. The data is part of a target application hosted by an enterprise. The method further includes obtaining a schema of objects associated with the target application. The schema models a relationship between the objects, and the objects represent the data of the target application. The method further includes executing the query or CRUD operation on the objects based on the schema, executing the query or CRUD operation on the data based on the schema, and reporting results of the query or CRUD operation on the data.

Abstract: In order to provide effective diagnostics and logging of error messages produced during the execution of processes across multiple components, techniques are disclosed for the generating, managing, and processing centralized logs containing those error messages. In particular, the components may write error messages to a centralized log instead of writing the error messages to local log files. The various error messages in the centralized log can be read, identified, and organized. Furthermore, enrichments and/or analytics may be applied to the error messages based on information from a knowledge source or the application of one or more machine learning models. The organized error messages, enrichments, and analytics can be stored in an output log that can be easily retrieved and viewed through a graphical interface. The organized error messages, enrichments, and analytics work together to allow for more effective diagnosing of execution errors.