Code Examples
A repository of 155 code examples for BeepBeep
Class Hierarchy
This inheritance list is sorted roughly, but not completely, alphabetically:
[detail level 123]
 Cfunctions.AddNumbersAdd two numbers with the Addition function
 Cbasic.AverageCompute the cumulative average of a list of numbers
 Cepisodes.AverageEpisodesComputes the list of average values of each episode, grouped by day
 Cbasic.AverageForkCompute the cumulative average of a list of numbers
 Cwidgets.AverageSliderDisplay a real-time plot of the values of a slider in a Swing frame
 Cmining.trenddistance.AverageValueAbsoluteTrend distance based on the average of values in a stream
 Cmining.trenddistance.AverageValueRelativeTrend distance based on the average of values in a stream
 Cutil.BagsContainsUsage of the Bags.contains function
 Cutil.BagsFunctionsIllustrate the use of a few functions from the Bags class
 Cnetwork.httppush.twinprimes.BigIntegerFunctionsContains a few utility functions for manipulating Java's BigInteger objects
 Cbasic.BinaryPushPush events into a processor of input arity 2
 Cnetwork.CompoundObjectA dummy object used to show serialization
 Cfunctions.ConstantUsageBasic usage of the ca.uqac.lif.cep.functions.Constant function
 Cbasic.ContextExampleUse a processor's Context object
 Cxml.ContextExampleEvaluate JPath expressions on JSON elements
 Cbasic.CountDecimateLastBehaviour of the CountDecimate processor on the last event of a stream
 Cbasic.CountDecimateSimpleUse the CountDecimate processor to discard events from a stream
 Ctuples.CsvReaderExampleRead tuples from a CSV file using the TupleFeeder processor
 Cfunctions.CumulateAndUse a cumulative processor to perform the conjunction of a stream of Boolean values
 Cplots.CumulativeScatterplotUpdate a 2D scatterplot in realtime from two streams of numbers
 Cbasic.CumulativeSumUse a cumulative processor to compute the sum of all events received so far
 Cbasic.DecimationSumCompute the sum of every pair of successive events
 Cnialm.DetectAppliance
 Crobot.DetectSkiddingDetects situations where a moving robot loses traction and starts skidding
 Cbasic.DuplicateContextDuplicating processors and observing what happens to their Context object
 Cbasic.DuplicateGroupDuplicating processors without preserving their state
 Cbasic.DuplicateNoStateDuplicating processors without preserving their state
 Cbasic.DuplicateStateDuplicating processors and preserving their state
 Cbasic.DuplicateStateQueuesDuplicating processors without preserving their state
 Cartimon.EngineCompute data about the execution of a hybrid car engine
 Cmining.learning.EngineOverheatSimpleTrain a classifier to predict the overheating of an engine
 Cltl.EventuallySimpleBasic usage of LTL's Eventually processor
 Cfinitestatemachines.ExtendedMooreMachineCreate an extended state machine with state variables
 Csignal.FakeSignal
 Ccomplex.FileDemoCreates complex events out of low-level events occurring to files
 Cbasic.FileReaderRead an input stream from a text file line by line and show the output
 Cbasic.FilterConditionCompositeFilter a trace by evaluating a compound condition on the events of that trace
 Cbasic.FilterConditionSimpleFilter a trace by evaluating a simple condition on the events of that trace
 Cbasic.FilterSimpleDiscard events from an input trace with the Filter processor
 Cfunctions.FixedIntervalCreates a compound function (a FunctionTree) that checks if a number lies between two fixed bounds
 Cfol.ForAllFunctionSimple
 Cbasic.ForkMutableSee the effect of sending a mutable object into a Fork processor
 Cbasic.ForkPullUse the Fork processor to replicate input events in multiple output streams
 Cbasic.ForkPushUse the Fork processor to replicate input events in multiple output streams
 Cqbf.Formula1Solves the QBF problem for the formula:

∀x ∃y ∃z : (x ∨ y) ∧ (¬x ∨ c) ∧ (¬y ∨ ¬ z)

The pipeline to solve this problem is the following:

 Cfunctions.FunctionBinaryApply a binary function on an input stream using the ApplyFunction processor
 Cfunctions.FunctionChainPipe multiple ApplyFunction processors to perform a more complex computation over a stream
 Cfunctions.FunctionTreeUsageUse a FunctionTree to create a complex function
 Cfunctions.FunctionUsageShow the basic usage of Function objects
 Csignal.GenerateSignalGrouped
 Cwidgets.GetValueSliderGet the value of a Swing widget and use it as a source of events
 Cltl.GloballySimpleBasic usage of LTL's Globally processor
 Cbasic.GroupBinaryEncapsulate a chain of processors into a Group, with an output arity of 2
 Cbasic.GroupSimpleEncapsulate a chain of processors into a Group
 Ctweets.Hashtags
 Cbasic.HelloWorldBasic example for testing the setup
 Cbasic.IncorrectPipingPipe processors with non-matching event types
 Cfunctions.IntervalCreates a compound function (a FunctionTree) that checks if a number lies between two other numbers
 Ccomplex.IteratorDemoCreates complex events out of low-level events occurring to Java iterators
 Cjson.JPathExampleEvaluate JPath expressions on JSON elements
 Cbasic.KeepLastPullUse the KeepLast processor to keep the last event of an input stream
 Cbasic.KeepLastPushPush events to the KeepLast processor
 Cmining.extraction.KmeansSymbolDistributionCreate clusters over the distribution of symbols in a set of input streams
 Cstockticker.LandmarkQuery
 Csignal.LimitExample
 Cio.LineReaderExampleRead lines from a text file and convert them into numbers
 Cwidgets.ListenerSourceExampleWrap a Swing widget into a BeepBeep event Source
 Cutil.MapPutIntoUse the PutInto processor to update a map from two input streams
 Cepisodes.MaxEpisodeComputes the maximum value of all episodes in each day
 Cmining.extraction.MaxMiningFunctionCreate a mining function that computes the maximum value of all sequences
 Cmining.extraction.MaxMiningFunctionProcessorCreate a mining function from BeepBeep processors
 Cmining.trenddistance.MaxSymbolsTrend distance based on the maximum number of distinct symbols in a stream
 Cdiagnose.MeasureThroughputMeasure the number of events per second at some point in a processor chain
 Cmisc.temperature.Monitoring
 Cmisc.temperature.MonitoringEventParent class of all the input events in this example
 Cauction.MonotonicBidChecks that all bids in an auction system are monotonic, i.e
 Cplots.MouseHeatmapDisplays the trail of the mouse pointer inside a heat map
 Ccustomprocessors.MyMaxExample
 Cltl.NestedBasic usage of LTL's Until processor
 Cfol.NestedQuantifiers
 Cltl.NextSimpleBasic usage of LTL's Next processor
 Cltl.OpenCloseUsing an LTL expression to filter events in an input stream
 Cnetwork.httppush.PackerExampleUse a packer to send events in batch and reduce the number of HTTP requests
 Cutil.PackExampleUse the Pack processor to accumulate events into a list
 Cutil.PackUnpackSee the effect of chaining a Pack processor to an Unpack processor
 Cdsl.ParserExampleUse the Bullwinkle parser to parse simple arithmetic expressions
 Cxml.ParsingParse XML strings
 Cjson.ParsingParse JSON strings
 Cbasic.PartialEvaluation
 Cmining.PatternMiningFunctionProcessorCreate a mining function from BeepBeep processors
 Csignal.PeakExample
 Csignal.PersistExample
 Cbasic.PipingBinaryPipe processors together using the Connector object
 Cbasic.PipingBinaryWaitPipe processors together using the Connector object
 Cbasic.PipingUnaryPipe processors together using the Connector object
 Cbasic.PipingUnaryIncorrectPipe processors together using the Connector object
 Cbasic.PipingUnaryMissingInstantiates two processors, but forgets to connect them
 Cbasic.PipingUnaryPushPipe processors together using the Connector object
 Cfunctions.PlaceholderUsageUse the ArgumentPlaceholder function to refer to the i-th argument of a function
 Csignal.PlateauExample
 Cvoyager.PlotSpeedDetect planetary encounters of Voyager 2 by analyzing its distance from the Earth
 Ccustomprocessors.Point
 Cbasic.PointDistanceCalculate the Euclidean distance of each two successive points in an input trace of (x,y) coordinates
 Cepisodes.PressureEventAbstract class representing events in a pressure stream
 Cio.PrintStdoutPrint events to the standard input
 Cbasic.ProcessorIdExample showing how to access the unique ID of a processor
 Cbasic.ProcessorIdGroupExample showing how the IDs of processors behave when multiple instances are created
 Cbasic.PullHardIllustration of the difference between using pull() and pullSoft() on a Pullable object
 Cbasic.PullSoftIllustration of the difference between using pull() and pullSoft() on a Pullable object
 Cbasic.PullWithoutSourceWhat happens when trying to pull events on a processor connected to no input
 Cnetwork.httppush.PushLocalSerializeIn 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.PushLocalSimpleIn 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.PushMachineAThis 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.PushMachineBThis 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.PushWithoutSinkWhat happens when trying to push events on a processor connected to no output
 Cutil.PutIntoExample
 Cbasic.QueueSinkUsagePush events into a QueueSink processor
 Cbasic.QueueSourceUsagePull events from the QueueSource processor
 Cvoyager.RadialAccelerationDetect planetary encounters of Voyager 2 by analyzing its distance from the Earth
 Cio.ReadHttpRead bytes from a remote source using HTTP
 Cio.ReadStdinRead bytes from the standard input (
 Cio.ReadTokensRead complete comma-separated tokens from the standard input
 Ctweets.Relationships
 Cbasic.ResetWindowUsage of a processor's reset() method
 Crobot.RobotEventEvent representing the status of a fictional robot that moves in a two-dimensional space
 Cutil.RunOnExampleApply a processor on collections of events using the RunOn processor
 Cmining.SequenceReaderUtility class that creates a set of sequences from a file
 Cwidgets.SetValueSliderSet the value of a widget using a stream of events
 Cbasic.SimpleFunctionUse the FunctionProcessor to apply a function to each input event
 Cfinitestatemachines.SimpleMooreMachineCheck the proper ordering of next/hasNext strings
 Cfinitestatemachines.SimpleMooreMachineCompactSimilar to SimpleMooreMachine, but with a bit of code written to avoid repetitions
 Cpingus.SkillChart
 Cbasic.SlicerCollapseApply an aggregation function on the output of a slicer
 Cbasic.SlicerOddEvenUse the SlicerMap to compute the sum of odd and even numbers separately
 Cbasic.SlicerSimpleUse the SlicerMap to perform a computation on multiple subsets of an input stream
 Cstockticker.SnapshotQuery
 Cjdbc.SourceExample
 Ccustomprocessors.StatefulDuplication
 Chl7.StdevExample
 Ctuples.SumAttributesCompute the sum of two tuple attributes using the GetAttribute function
 Ctuples.SumAttributesTreeCompute the sum of two tuple attributes using the GetAttribute function
 Cbasic.SumTwoUse the Trim and Fork processors to compute the sum of two successive events
 Cmining.trenddistance.SymbolDistributionTrend distance based on the statistical distribution of symbols in a stream
 Cmining.trenddistance.SymbolDistributionClustersTrend distance based on the statistical distribution of symbols in a stream
 Cmisc.Temperature
 Cmisc.temperature.TemperatureAlertA temperature alert message
 Cmisc.temperature.TemperatureWarningA temperature warning message
 Csignal.ThresholdExample
 Cutil.ToListExampleCreate a stream of lists from the input of multiple processors, using the ToList function
 Cbasic.TrimPullUse the Trim processor to discard events from the beginning of a stream
 Cbasic.TrimPushUse the Trim processor to discard events from the beginning of a stream
 Cnetwork.httppush.twinprimes.TwinPrimesAThe code for Machine A in the twin prime example
 Cnetwork.httppush.twinprimes.TwinPrimesBThe code for Machine B in the twin prime example
 Cutil.UnpackExampleUse the Unpack processor to feed events from a stream of lists
 Cutil.UnpackPushSee the effect of using the Unpack processor in push mode
 Cltl.UntilSimpleBasic usage of LTL's Until processor
 Cplots.UpdateTableStreamExampleUpdate a table from two streams of numbers
 Cchess.WhiteVsBlackProcess a database of chess games to calculate the number of white wins vs
 Cbasic.WindowAverageCompute the cumulative average of a list of numbers over a sliding window
 Cbasic.WindowEvenUse a Window processor to perform a computation over a sliding window of events that are not numeric
 Cstockticker.WindowQuery
 Cplots.WindowScatterplotUpdate a windowed 2D scatterplot in realtime from two streams of numbers
 Cbasic.WindowSimpleUse a Window processor to perform a computation over a sliding window of events
 Cbasic.WithoutPumpPrint events from a queue source without the use of a pump
 Cbasic.WithPumpPrint events from a queue source with the use of a Pump processor
 Cbasic.WithTank
 Cxml.XPathExampleEvaluate JPath expressions on JSON elements
 CBinaryFunction
 CFunction
 CFunctionTree
 CGrammarObjectBuilder
 CGroupProcessor
 CGroupProcessorBuilder
 CMooreMachine
 CPassthroughFunction
 CSink
 CSource
 CSynchronousProcessor
 CUnaryFunction
 CUniformProcessor