![]() |
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 |