摘要:
Implementations of the present disclosure include methods for managing data quality for event data. In some implementations, methods include receiving, at one or more computing devices, a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity, processing, using the one or more computing devices, the plurality of events using one or more complex event processing (CEP) rules to generate a complex event, in response to generating the complex event, annotating the complex event with quality information corresponding to each of the plurality of events to provide a quality-enriched event, and publishing the quality-enriched event.
摘要:
Data is received that includes a multi-dimensional data set having data at different hierarchy levels. Using the received data, a first view of a chart having a branch corresponding to each dimension within the data set is rendered in a graphical user interface. Each branch extends outwardly from a center point and has graphical indicators corresponding to each corresponding hierarchy level. The hierarchy levels are arranged in order such that a highest hierarchy level is closest to the center point and a lowest hierarchy level is closest to or at a termination point of the corresponding branch. Related apparatus, systems, techniques and articles are also described.
摘要:
Implementations of the present disclosure include methods for managing data quality for event data. In some implementations, methods include receiving, at one or more computing devices, a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity, processing, using the one or more computing devices, the plurality of events using one or more complex event processing (CEP) rules to generate a complex event, in response to generating the complex event, annotating the complex event with quality information corresponding to each of the plurality of events to provide a quality-enriched event, and publishing the quality-enriched event.
摘要:
Implementations of the present disclosure include methods for providing transparency in streaming event data. In some implementations, methods include receiving a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity, processing the plurality of events using one or more complex event processing (CEP) rules to generate a complex event, in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event, and storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium.
摘要:
Examples of energy forecasting in hierarchical energy systems are provided herein. A global forecast model instance for a hierarchical energy system can be determined through aggregation of energy forecast model data from individual energy smart meters. Energy forecast model data can include values for energy forecast model parameters used by the individual smart meters. The energy smart meters include measurement, forecasting, and calculation capabilities. The smart meters locally determine a forecast model instance used by the smart meter and provide corresponding information to higher levels in the energy system hierarchy. A global forecast model instance is determined based on the provided information.
摘要:
Implementations of the present disclosure include methods for providing transparency in streaming event data. In some implementations, methods include receiving a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity, processing the plurality of events using one or more complex event processing (CEP) rules to generate a complex event, in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event, and storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium.
摘要:
Methods, systems, and computer-readable storage media for recommending a storage layout for the hybrid-store database with actions including receiving one or more data characteristics associated with data that is to be stored in the hybrid-store database, receiving one or more query characteristics associated with one or more queries that are expected to be applied to the hybrid-store database, processing the one or more data characteristics and the one or more query characteristics using a cost model to generate a plurality of costs, each cost being associated with a respective storage layout, identifying, based on the plurality of costs, a recommended storage layout, and providing the recommended storage layout for application to the hybrid-store database.
摘要:
Implementations of the present disclosure include methods, systems, and computer-readable storage mediums for receiving a probability distribution function model, the probability distribution function model representing an uncertain time series and providing a plurality of probability distribution functions, each probability distribution function corresponding to respective values at a respective time in the uncertain time series, generating a visualization based on the probability distribution function model to create a transparency gradient, the transparency gradient including a plurality of points graphically representing the plurality of probability distribution functions, and displaying the visualization including the transparency gradient, wherein a visual characteristic of each point of the plurality of points of the transparency gradient is a function of a probability of the respective value associated with the respective point.
摘要:
Examples of dynamic online energy forecasting are provided herein. An energy forecast request is received. An initial energy forecast is calculated in response to the request. One or more of a plurality of energy forecast model instances are selected as candidate forecast model instances. At least one of the candidate instances are transformed into an improved forecast model instance having greater accuracy than the candidate forecast model instance. The transformation is accomplished by determining alternative values for at least some parameters of an energy forecast model of the candidate forecast model instance. An improved energy forecast having a greater accuracy than the initial forecast can then be calculated using the improved forecast model instance.
摘要:
Examples of energy forecasting in hierarchical energy systems are provided herein. A global forecast model instance for a hierarchical energy system can be determined through aggregation of energy forecast model data from individual energy smart meters. Energy forecast model data can include values for energy forecast model parameters used by the individual smart meters. The energy smart meters include measurement, forecasting, and calculation capabilities. The smart meters locally determine a forecast model instance used by the smart meter and provide corresponding information to higher levels in the energy system hierarchy. A global forecast model instance is determined based on the provided information.