![]() |
Code Examples
A repository of 155 code examples for BeepBeep
|
| Cfunctions.AddNumbers | Add two numbers with the Addition function |
| Cbasic.Average | Compute the cumulative average of a list of numbers |
| Cepisodes.AverageEpisodes | Computes the list of average values of each episode, grouped by day |
| Cbasic.AverageFork | Compute the cumulative average of a list of numbers |
| Cwidgets.AverageSlider | Display a real-time plot of the values of a slider in a Swing frame |
| Cmining.trenddistance.AverageValueAbsolute | Trend distance based on the average of values in a stream |
| Cmining.trenddistance.AverageValueRelative | Trend distance based on the average of values in a stream |
| Cutil.BagsContains | Usage of the Bags.contains function |
| Cutil.BagsFunctions | Illustrate the use of a few functions from the Bags class |
| Cnetwork.httppush.twinprimes.BigIntegerFunctions | Contains a few utility functions for manipulating Java's BigInteger objects |
| Cbasic.BinaryPush | Push events into a processor of input arity 2 |
| Cnetwork.CompoundObject | A dummy object used to show serialization |
| Cfunctions.ConstantUsage | Basic usage of the ca.uqac.lif.cep.functions.Constant function |
| Cbasic.ContextExample | Use a processor's Context object |
| Cxml.ContextExample | Evaluate JPath expressions on JSON elements |
| Cbasic.CountDecimateLast | Behaviour of the CountDecimate processor on the last event of a stream |
| Cbasic.CountDecimateSimple | Use the CountDecimate processor to discard events from a stream |
| Ctuples.CsvReaderExample | Read tuples from a CSV file using the TupleFeeder processor |
| Cfunctions.CumulateAnd | Use a cumulative processor to perform the conjunction of a stream of Boolean values |
| Cplots.CumulativeScatterplot | Update a 2D scatterplot in realtime from two streams of numbers |
| Cbasic.CumulativeSum | Use a cumulative processor to compute the sum of all events received so far |
| Cbasic.DecimationSum | Compute the sum of every pair of successive events |
| Cnialm.DetectAppliance | |
| Crobot.DetectSkidding | Detects situations where a moving robot loses traction and starts skidding |
| Cbasic.DuplicateContext | Duplicating processors and observing what happens to their Context object |
| Cbasic.DuplicateGroup | Duplicating processors without preserving their state |
| Cbasic.DuplicateNoState | Duplicating processors without preserving their state |
| Cbasic.DuplicateState | Duplicating processors and preserving their state |
| Cbasic.DuplicateStateQueues | Duplicating processors without preserving their state |
| Cartimon.Engine | Compute data about the execution of a hybrid car engine |
| Cmining.learning.EngineOverheatSimple | Train a classifier to predict the overheating of an engine |
| Cltl.EventuallySimple | Basic usage of LTL's Eventually processor |
| Cfinitestatemachines.ExtendedMooreMachine | Create an extended state machine with state variables |
| Csignal.FakeSignal | |
| Ccomplex.FileDemo | Creates complex events out of low-level events occurring to files |
| Cbasic.FileReader | Read an input stream from a text file line by line and show the output |
| Cbasic.FilterConditionComposite | Filter a trace by evaluating a compound condition on the events of that trace |
| Cbasic.FilterConditionSimple | Filter a trace by evaluating a simple condition on the events of that trace |
| Cbasic.FilterSimple | Discard events from an input trace with the Filter processor |
| Cfunctions.FixedInterval | Creates a compound function (a FunctionTree) that checks if a number lies between two fixed bounds |
| Cfol.ForAllFunctionSimple | |
| Cbasic.ForkMutable | See the effect of sending a mutable object into a Fork processor |
| Cbasic.ForkPull | Use the Fork processor to replicate input events in multiple output streams |
| Cbasic.ForkPush | Use the Fork processor to replicate input events in multiple output streams |
| Cqbf.Formula1 | Solves the QBF problem for the formula:
The pipeline to solve this problem is the following: |
| Cfunctions.FunctionBinary | Apply a binary function on an input stream using the ApplyFunction processor |
| Cfunctions.FunctionChain | Pipe multiple ApplyFunction processors to perform a more complex computation over a stream |
| Cfunctions.FunctionTreeUsage | Use a FunctionTree to create a complex function |
| Cfunctions.FunctionUsage | Show the basic usage of Function objects |
| Csignal.GenerateSignalGrouped | |
| Cwidgets.GetValueSlider | Get the value of a Swing widget and use it as a source of events |
| Cltl.GloballySimple | Basic usage of LTL's Globally processor |
| Cbasic.GroupBinary | Encapsulate a chain of processors into a Group, with an output arity of 2 |
| Cbasic.GroupSimple | Encapsulate a chain of processors into a Group |
| Ctweets.Hashtags | |
| Cbasic.HelloWorld | Basic example for testing the setup |
| Cbasic.IncorrectPiping | Pipe processors with non-matching event types |
| Cfunctions.Interval | Creates a compound function (a FunctionTree) that checks if a number lies between two other numbers |
| Ccomplex.IteratorDemo | Creates complex events out of low-level events occurring to Java iterators |
| Cjson.JPathExample | Evaluate JPath expressions on JSON elements |
| Cbasic.KeepLastPull | Use the KeepLast processor to keep the last event of an input stream |
| Cbasic.KeepLastPush | Push events to the KeepLast processor |
| Cmining.extraction.KmeansSymbolDistribution | Create clusters over the distribution of symbols in a set of input streams |
| Cstockticker.LandmarkQuery | |
| Csignal.LimitExample | |
| Cio.LineReaderExample | Read lines from a text file and convert them into numbers |
| Cwidgets.ListenerSourceExample | Wrap a Swing widget into a BeepBeep event Source |
| Cutil.MapPutInto | Use the PutInto processor to update a map from two input streams |
| Cepisodes.MaxEpisode | Computes the maximum value of all episodes in each day |
| Cmining.extraction.MaxMiningFunction | Create a mining function that computes the maximum value of all sequences |
| Cmining.extraction.MaxMiningFunctionProcessor | Create a mining function from BeepBeep processors |
| Cmining.trenddistance.MaxSymbols | Trend distance based on the maximum number of distinct symbols in a stream |
| Cdiagnose.MeasureThroughput | Measure the number of events per second at some point in a processor chain |
| Cmisc.temperature.Monitoring | |
| Cmisc.temperature.MonitoringEvent | Parent class of all the input events in this example |
| Cauction.MonotonicBid | Checks that all bids in an auction system are monotonic, i.e |
| Cplots.MouseHeatmap | Displays the trail of the mouse pointer inside a heat map |
| Ccustomprocessors.MyMaxExample | |
| Cltl.Nested | Basic usage of LTL's Until processor |
| Cfol.NestedQuantifiers | |
| Cltl.NextSimple | Basic usage of LTL's Next processor |
| Cltl.OpenClose | Using an LTL expression to filter events in an input stream |
| Cnetwork.httppush.PackerExample | Use a packer to send events in batch and reduce the number of HTTP requests |
| Cutil.PackExample | Use the Pack processor to accumulate events into a list |
| Cutil.PackUnpack | See the effect of chaining a Pack processor to an Unpack processor |
| Cdsl.ParserExample | Use the Bullwinkle parser to parse simple arithmetic expressions |
| Cxml.Parsing | Parse XML strings |
| Cjson.Parsing | Parse JSON strings |
| Cbasic.PartialEvaluation | |
| Cmining.PatternMiningFunctionProcessor | Create a mining function from BeepBeep processors |
| Csignal.PeakExample | |
| Csignal.PersistExample | |
| Cbasic.PipingBinary | Pipe processors together using the Connector object |
| Cbasic.PipingBinaryWait | Pipe processors together using the Connector object |
| Cbasic.PipingUnary | Pipe processors together using the Connector object |
| Cbasic.PipingUnaryIncorrect | Pipe processors together using the Connector object |
| Cbasic.PipingUnaryMissing | Instantiates two processors, but forgets to connect them |
| Cbasic.PipingUnaryPush | Pipe processors together using the Connector object |
| Cfunctions.PlaceholderUsage | Use the ArgumentPlaceholder function to refer to the i-th argument of a function |
| Csignal.PlateauExample | |
| Cvoyager.PlotSpeed | Detect planetary encounters of Voyager 2 by analyzing its distance from the Earth |
| Ccustomprocessors.Point | |
| Cbasic.PointDistance | Calculate the Euclidean distance of each two successive points in an input trace of (x,y) coordinates |
| Cepisodes.PressureEvent | Abstract class representing events in a pressure stream |
| Cio.PrintStdout | Print events to the standard input |
| Cbasic.ProcessorId | Example showing how to access the unique ID of a processor |
| Cbasic.ProcessorIdGroup | Example showing how the IDs of processors behave when multiple instances are created |
| Cbasic.PullHard | Illustration of the difference between using pull() and pullSoft() on a Pullable object |
| Cbasic.PullSoft | Illustration of the difference between using pull() and pullSoft() on a Pullable object |
| Cbasic.PullWithoutSource | What happens when trying to pull events on a processor connected to no input |
| Cnetwork.httppush.PushLocalSerialize | In this example, Machine A and Machine B are actually the same host; they just listen to different TCP ports on the same computer |
| Cnetwork.httppush.PushLocalSimple | In this example, Machine A and Machine B are actually the same host; they just listen to different TCP ports on the same computer |
| Cnetwork.httppush.PushMachineA | This is the same example as PushLocalSerialize, but with the "Machine A" and "Machine B" parts of the chain split into two independent programs, with some user interaction added |
| Cnetwork.httppush.PushMachineB | This is the same example as PushLocalSerialize, but with the "Machine A" and "Machine B" parts of the chain split into two independent programs, with some user interaction added |
| Cbasic.PushWithoutSink | What happens when trying to push events on a processor connected to no output |
| Cutil.PutIntoExample | |
| Cbasic.QueueSinkUsage | Push events into a QueueSink processor |
| Cbasic.QueueSourceUsage | Pull events from the QueueSource processor |
| Cvoyager.RadialAcceleration | Detect planetary encounters of Voyager 2 by analyzing its distance from the Earth |
| Cio.ReadHttp | Read bytes from a remote source using HTTP |
| Cio.ReadStdin | Read bytes from the standard input ( |
| Cio.ReadTokens | Read complete comma-separated tokens from the standard input |
| Ctweets.Relationships | |
| Cbasic.ResetWindow | Usage of a processor's reset() method |
| Crobot.RobotEvent | Event representing the status of a fictional robot that moves in a two-dimensional space |
| Cutil.RunOnExample | Apply a processor on collections of events using the RunOn processor |
| Cmining.SequenceReader | Utility class that creates a set of sequences from a file |
| Cwidgets.SetValueSlider | Set the value of a widget using a stream of events |
| Cbasic.SimpleFunction | Use the FunctionProcessor to apply a function to each input event |
| Cfinitestatemachines.SimpleMooreMachine | Check the proper ordering of next/hasNext strings |
| Cfinitestatemachines.SimpleMooreMachineCompact | Similar to SimpleMooreMachine, but with a bit of code written to avoid repetitions |
| Cpingus.SkillChart | |
| Cbasic.SlicerCollapse | Apply an aggregation function on the output of a slicer |
| Cbasic.SlicerOddEven | Use the SlicerMap to compute the sum of odd and even numbers separately |
| Cbasic.SlicerSimple | Use the SlicerMap to perform a computation on multiple subsets of an input stream |
| Cstockticker.SnapshotQuery | |
| Cjdbc.SourceExample | |
| Ccustomprocessors.StatefulDuplication | |
| Chl7.StdevExample | |
| Ctuples.SumAttributes | Compute the sum of two tuple attributes using the GetAttribute function |
| Ctuples.SumAttributesTree | Compute the sum of two tuple attributes using the GetAttribute function |
| Cbasic.SumTwo | Use the Trim and Fork processors to compute the sum of two successive events |
| Cmining.trenddistance.SymbolDistribution | Trend distance based on the statistical distribution of symbols in a stream |
| Cmining.trenddistance.SymbolDistributionClusters | Trend distance based on the statistical distribution of symbols in a stream |
| Cmisc.Temperature | |
| Cmisc.temperature.TemperatureAlert | A temperature alert message |
| Cmisc.temperature.TemperatureWarning | A temperature warning message |
| Csignal.ThresholdExample | |
| Cutil.ToListExample | Create a stream of lists from the input of multiple processors, using the ToList function |
| Cbasic.TrimPull | Use the Trim processor to discard events from the beginning of a stream |
| Cbasic.TrimPush | Use the Trim processor to discard events from the beginning of a stream |
| Cnetwork.httppush.twinprimes.TwinPrimesA | The code for Machine A in the twin prime example |
| Cnetwork.httppush.twinprimes.TwinPrimesB | The code for Machine B in the twin prime example |
| Cutil.UnpackExample | Use the Unpack processor to feed events from a stream of lists |
| Cutil.UnpackPush | See the effect of using the Unpack processor in push mode |
| Cltl.UntilSimple | Basic usage of LTL's Until processor |
| Cplots.UpdateTableStreamExample | Update a table from two streams of numbers |
| Cchess.WhiteVsBlack | Process a database of chess games to calculate the number of white wins vs |
| Cbasic.WindowAverage | Compute the cumulative average of a list of numbers over a sliding window |
| Cbasic.WindowEven | Use a Window processor to perform a computation over a sliding window of events that are not numeric |
| Cstockticker.WindowQuery | |
| Cplots.WindowScatterplot | Update a windowed 2D scatterplot in realtime from two streams of numbers |
| Cbasic.WindowSimple | Use a Window processor to perform a computation over a sliding window of events |
| Cbasic.WithoutPump | Print events from a queue source without the use of a pump |
| Cbasic.WithPump | Print events from a queue source with the use of a Pump processor |
| Cbasic.WithTank | |
| Cxml.XPathExample | Evaluate JPath expressions on JSON elements |
| ►CBinaryFunction | |
| ►CFunction | |
| ►CFunctionTree | |
| ►CGrammarObjectBuilder | |
| ►CGroupProcessor | |
| ►CGroupProcessorBuilder | |
| ►CMooreMachine | |
| ►CPassthroughFunction | |
| ►CSink | |
| ►CSource | |
| ►CSynchronousProcessor | |
| ►CUnaryFunction | |
| ►CUniformProcessor |