Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W Z 

A

AbstractContext<I,O> - Class in org.apache.edgent.runtime.etiao
Provides a skeletal implementation of the OpletContext interface.
AbstractContext(JobContext, RuntimeServices) - Constructor for class org.apache.edgent.runtime.etiao.AbstractContext
 
AbstractGraph<G> - Class in org.apache.edgent.graph.spi
A skeletal implementation of the Graph interface, to minimize the effort required to implement the interface.
AbstractGraph() - Constructor for class org.apache.edgent.graph.spi.AbstractGraph
 
AbstractGraphJob - Class in org.apache.edgent.graph.spi.execution
Placeholder for a skeletal implementation of the Job interface, to minimize the effort required to implement the interface.
AbstractGraphJob() - Constructor for class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
AbstractOplet<I,O> - Class in org.apache.edgent.oplet.core
 
AbstractOplet() - Constructor for class org.apache.edgent.oplet.core.AbstractOplet
 
AbstractTester - Class in org.apache.edgent.topology.spi.tester
 
AbstractTester() - Constructor for class org.apache.edgent.topology.spi.tester.AbstractTester
 
AbstractTopology<X extends Tester> - Class in org.apache.edgent.topology.spi
Topology implementation that uses the basic functions to implement most sources streams.
AbstractTopology(String) - Constructor for class org.apache.edgent.topology.spi.AbstractTopology
 
AbstractTopologyProvider<T extends Topology> - Class in org.apache.edgent.topology.spi
 
AbstractTopologyProvider() - Constructor for class org.apache.edgent.topology.spi.AbstractTopologyProvider
 
AbstractTStream<G extends Topology,T> - Class in org.apache.edgent.topology.spi
Abstract stream that uses the functional primitives to implement most methods.
AbstractTStream(G) - Constructor for class org.apache.edgent.topology.spi.AbstractTStream
 
AbstractTWindow<T,K> - Class in org.apache.edgent.topology.spi.graph
 
AbstractVertex<OP extends Oplet<I,O>,I,O> - Class in org.apache.edgent.graph.spi
Placeholder for a skeletal implementation of the Vertex interface, to minimize the effort required to implement the interface.
AbstractVertex() - Constructor for class org.apache.edgent.graph.spi.AbstractVertex
 
accept(T, U) - Method in interface org.apache.edgent.function.BiConsumer
Consume the two arguments.
accept(T) - Method in interface org.apache.edgent.function.Consumer
Apply the function to value.
accept(T) - Method in class org.apache.edgent.oplet.core.FanOut
 
accept(T) - Method in class org.apache.edgent.oplet.core.Peek
 
accept(T) - Method in class org.apache.edgent.oplet.core.Split
 
accept(T) - Method in class org.apache.edgent.oplet.functional.Events
 
accept(T) - Method in class org.apache.edgent.oplet.functional.Filter
 
accept(I) - Method in class org.apache.edgent.oplet.functional.FlatMap
 
accept(I) - Method in class org.apache.edgent.oplet.functional.Map
 
accept(T, int) - Method in class org.apache.edgent.oplet.plumbing.Barrier
 
accept(T) - Method in class org.apache.edgent.oplet.plumbing.Isolate
 
accept(T) - Method in class org.apache.edgent.oplet.plumbing.PressureReliever
 
accept(T) - Method in class org.apache.edgent.oplet.plumbing.UnorderedIsolate
 
accept(T) - Method in class org.apache.edgent.oplet.window.Aggregate
 
accept(T) - Method in class org.apache.edgent.runtime.etiao.SettableForwarder
 
accept(T) - Method in class org.apache.edgent.streamscope.StreamScope
 
add(T) - Method in class org.apache.edgent.window.InsertionTimeList
 
addCleaner(BiConsumer<String, String>) - Method in class org.apache.edgent.execution.services.ServiceContainer
Registers a new cleaner.
addHeartBeat(IotDevice, long, TimeUnit, String) - Static method in class org.apache.edgent.connectors.iot.HeartBeat
Add IoT device heart beat processing to a topology.
addIotDevice(TopologyElement) - Static method in class org.apache.edgent.apps.iot.IotDevicePubSub
Add a proxy IotDevice for the topology containing te.
additionalNameKeys(Hashtable<String, String>) - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
 
addJob(Job) - Method in interface org.apache.edgent.execution.services.JobRegistryService
Adds the specified job.
addJob(Job) - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
addKeyProperties(String, Map<String, String>) - Method in class org.apache.edgent.metrics.MetricObjectNameFactory
Extracts job and oplet identifier values from the specified buffer and adds the MetricObjectNameFactory.KEY_JOBID and MetricObjectNameFactory.KEY_OPID key properties to the specified properties map.
addListener(BiConsumer<JobRegistryService.EventType, Job>) - Method in interface org.apache.edgent.execution.services.JobRegistryService
Adds a handler to a collection of listeners that will be notified on job registration and state changes.
addListener(BiConsumer<JobRegistryService.EventType, Job>) - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
addOpletInvocation(T, int, int) - Method in class org.apache.edgent.runtime.etiao.Executable
Creates a new Invocation associated with the specified oplet.
addOutput() - Method in interface org.apache.edgent.graph.Vertex
Add an output port to the vertex.
addOutput() - Method in class org.apache.edgent.runtime.etiao.graph.ExecutableVertex
 
addOutput() - Method in class org.apache.edgent.runtime.etiao.Invocation
Adds a new output.
addService(Class<T>, T) - Method in class org.apache.edgent.execution.services.ServiceContainer
Adds the specified service to this ServiceContainer.
addStreamScopes(Topology) - Static method in class org.apache.edgent.streamscope.StreamScopeSetup
Add StreamScope instances to the topology
addSubscriber(String, Class<T>, Consumer<T>) - Method in class org.apache.edgent.connectors.pubsub.service.ProviderPubSub
 
addSubscriber(String, Class<T>, Consumer<T>) - Method in interface org.apache.edgent.connectors.pubsub.service.PublishSubscribeService
Add a subscriber to a published topic.
afterExecute(Runnable, Throwable) - Method in class org.apache.edgent.runtime.etiao.TrackingScheduledExecutor
Invoked by the super class after each task execution.
aggregate(Collection<? extends Number>, UnivariateAggregate) - Static method in class org.apache.edgent.analytics.math3.Aggregations
Perform the specified UnivariateAggregate on a Collection of Number.
aggregate(Collection<T>, ToDoubleFunction<T>, UnivariateAggregate) - Static method in class org.apache.edgent.analytics.math3.Aggregations
Perform the specified UnivariateAggregate a Collection of T using the specified getter to extract the variable to aggregate.
aggregate(TWindow<JsonObject, K>, String, String, JsonUnivariateAggregate...) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Aggregate against a single Numeric variable contained in an JSON object.
aggregate(TWindow<JsonObject, K>, String, String, ToDoubleFunction<JsonObject>, JsonUnivariateAggregate...) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Aggregate against a single Numeric variable contained in an JSON object.
Aggregate<T,U,K> - Class in org.apache.edgent.oplet.window
Aggregate a window.
Aggregate(Window<T, K, ? extends List<T>>, BiFunction<List<T>, K, U>) - Constructor for class org.apache.edgent.oplet.window.Aggregate
 
aggregate(BiFunction<List<T>, K, U>) - Method in class org.apache.edgent.topology.spi.graph.TWindowImpl
 
aggregate(BiFunction<List<T>, K, U>) - Method in class org.apache.edgent.topology.spi.graph.TWindowTimeImpl
Window behaviour here is that: Tuples are always inserted into the partition.
aggregate(BiFunction<List<T>, K, U>) - Method in interface org.apache.edgent.topology.TWindow
Declares a stream that is a continuous, sliding, aggregation of partitions in this window.
aggregateList(String, String, ToDoubleFunction<JsonObject>, JsonUnivariateAggregate...) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Create a Function that aggregates against a single Numeric variable contained in an JSON object.
aggregateN(Collection<? extends Number>, UnivariateAggregate...) - Static method in class org.apache.edgent.analytics.math3.Aggregations
Perform the specified UnivariateAggregate on a Collection of Number.
aggregateN(Collection<T>, ToDoubleFunction<T>, UnivariateAggregate...) - Static method in class org.apache.edgent.analytics.math3.Aggregations
Perform the specified UnivariateAggregate a Collection of T using the specified getter to extract the variable to aggregate.
Aggregations - Class in org.apache.edgent.analytics.math3
Apache Common Math analytics for Collections.
Aggregations() - Constructor for class org.apache.edgent.analytics.math3.Aggregations
 
alias(String) - Method in interface org.apache.edgent.graph.Connector
Set the alias for the connector.
ALIAS - Static variable in interface org.apache.edgent.topology.services.ApplicationService
Default alias a service registers its control MBean as.
alias(String) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
alias(String) - Method in interface org.apache.edgent.topology.TStream
Set an alias for the stream.
ALIAS_KEY - Static variable in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
Key for the alias of the control MBean in a JSON request.
alwaysFalse() - Static method in class org.apache.edgent.function.Functions
A Predicate that is always false
alwaysInsert() - Static method in class org.apache.edgent.window.Policies
Returns an insertion policy that indicates the tuple is to be inserted into the partition.
alwaysTrue() - Static method in class org.apache.edgent.function.Functions
A Predicate that is always true
and(Condition<?>...) - Method in class org.apache.edgent.topology.spi.tester.AbstractTester
 
and(Condition<?>...) - Method in interface org.apache.edgent.topology.tester.Tester
Return a condition that is valid only if all of conditions are valid.
APP_NAME - Static variable in class org.apache.edgent.apps.iot.IotDevicePubSub
IotDevicePubSub application name.
APP_NAME - Static variable in class org.apache.edgent.apps.runtime.JobMonitorApp
Job monitoring application name.
ApplicationService - Interface in org.apache.edgent.topology.services
A service that allows registration of applications and the ability to submit them through a control MBean.
ApplicationServiceMXBean - Interface in org.apache.edgent.topology.mbeans
Control MBean for the application service.
apply(T) - Method in interface org.apache.edgent.connectors.jdbc.CheckedFunction
Apply a function to t and return the result.
apply(T, U) - Method in interface org.apache.edgent.function.BiFunction
Apply a function to t and u.
apply(T) - Method in interface org.apache.edgent.function.Function
Apply a function to value.
applyAsDouble(T) - Method in interface org.apache.edgent.function.ToDoubleFunction
Apply a function to value.
applyAsInt(T) - Method in interface org.apache.edgent.function.ToIntFunction
Apply a function to value.
applyAsInt(T) - Method in class org.apache.edgent.topology.plumbing.LoadBalancedSplitter
 
AppService - Class in org.apache.edgent.runtime.appservice
Application service for a TopologyProvider.
AppService(TopologyProvider, DirectSubmitter<Topology, Job>, String) - Constructor for class org.apache.edgent.runtime.appservice.AppService
Create an ApplicationService instance.
AppServiceControl - Class in org.apache.edgent.runtime.appservice
 
ARGS_KEY - Static variable in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
Key for the argument list.
asBytes() - Static method in class org.apache.edgent.topology.json.JsonFunctions
Get the UTF-8 bytes representation of the JSON for a JsonObject.
asString() - Static method in class org.apache.edgent.topology.json.JsonFunctions
Get the JSON for a JsonObject.
asString() - Method in class org.apache.edgent.topology.spi.AbstractTStream
Convert this stream to a stream of String tuples by calling toString() on each tuple.
asString() - Method in interface org.apache.edgent.topology.TStream
Convert this stream to a stream of String tuples by calling toString() on each tuple.
AT_LEAST_ONCE - Static variable in interface org.apache.edgent.connectors.iot.QoS
The message containing the event arrives at the message hub at least once.
AT_MOST_ONCE - Static variable in interface org.apache.edgent.connectors.iot.QoS
The message containing the event arrives at the message hub either once or not at all.
atLeast(T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range [lowerEndpoint..*) (inclusive/CLOSED)
atLeastTupleCount(TStream<?>, long) - Method in interface org.apache.edgent.topology.tester.Tester
Return a condition that evaluates if stream has submitted at least expectedCount number of tuples.
atMost(T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range (*..upperEndpoint] (inclusive/CLOSED)
ATTR_DEVICE_ID - Static variable in class org.apache.edgent.connectors.iotp.IotpGateway
WIoTP Device Id identifier key.
ATTR_DEVICE_TYPE - Static variable in class org.apache.edgent.connectors.iotp.IotpGateway
WIoTP Device Type identifier key.

B

Barrier<T> - Class in org.apache.edgent.oplet.plumbing
A tuple synchronization barrier.
Barrier(int) - Constructor for class org.apache.edgent.oplet.plumbing.Barrier
Create a new instance.
barrier(List<TStream<T>>) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
A tuple synchronization barrier.
barrier(List<TStream<T>>, int) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
A tuple synchronization barrier.
basic(String, String) - Static method in class org.apache.edgent.connectors.http.HttpClients
Create a basic authentication HTTP client with a fixed user and password.
basic(Supplier<String>, Supplier<String>) - Static method in class org.apache.edgent.connectors.http.HttpClients
Method to create a basic authentication HTTP client.
batch(BiFunction<List<T>, K, U>) - Method in class org.apache.edgent.topology.spi.graph.TWindowImpl
 
batch(BiFunction<List<T>, K, U>) - Method in class org.apache.edgent.topology.spi.graph.TWindowTimeImpl
 
batch(BiFunction<List<T>, K, U>) - Method in interface org.apache.edgent.topology.TWindow
Declares a stream that represents a batched aggregation of partitions in this window.
BiConsumer<T,U> - Interface in org.apache.edgent.function
Consumer function that takes two arguments.
BiFunction<T,U,R> - Interface in org.apache.edgent.function
Function that takes two arguments and returns a value.
blockingDelay(TStream<T>, long, TimeUnit) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Insert a blocking delay between tuples.
blockingOneShotDelay(TStream<T>, long, TimeUnit) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Insert a blocking delay before forwarding the first tuple and no delay for subsequent tuples.
blockingThrottle(TStream<T>, long, TimeUnit) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Maintain a constant blocking delay between tuples.
BufferManager() - Constructor for class org.apache.edgent.streamscope.StreamScope.BufferManager
 
bufferMgr() - Method in class org.apache.edgent.streamscope.StreamScope

C

channelDone(int) - Method in class org.apache.edgent.topology.plumbing.LoadBalancedSplitter
Signal that the channel is done processing the splitter supplied tuple.
CheckedFunction<T,R> - Interface in org.apache.edgent.connectors.jdbc
Function to apply a funtion to an input value and return a result.
CheckedSupplier<T> - Interface in org.apache.edgent.connectors.jdbc
Function that supplies a result and may throw an Exception.
checkName(String) - Method in class org.apache.edgent.topology.spi.AbstractTopologyProvider
 
cleanOplet(String, String) - Method in class org.apache.edgent.execution.services.ServiceContainer
Invokes all the registered cleaners in the context of the specified job and element.
clear(JsonElement, int) - Method in interface org.apache.edgent.analytics.math3.json.JsonUnivariateAggregator
Clear the aggregator to prepare for a new aggregation.
clear(JsonElement, int) - Method in class org.apache.edgent.analytics.math3.stat.JsonStorelessStatistic
 
clear(int) - Method in class org.apache.edgent.analytics.math3.stat.StorelessStatistic
 
clear(int) - Method in interface org.apache.edgent.analytics.math3.UnivariateAggregator
Clear the aggregator to prepare for a new aggregation.
clear() - Method in class org.apache.edgent.window.InsertionTimeList
 
close() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
close() - Method in class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet
 
close() - Method in class org.apache.edgent.oplet.core.FanIn
 
close() - Method in class org.apache.edgent.oplet.core.FanOut
 
close() - Method in class org.apache.edgent.oplet.core.Sink
 
close() - Method in class org.apache.edgent.oplet.core.Split
 
close() - Method in class org.apache.edgent.oplet.core.Union
 
close() - Method in class org.apache.edgent.oplet.functional.Events
 
close() - Method in class org.apache.edgent.oplet.functional.Filter
 
close() - Method in class org.apache.edgent.oplet.functional.FlatMap
 
close() - Method in class org.apache.edgent.oplet.functional.Map
 
close() - Method in class org.apache.edgent.oplet.functional.Peek
 
close() - Method in class org.apache.edgent.oplet.functional.SupplierPeriodicSource
 
close() - Method in class org.apache.edgent.oplet.functional.SupplierSource
 
close() - Method in class org.apache.edgent.oplet.plumbing.Barrier
 
close() - Method in class org.apache.edgent.oplet.plumbing.Isolate
 
close() - Method in class org.apache.edgent.oplet.plumbing.PressureReliever
 
close() - Method in class org.apache.edgent.oplet.plumbing.UnorderedIsolate
 
close() - Method in class org.apache.edgent.oplet.window.Aggregate
 
close() - Method in class org.apache.edgent.runtime.etiao.Executable
Shuts down the user scheduler and thread factory, close all invocations, then shutdown the control scheduler.
close() - Method in class org.apache.edgent.runtime.etiao.Invocation
 
closeActiveFile(Path) - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
closed(T, T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range [lowerEndpoint..upperEndpoint] (both inclusive/CLOSED)
closedOpen(T, T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range [lowerEndpoint..upperEndpoint) (inclusive/CLOSED,exclusive/OPEN)
closeFunction(Object) - Static method in class org.apache.edgent.function.Functions
Close the function.
closeJob(String, ControlService) - Static method in class org.apache.edgent.apps.runtime.JobMonitorApp
Closes a job using a JobMXBean control registered with the specified ControlService.
CMD_DEVICE - Static variable in interface org.apache.edgent.connectors.iot.IotDevice
Device identifier key.
CMD_FORMAT - Static variable in interface org.apache.edgent.connectors.iot.IotDevice
Command format key.
CMD_ID - Static variable in interface org.apache.edgent.connectors.iot.IotDevice
Command identifier key.
CMD_PAYLOAD - Static variable in interface org.apache.edgent.connectors.iot.IotDevice
Command payload key.
CMD_TS - Static variable in interface org.apache.edgent.connectors.iot.IotDevice
Command timestamp (in milliseconds) key.
collection(Collection<T>) - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
collection(Collection<T>) - Method in interface org.apache.edgent.topology.Topology
Declare a stream of constants from a collection.
commandReaderList(ProcessBuilder) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Create a Supplier<List<String>> to ingest a command's output.
Commands - Interface in org.apache.edgent.connectors.iot
Device command identifiers used by Edgent.
commands(String...) - Method in interface org.apache.edgent.connectors.iot.IotDevice
Create a stream of device commands as JSON objects.
commands(String...) - Method in class org.apache.edgent.connectors.iotp.IotpDevice
Create a stream of device commands as JSON objects.
commands(String...) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
commands(String...) - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Create a stream of device commands as JSON objects.
COMMANDS_TOPIC - Static variable in class org.apache.edgent.apps.iot.IotDevicePubSub
Device commands are published to "edgent/iot/commands" by this application.
commandsForDevice(Set<String>, String...) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Create a stream of device commands as JSON objects.
commandsForDevice(String, String...) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Create a stream of device commands as JSON objects.
commandsForDevice(Set<String>, String...) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
commandsForDevice(String, String...) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
commandsForType(String, String...) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Create a stream of device commands as JSON objects.
commandsForType(String, String...) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
CommandStreams - Class in org.apache.edgent.connectors.command
Connector for creating a TStream from a Command's / OS Process's output and sinking a TStream to a Command's / OS Process's input.
commandTopic(String) - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Get the MQTT topic for a command.
commandWriter(ProcessBuilder) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Create a Consumer<String> to write UTF8 string data to a command's input.
complete() - Method in interface org.apache.edgent.execution.Job
Waits for any outstanding job work to complete.
complete(long, TimeUnit) - Method in interface org.apache.edgent.execution.Job
Waits for at most the specified time for the job to complete.
complete() - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
complete(long, TimeUnit) - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
complete(Submitter<Topology, ? extends Job>, JsonObject, Condition<?>, long, TimeUnit) - Method in class org.apache.edgent.topology.spi.tester.AbstractTester
 
complete(Submitter<Topology, ? extends Job>, JsonObject, Condition<?>, long, TimeUnit) - Method in interface org.apache.edgent.topology.tester.Tester
Submit the topology for this tester and wait for it to complete, or reach an end condition.
completeClosing(long, TimeUnit) - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
Complete job closing.
completeTransition() - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
completeTransition() - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
CompressedFileWriterPolicy<T> - Class in org.apache.edgent.connectors.file
A FileWriterPolicy that generates zip compressed files.
CompressedFileWriterPolicy() - Constructor for class org.apache.edgent.connectors.file.CompressedFileWriterPolicy
 
CompressedFileWriterPolicy(FileWriterFlushConfig<T>, FileWriterCycleConfig<T>, FileWriterRetentionConfig) - Constructor for class org.apache.edgent.connectors.file.CompressedFileWriterPolicy
 
compressFile(Path, Path) - Method in class org.apache.edgent.connectors.file.CompressedFileWriterPolicy
 
concurrent(TStream<T>, List<Function<TStream<T>, TStream<U>>>, Function<List<U>, R>) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Perform analytics concurrently.
concurrentMap(TStream<T>, List<Function<T, U>>, Function<List<U>, R>) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Perform analytics concurrently.
Condition<T> - Interface in org.apache.edgent.topology.tester
Function representing if a condition is valid or not.
Configs - Interface in org.apache.edgent.execution
Configuration property names.
connect(Vertex<?, T, ?>, int) - Method in interface org.apache.edgent.graph.Connector
Connect this Connector to the specified target's input.
Connector<T> - Interface in org.apache.edgent.graph
A Connector represents an output port of a Vertex.
ConnectorStream<G extends Topology,T> - Class in org.apache.edgent.topology.spi.graph
A stream that directly adds oplets to the graph.
ConnectorStream(G, Connector<T>) - Constructor for class org.apache.edgent.topology.spi.graph.ConnectorStream
 
connectPipe(N) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
Consumer<T> - Interface in org.apache.edgent.function
Function that consumes a value.
consumer(int) - Method in class org.apache.edgent.oplet.core.FanIn
Create a Consumer for the input port that invokes the receiver and submits a generated tuple, if any, to the output.
contains(T, Comparator<T>) - Method in class org.apache.edgent.analytics.sensors.Range
Determine if the Region contains the value.
contains(T) - Method in class org.apache.edgent.analytics.sensors.Range
Determine if the Region contains the value.
contentsUnordered(TStream<T>, T...) - Method in interface org.apache.edgent.topology.tester.Tester
Return a condition that evaluates if stream has submitted tuples matching values in any order.
CONTROL_APP_NAME - Static variable in class org.apache.edgent.providers.iot.IotProvider
IoT control using device commands application name.
CONTROL_SERVICE - Static variable in interface org.apache.edgent.connectors.iot.Commands
Command identifier used for the control service.
controlRequest(JsonObject) - Method in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
Handle a JSON control request.
Controls - Class in org.apache.edgent.execution.services
Utilities for the control service.
Controls() - Constructor for class org.apache.edgent.execution.services.Controls
 
ControlService - Interface in org.apache.edgent.execution.services
Service that provides a control mechanism.
countContentsPolicy(int) - Static method in class org.apache.edgent.window.Policies
Returns a count-based contents policy.
counter(TStream<T>) - Static method in class org.apache.edgent.metrics.Metrics
Increment a counter metric when peeking at each tuple.
counter(Topology) - Static method in class org.apache.edgent.metrics.Metrics
Add counter metrics to all the topology's streams.
CounterOp<T> - Class in org.apache.edgent.metrics.oplets
A metrics oplet which counts the number of tuples peeked at.
CounterOp() - Constructor for class org.apache.edgent.metrics.oplets.CounterOp
 
createAndRegister(TopologyProvider, DirectSubmitter<Topology, Job>) - Static method in class org.apache.edgent.runtime.appservice.AppService
Create an register an application service using the default alias ApplicationService.ALIAS.
createAndRegister(ServiceContainer) - Static method in class org.apache.edgent.runtime.jobregistry.JobRegistry
Creates and registers a JobRegistry with the given service container.
createApplication(IotDevice) - Static method in class org.apache.edgent.apps.iot.IotDevicePubSub
Create an instance of this application using device as the device connection to a message hub.
createIotCommandToControlApp() - Method in class org.apache.edgent.providers.iot.IotProvider
Create application connects edgentControl device commands to the control service.
createIotDeviceApp() - Method in class org.apache.edgent.providers.iot.IotProvider
Create application that connects to the message hub.
createJob(Graph, String, String) - Method in class org.apache.edgent.runtime.etiao.Executable
 
createJobMonitorApp() - Method in class org.apache.edgent.providers.iot.IotProvider
Create Job monitor application.
createMessageHubDevice(Topology) - Method in class org.apache.edgent.providers.iot.IotProvider
Create the connection to the message hub.
createName(String, String, String) - Method in class org.apache.edgent.metrics.MetricObjectNameFactory
Creates a JMX ObjectName from the given domain, metric type, and metric name.
Csv - Class in org.apache.edgent.connectors.csv
Utilities for working with CSV strings.

D

deadband(TStream<T>, Function<T, V>, Predicate<V>, long, TimeUnit) - Static method in class org.apache.edgent.analytics.sensors.Filters
Deadband filter with maximum suppression time.
deadband(TStream<T>, Function<T, V>, Predicate<V>) - Static method in class org.apache.edgent.analytics.sensors.Filters
Deadband filter.
Deadtime<T> - Class in org.apache.edgent.analytics.sensors
Deadtime Predicate.
Deadtime() - Constructor for class org.apache.edgent.analytics.sensors.Deadtime
Create a new Deadtime Predicate
Deadtime(long, TimeUnit) - Constructor for class org.apache.edgent.analytics.sensors.Deadtime
Create a new Deadtime Predicate
deadtime(TStream<T>, long, TimeUnit) - Static method in class org.apache.edgent.analytics.sensors.Filters
Deadtime filter.
declareTopology(String) - Method in class org.apache.edgent.apps.runtime.JobMonitorApp
Declares the following topology:
declareTopology(Topology) - Static method in class org.apache.edgent.apps.runtime.JobMonitorApp
Populates the following topology:
decorateTask(Runnable, RunnableScheduledFuture<V>) - Method in class org.apache.edgent.runtime.etiao.TrackingScheduledExecutor
 
decorateTask(Callable<V>, RunnableScheduledFuture<V>) - Method in class org.apache.edgent.runtime.etiao.TrackingScheduledExecutor
 
delayedConsume(Consumer<T>, T) - Static method in class org.apache.edgent.function.Functions
Create a Runnable that calls consumer.accept(value) when run() is called.
deleteJson(TStream<JsonObject>, Supplier<CloseableHttpClient>, Function<JsonObject, String>) - Static method in class org.apache.edgent.connectors.http.HttpStreams
Make an HTTP DELETE request with JsonObject.
derived(Connector<U>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
DevelopmentProvider - Class in org.apache.edgent.providers.development
Provider intended for development.
DevelopmentProvider() - Constructor for class org.apache.edgent.providers.development.DevelopmentProvider
 
DirectEdge - Class in org.apache.edgent.graph.spi
This class provides a simple implementation of the Edge interface in the context of a DirectProvider.
DirectEdge(Connector<?>, Vertex<?, ?, ?>, int, Vertex<?, ?, ?>, int) - Constructor for class org.apache.edgent.graph.spi.DirectEdge
 
DirectEdge() - Constructor for class org.apache.edgent.graph.spi.DirectEdge
Create disconnected edge.
DirectGraph - Class in org.apache.edgent.runtime.etiao.graph
DirectGraph is a Graph that is executed in the current virtual machine.
DirectGraph(String, ServiceContainer) - Constructor for class org.apache.edgent.runtime.etiao.graph.DirectGraph
Creates a new DirectGraph instance underlying the specified topology.
directoryWatcher(TopologyElement, Supplier<String>) - Static method in class org.apache.edgent.connectors.file.FileStreams
Declare a stream containing the absolute pathname of newly created file names from watching directory.
directoryWatcher(TopologyElement, Supplier<String>, Comparator<File>) - Static method in class org.apache.edgent.connectors.file.FileStreams
Declare a stream containing the absolute pathname of newly created file names from watching directory.
DirectProvider - Class in org.apache.edgent.providers.direct
DirectProvider is a TopologyProvider that runs a submitted topology as a Job in threads in the current virtual machine.
DirectProvider() - Constructor for class org.apache.edgent.providers.direct.DirectProvider
 
DirectSubmitter<E,J extends Job> - Interface in org.apache.edgent.execution
An interface for submission of an executable that is executed directly within the current virtual machine.
DirectTopology - Class in org.apache.edgent.providers.direct
DirectTopology is a GraphTopology that is executed in threads in the current virtual machine.
discard() - Static method in class org.apache.edgent.function.Functions
A Consumer that discards all items passed to it.
disconnect(int) - Method in class org.apache.edgent.runtime.etiao.Invocation
Disconnects the specified port by connecting to a no-op Consumer implementation.
doNothing() - Static method in class org.apache.edgent.window.Policies
A BiConsumer policy which does nothing.

E

Edge - Interface in org.apache.edgent.graph
Represents an edge between two Vertices.
EdgeType - Class in org.apache.edgent.runtime.etiao.graph.model
Represents an edge between two VertexType nodes.
EdgeType() - Constructor for class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
EdgeType(Edge, IdMapper<String>) - Constructor for class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
endlessCommandReader(ProcessBuilder) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Create an endless Supplier<String> for ingesting a long running command's output.
EndlessSupplier<T> - Class in org.apache.edgent.topology.spi.functions
 
EndlessSupplier(Supplier<T>) - Constructor for class org.apache.edgent.topology.spi.functions.EndlessSupplier
 
equals(Object) - Method in class org.apache.edgent.analytics.sensors.Range
Returns true if o is a Range having equal endpoints and bound types to this Range.
EtiaoJob - Class in org.apache.edgent.runtime.etiao
Etiao runtime implementation of the Job interface.
EtiaoJobBean - Class in org.apache.edgent.runtime.etiao.mbeans
Implementation of a control interface for the EtiaoJob.
evaluate(long, int, T) - Method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
Evaluate if the specified values indicate that a cycling of the active file should be performed.
evaluate(int, T) - Method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
Evaluate if the specified values indicate that a flush should be performed.
evaluate(int, long) - Method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
Evaluate if the specified values indicate that a final file should be removed.
Events - Interface in org.apache.edgent.connectors.iot
Device event identifiers used by Edgent.
events(TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>, Function<JsonObject, Integer>) - Method in interface org.apache.edgent.connectors.iot.IotDevice
Publish a stream's tuples as device events.
events(TStream<JsonObject>, String, int) - Method in interface org.apache.edgent.connectors.iot.IotDevice
Publish a stream's tuples as device events.
events(TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>, Function<JsonObject, Integer>) - Method in class org.apache.edgent.connectors.iotp.IotpDevice
Publish a stream's tuples as device events.
events(TStream<JsonObject>, String, int) - Method in class org.apache.edgent.connectors.iotp.IotpDevice
Publish a stream's tuples as device events.
events(TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>, Function<JsonObject, Integer>) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
events(TStream<JsonObject>, String, int) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
events(TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>, Function<JsonObject, Integer>) - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Publish a stream's tuples as device events.
events(TStream<JsonObject>, String, int) - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Publish a stream's tuples as device events.
Events<T> - Class in org.apache.edgent.oplet.functional
Generate tuples from events.
Events(Consumer<Consumer<T>>) - Constructor for class org.apache.edgent.oplet.functional.Events
 
events(Consumer<Consumer<T>>) - Method in class org.apache.edgent.topology.spi.graph.GraphTopology
 
events(Consumer<Consumer<T>>) - Method in interface org.apache.edgent.topology.Topology
Declare a stream populated by an event system.
EVENTS_TOPIC - Static variable in class org.apache.edgent.apps.iot.IotDevicePubSub
Events published to topic "edgent/iot/events" are sent as device events using the actual message hub IotDevice.
eventsForDevice(Function<JsonObject, String>, TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>, Function<JsonObject, Integer>) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Publish a stream's tuples as device events.
eventsForDevice(String, TStream<JsonObject>, String, int) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Publish a stream's tuples as device events.
eventsForDevice(Function<JsonObject, String>, TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>, Function<JsonObject, Integer>) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
eventsForDevice(String, TStream<JsonObject>, String, int) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
eventTopic(String) - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Get the MQTT topic for an device event.
evict() - Method in interface org.apache.edgent.window.Partition
Calls the partition's evictDeterminer.
evictAll() - Static method in class org.apache.edgent.window.Policies
Returns a Consumer representing an evict determiner that evict all tuples from the window.
evictAllAndScheduleEvictWithProcess(long, TimeUnit) - Static method in class org.apache.edgent.window.Policies
An eviction policy which processes the window, evicts all tuples, and schedules the next eviction after the appropriate interval.
evictOlderWithProcess(long, TimeUnit) - Static method in class org.apache.edgent.window.Policies
An eviction policy which evicts all tuples that are older than a specified time.
evictOldest() - Static method in class org.apache.edgent.window.Policies
Returns an evict determiner that evicts the oldest tuple.
EXACTLY_ONCE - Static variable in interface org.apache.edgent.connectors.iot.QoS
The message containing the event arrives at the message hub exactly once.
Executable - Class in org.apache.edgent.runtime.etiao
Executes and provides runtime services to the executable graph elements (oplets and functions).
Executable(String, ServiceContainer) - Constructor for class org.apache.edgent.runtime.etiao.Executable
Creates a new Executable for the specified job.
Executable(String, ServiceContainer, ThreadFactory) - Constructor for class org.apache.edgent.runtime.etiao.Executable
Creates a new Executable for the specified topology name, which uses the given thread factory to create new threads for oplet execution.
executable() - Method in class org.apache.edgent.runtime.etiao.graph.DirectGraph
Returns the Executable running this graph.
ExecutableVertex<N extends Oplet<C,P>,C,P> - Class in org.apache.edgent.runtime.etiao.graph
 
executeStatement(TStream<T>, Supplier<String>, ParameterSetter<T>, ResultsHandler<T, R>) - Method in class org.apache.edgent.connectors.jdbc.JdbcStreams
For each tuple on stream execute an SQL statement and add 0 or more resulting tuples to a result stream.
executeStatement(TStream<T>, StatementSupplier, ParameterSetter<T>, ResultsHandler<T, R>) - Method in class org.apache.edgent.connectors.jdbc.JdbcStreams
For each tuple on stream execute an SQL statement and add 0 or more resulting tuples to a result stream.
executeStatement(TStream<T>, Supplier<String>, ParameterSetter<T>) - Method in class org.apache.edgent.connectors.jdbc.JdbcStreams
For each tuple on stream execute an SQL statement.
executeStatement(TStream<T>, StatementSupplier, ParameterSetter<T>) - Method in class org.apache.edgent.connectors.jdbc.JdbcStreams
For each tuple on stream execute an SQL statement.

F

f() - Method in class org.apache.edgent.function.WrappedFunction
Function that was wrapped.
FanIn<T,U> - Class in org.apache.edgent.oplet.core
FanIn oplet, merges multiple input ports into a single output port.
FanIn() - Constructor for class org.apache.edgent.oplet.core.FanIn
 
FanIn(BiFunction<T, Integer, U>) - Constructor for class org.apache.edgent.oplet.core.FanIn
 
fanin(FanIn<T, U>, List<TStream<T>>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
fanin(FanIn<T, U>, List<TStream<T>>) - Method in interface org.apache.edgent.topology.TStream
Declare a stream that contains the output of the specified FanIn oplet applied to this stream and others.
FanOut<T> - Class in org.apache.edgent.oplet.core
 
FanOut() - Constructor for class org.apache.edgent.oplet.core.FanOut
 
feeder() - Method in class org.apache.edgent.topology.spi.graph.AbstractTWindow
 
feeder() - Method in interface org.apache.edgent.topology.TWindow
Get the stream that feeds this window.
fetchTuples() - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
fetchTuples() - Method in class org.apache.edgent.oplet.functional.SupplierPeriodicSource
 
FileStreams - Class in org.apache.edgent.connectors.file
FileStreams is a connector for integrating with file system objects.
FileWriterCycleConfig<T> - Class in org.apache.edgent.connectors.file
FileWriter active file cycle configuration control.
FileWriterFlushConfig<T> - Class in org.apache.edgent.connectors.file
FileWriter active file flush configuration control.
FileWriterPolicy<T> - Class in org.apache.edgent.connectors.file
A full featured IFileWriterPolicy implementation.
FileWriterPolicy() - Constructor for class org.apache.edgent.connectors.file.FileWriterPolicy
Create a new file writer policy instance.
FileWriterPolicy(FileWriterFlushConfig<T>, FileWriterCycleConfig<T>, FileWriterRetentionConfig) - Constructor for class org.apache.edgent.connectors.file.FileWriterPolicy
Create a new file writer policy instance.
FileWriterRetentionConfig - Class in org.apache.edgent.connectors.file
FileWriter finalized (non-active) file retention configuration control.
Filter<T> - Class in org.apache.edgent.oplet.functional
 
Filter(Predicate<T>) - Constructor for class org.apache.edgent.oplet.functional.Filter
 
filter(Predicate<T>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
filter(Predicate<T>) - Method in interface org.apache.edgent.topology.TStream
Declare a new stream that filters tuples from this stream.
Filters - Class in org.apache.edgent.analytics.sensors
Filters aimed at sensors.
FIRE_AND_FORGET - Static variable in interface org.apache.edgent.connectors.iot.QoS
Fire and forget the event.
FlatMap<I,O> - Class in org.apache.edgent.oplet.functional
Map an input tuple to 0-N output tuples.
FlatMap(Function<I, Iterable<O>>) - Constructor for class org.apache.edgent.oplet.functional.FlatMap
 
flatMap(Function<T, Iterable<U>>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
flatMap(Function<T, Iterable<U>>) - Method in interface org.apache.edgent.topology.TStream
Declare a new stream that maps tuples from this stream into one or more (or zero) tuples of a different type U.
fromBytes() - Static method in class org.apache.edgent.topology.json.JsonFunctions
Create a new JsonObject from the UTF8 bytes representation of JSON.
fromProperties(Properties) - Static method in class org.apache.edgent.connectors.mqtt.MqttConfig
Create a new configuration from Properties.
fromString() - Static method in class org.apache.edgent.topology.json.JsonFunctions
Create a new JsonObject from JSON.
Function<T,R> - Interface in org.apache.edgent.function
Single argument function.
Functions - Class in org.apache.edgent.function
Common functions and functional utilities.
Functions() - Constructor for class org.apache.edgent.function.Functions
 

G

gate(TStream<T>, Semaphore) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Control the flow of tuples to an output stream.
generate(Topology, ProcessBuilder) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Create an endless TStream<String> from a long running command's output.
generate(Supplier<T>) - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
generate(Supplier<T>) - Method in interface org.apache.edgent.topology.Topology
Declare an endless source stream.
get() - Method in enum org.apache.edgent.analytics.math3.stat.Statistic
Return a new instance of this statistic implementation.
get() - Method in enum org.apache.edgent.analytics.math3.stat.Statistic2
Return a new instance of this statistic implementation.
get() - Method in interface org.apache.edgent.connectors.jdbc.CheckedSupplier
Get a result.
get(Connection) - Method in interface org.apache.edgent.connectors.jdbc.StatementSupplier
Create a JDBC SQL PreparedStatement containing 0 or more parameters.
get() - Method in interface org.apache.edgent.function.Supplier
Supply a value, each call to this function may return a different value.
get() - Method in class org.apache.edgent.topology.spi.functions.EndlessSupplier
 
getActionTimeToWaitMillis() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the maximum time to wait for an action (e.g., publish message) to complete.
getAgeSec() - Method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
Get the file age configuration value.
getAggregate() - Method in class org.apache.edgent.analytics.math3.stat.StorelessStatistic
 
getAggregate() - Method in interface org.apache.edgent.analytics.math3.UnivariateAggregator
Get the UnivariateAggregate this aggregator is associated with.
getAggregateFileSize() - Method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
Get the aggregate file size configuration value.
getAlias() - Method in interface org.apache.edgent.graph.Connector
Returns the alias for the connector if any.
getAlias() - Method in interface org.apache.edgent.graph.Edge
Returns the alias associated with this edge.
getAlias() - Method in class org.apache.edgent.graph.spi.DirectEdge
 
getAlias() - Method in interface org.apache.edgent.oplet.OutputPortContext
Get the alias of the output port if any.
getAlias() - Method in class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
getAlias() - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
getAlias() - Method in interface org.apache.edgent.topology.TStream
Returns the stream's alias if any.
getApplicationNames() - Method in class org.apache.edgent.runtime.appservice.AppService
 
getApplicationNames() - Method in interface org.apache.edgent.topology.services.ApplicationService
Returns the names of applications registered with this service.
getApplicationService() - Method in class org.apache.edgent.providers.iot.IotProvider
Get the application service.
getBuilder() - Method in interface org.apache.edgent.topology.services.TopologyBuilder
How the application is built.
getClassName() - Method in class org.apache.edgent.runtime.etiao.graph.model.InvocationType
 
getClientId() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the connection Client Id.
getCntTuples() - Method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
Get the tuple count configuration value.
getCntTuples() - Method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
Get the tuple count configuration value.
getConnectionTimeout() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the connection timeout.
getConnectors() - Method in interface org.apache.edgent.graph.Vertex
Get the vertice's collection of output connectors.
getConnectors() - Method in class org.apache.edgent.runtime.etiao.graph.ExecutableVertex
 
getContents() - Method in interface org.apache.edgent.window.Partition
Retrieves the window contents.
getContentsPolicy() - Method in interface org.apache.edgent.window.Window
Returns the contents policy of the window.
getControl(String, String, Class<T>) - Method in interface org.apache.edgent.execution.services.ControlService
Return a control Mbean registered with this service.
getControl(String, String, Class<T>) - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
 
getControl(String, String, Class<T>) - Method in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
 
getControlId(String, String, Class<T>) - Method in interface org.apache.edgent.execution.services.ControlService
Return the unique identifier for a control Mbean registered with this service.
getControlId() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getControlId(String, String, Class<T>) - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
 
getControlId(String, String, Class<T>) - Method in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
 
getControlService() - Method in class org.apache.edgent.providers.iot.IotProvider
 
getCurrentState() - Method in interface org.apache.edgent.execution.Job
Retrieves the current state of this job.
getCurrentState() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Retrieves the current state of the job.
getCurrentState() - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
getCurrentState() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getCycleConfig() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
Get the policy's active file cycle configuration
getDestination() - Method in class org.apache.edgent.oplet.core.FanIn
 
getDestination() - Method in class org.apache.edgent.oplet.core.Pipe
 
getDestination() - Method in class org.apache.edgent.oplet.core.Source
 
getDestination() - Method in class org.apache.edgent.runtime.etiao.SettableForwarder
Get the destination.
getDeviceId() - Method in interface org.apache.edgent.connectors.iot.IotDevice
Get the device's unique opaque device identifier.
getDeviceId() - Method in class org.apache.edgent.connectors.iotp.IotpDevice
 
getDeviceId() - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
getDeviceId() - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
 
getDeviceType() - Method in interface org.apache.edgent.connectors.iot.IotDevice
Get the device's opaque device type identifier.
getDeviceType() - Method in class org.apache.edgent.connectors.iotp.IotpDevice
 
getDeviceType() - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
getDeviceType() - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Get the device's opaque device type identifier.
getDomain() - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
Get the JMX domain being used by this control service.
getEdges() - Method in interface org.apache.edgent.graph.Graph
Return an unmodifiable view of all edges in this graph.
getEdges() - Method in class org.apache.edgent.runtime.etiao.graph.DirectGraph
 
getEdges() - Method in class org.apache.edgent.runtime.etiao.graph.model.GraphType
 
getEvictDeterminer() - Method in interface org.apache.edgent.window.Window
Returns the window's eviction determiner.
getFeed() - Method in interface org.apache.edgent.topology.TSink
Get the stream feeding this sink.
getFileCount() - Method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
Get the file count configuration value.
getFileSize() - Method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
Get the file size configuration value.
getFlushConfig() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
Get the policy's active file flush configuration
getHealth() - Method in interface org.apache.edgent.execution.Job
Returns the summarized health indicator of the graph nodes.
getHealth() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Returns the summarized health indicator of the job.
getHealth() - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
getHealth() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getId() - Method in interface org.apache.edgent.execution.Job
Returns the identifier of this job.
getId() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Returns the identifier of the job.
getId() - Method in interface org.apache.edgent.oplet.JobContext
Get the runtime identifier for the job containing this Oplet.
getId() - Method in interface org.apache.edgent.oplet.OpletContext
Get the unique identifier (within the running job) for this oplet.
getId() - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
getId() - Method in class org.apache.edgent.runtime.etiao.graph.model.VertexType
 
getId() - Method in class org.apache.edgent.runtime.etiao.Invocation
Returns the unique identifier associated with this Invocation.
getId() - Method in class org.apache.edgent.runtime.etiao.InvocationContext
 
getId() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getIdleTimeout() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the idle connection timeout.
getInput() - Method in interface org.apache.edgent.connectors.serial.SerialPort
Get the input stream for this serial port.
getInputCount() - Method in interface org.apache.edgent.oplet.OpletContext
Get the number of connected inputs to this oplet.
getInputCount() - Method in class org.apache.edgent.runtime.etiao.InvocationContext
 
getInputs() - Method in class org.apache.edgent.oplet.core.FanIn
 
getInputs() - Method in class org.apache.edgent.oplet.core.FanOut
 
getInputs() - Method in class org.apache.edgent.oplet.core.Pipe
 
getInputs() - Method in class org.apache.edgent.oplet.core.Sink
 
getInputs() - Method in class org.apache.edgent.oplet.core.Source
 
getInputs() - Method in class org.apache.edgent.oplet.core.Split
 
getInputs() - Method in interface org.apache.edgent.oplet.Oplet
Get the input stream data handlers for this oplet.
getInputs() - Method in class org.apache.edgent.runtime.etiao.Invocation
Returns the list of input stream forwarders for this invocation.
getInsertionPolicy() - Method in interface org.apache.edgent.window.Window
Returns the insertion policy of the window.
getInstance() - Method in interface org.apache.edgent.graph.Vertex
Get the instance of the oplet that will be executed.
getInstance() - Method in class org.apache.edgent.runtime.etiao.graph.ExecutableVertex
 
getInvocation() - Method in class org.apache.edgent.runtime.etiao.graph.model.VertexType
 
getInvocationId() - Method in class org.apache.edgent.runtime.etiao.graph.ExecutableVertex
 
getIotDevice(Map<String, String>) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Get an IotDevice for a connected device.
getIotDevice(String) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Get an IotDevice for a connected device.
getIotDevice(Map<String, String>) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
Get an IotDevice for a connected device.
getIotDevice(String) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
getIotDeviceId(Map<String, String>) - Method in interface org.apache.edgent.connectors.iot.IotGateway
Get a deviceId for a device.
getIotDeviceId(Map<String, String>) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
Get a deviceId for a device.
getJob(String) - Method in interface org.apache.edgent.execution.services.JobRegistryService
Returns a job given its identifier.
getJob(String) - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
getJob() - Method in class org.apache.edgent.topology.spi.tester.AbstractTester
 
getJob() - Method in interface org.apache.edgent.topology.tester.Tester
Get the Job reference for the topology submitted by complete().
getJobContext() - Method in interface org.apache.edgent.oplet.OpletContext
Get the job hosting this oplet.
getJobContext() - Method in class org.apache.edgent.runtime.etiao.AbstractContext
 
getJobIds() - Method in interface org.apache.edgent.execution.services.JobRegistryService
Returns a set of all the registered job identifiers.
getJobIds() - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
getJson(TStream<JsonObject>, Supplier<CloseableHttpClient>, Function<JsonObject, String>) - Static method in class org.apache.edgent.connectors.http.HttpStreams
Make an HTTP GET request with JsonObject.
getKeepAliveInterval() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the connection Keep alive interval.
getKey() - Method in interface org.apache.edgent.window.Partition
Returns the key associated with this partition
getKeyFunction() - Method in class org.apache.edgent.topology.spi.graph.AbstractTWindow
 
getKeyFunction() - Method in interface org.apache.edgent.topology.TWindow
Returns the key function used to map tuples to partitions.
getKeyFunction() - Method in interface org.apache.edgent.window.Window
Returns the keyFunction of the window
getKeyStore() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the SSL trust store path.
getKeyStorePassword() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the SSL key store path password.
getLastError() - Method in interface org.apache.edgent.execution.Job
Returns the last error message caught by the current job execution.
getLastError() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Returns the last error message caught by the current job execution.
getLastError() - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
getLastError() - Method in class org.apache.edgent.runtime.etiao.Executable
 
getLastError() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getMbs() - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
Get the MBean server being used by this control service.
getMetric() - Method in class org.apache.edgent.metrics.oplets.CounterOp
 
getMetric() - Method in class org.apache.edgent.metrics.oplets.RateMeter
 
getMetric() - Method in class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet
 
getMetricName() - Method in class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet
Returns the name of the metric used by this oplet for registration.
getMqttConfig() - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Get the device's MqttConfig
getMvAggregate(JsonObject, String, String, JsonUnivariateAggregate) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Get the value of an aggregate computed by a multi-variable aggregation.
getName() - Method in interface org.apache.edgent.execution.Job
Returns the name of this job.
getName() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Returns the name of the job.
getName() - Method in interface org.apache.edgent.oplet.JobContext
Get the name of the job containing this Oplet.
getName() - Method in class org.apache.edgent.providers.iot.IotProvider
Return the name of this provider.
getName() - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
getName() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getName() - Method in interface org.apache.edgent.topology.services.TopologyBuilder
Name the application will be known as.
getName() - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
getName() - Method in interface org.apache.edgent.topology.Topology
Name of this topology.
getNames() - Method in class org.apache.edgent.streamscope.StreamScopeRegistry
Get the registered names.
getNextActiveFilePath() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
getNextState() - Method in interface org.apache.edgent.execution.Job
Retrieves the next execution state when this job makes a state transition.
getNextState() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Retrieves the next execution state when the job makes a state transition.
getNextState() - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
getNextState() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
getOplet() - Method in class org.apache.edgent.runtime.etiao.Invocation
Returns the oplet associated with this Invocation.
getOpletContext() - Method in class org.apache.edgent.oplet.core.AbstractOplet
 
getOutput() - Method in interface org.apache.edgent.connectors.serial.SerialPort
Get the output stream for this serial port.
getOutputContext() - Method in interface org.apache.edgent.oplet.OpletContext
Get the oplet's output port context information.
getOutputContext() - Method in class org.apache.edgent.runtime.etiao.InvocationContext
 
getOutputCount() - Method in interface org.apache.edgent.oplet.OpletContext
Get the number of connected outputs to this oplet.
getOutputCount() - Method in class org.apache.edgent.runtime.etiao.Invocation
Returns the number of outputs for this invocation.
getOutputCount() - Method in class org.apache.edgent.runtime.etiao.InvocationContext
 
getOutputs() - Method in interface org.apache.edgent.oplet.OpletContext
Get the mechanism to submit tuples on an output port.
getOutputs() - Method in class org.apache.edgent.runtime.etiao.InvocationContext
 
getPartitionProcessor() - Method in interface org.apache.edgent.window.Window
Returns the partition processor associated with the window.
getPartitions() - Method in interface org.apache.edgent.window.Window
Retrieves the partitions in the window.
getPassword() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the the password to use for authentication with the server.
getPeeker() - Method in class org.apache.edgent.oplet.functional.Peek
 
getPeriod() - Method in interface org.apache.edgent.execution.mbeans.PeriodMXBean
Get the period.
getPeriod() - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
getPeriodMsec() - Method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
Get the time period configuration value.
getPeriodMsec() - Method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
Get the time period configuration value.
getPeriodMsec() - Method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
Get the time period configuration value.
getPersistence() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the QoS 1 and 2 in-flight message persistence handler.
getPreferences(String) - Static method in class org.apache.edgent.providers.iot.IotProvider
Get the Preferences node that will be used for the IotProvider with the specified name.
getPublishDestination(String, Class<? super T>) - Method in class org.apache.edgent.connectors.pubsub.service.ProviderPubSub
 
getPublishDestination(String, Class<? super T>) - Method in interface org.apache.edgent.connectors.pubsub.service.PublishSubscribeService
Get the destination for a publisher.
getResult() - Method in class org.apache.edgent.analytics.math3.stat.StorelessStatistic
 
getResult() - Method in interface org.apache.edgent.analytics.math3.UnivariateAggregator
Get the aggregation result.
getResult() - Method in interface org.apache.edgent.topology.tester.Condition
 
getRetentionConfig() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
Get the policy's retention configuration
getRunnable() - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
getRunnable() - Method in class org.apache.edgent.oplet.core.ProcessSource
 
getRuntimeServiceSupplier() - Method in class org.apache.edgent.providers.direct.DirectTopology
 
getRuntimeServiceSupplier() - Method in interface org.apache.edgent.topology.Topology
Return a function that at execution time will return a RuntimeServices instance a stream function can use.
getSampleCount() - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Get the number of Samples currently captured
getSampleCount() - Method in class org.apache.edgent.streamscope.StreamScope
Get the number of Samples currently captured
getSampleCount() - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
getSamples() - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Get all captured tuples as JSON.
getSamples() - Method in class org.apache.edgent.streamscope.StreamScope
Get all captured tuples.
getSamples() - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
getScheduledExecutorService() - Method in interface org.apache.edgent.window.Window
Returns the ScheduledExecutorService associated with the window.
getScheduler() - Method in class org.apache.edgent.runtime.etiao.Executable
Returns the ScheduledExecutorService used for running executable graph elements.
getServerURLs() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the MQTT Server URLs
getService(Class<T>) - Method in interface org.apache.edgent.execution.services.RuntimeServices
Get a service for this invocation.
getService(Class<T>) - Method in class org.apache.edgent.execution.services.ServiceContainer
Returns the service to which the specified service class key is mapped, or null if this ServiceContainer contains no service for that key.
getService(Class<T>) - Method in interface org.apache.edgent.oplet.OpletContext
Get a service for this invocation.
getService(Class<T>) - Method in class org.apache.edgent.runtime.etiao.AbstractContext
 
getService(Class<T>) - Method in class org.apache.edgent.runtime.etiao.Executable
Acts as a service provider for executable elements in the graph, first looking for a service specific to this job, and then one from the container.
getServices() - Method in interface org.apache.edgent.execution.DirectSubmitter
Access to services.
getServices() - Method in class org.apache.edgent.providers.direct.DirectProvider
Access to services.
getServices() - Method in class org.apache.edgent.providers.iot.IotProvider
Access to services.
getSinker() - Method in class org.apache.edgent.oplet.core.Sink
Get the sink function that processes each tuple.
getSize() - Method in class org.apache.edgent.topology.spi.graph.TWindowImpl
 
getSource(Function<SerialPort, T>) - Method in interface org.apache.edgent.connectors.serial.SerialDevice
Create a function that can be used to source a stream from a serial port device.
getSource() - Method in interface org.apache.edgent.graph.Edge
Returns the source vertex.
getSource() - Method in class org.apache.edgent.graph.spi.DirectEdge
 
getSourceId() - Method in class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
getSourceOutputPort() - Method in interface org.apache.edgent.graph.Edge
Returns the source output port index.
getSourceOutputPort() - Method in class org.apache.edgent.graph.spi.DirectEdge
 
getSourceOutputPort() - Method in class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
getState(K) - Method in class org.apache.edgent.window.PartitionedState
Get the current state for key.
getStreamScopes() - Method in class org.apache.edgent.streamscope.StreamScopeRegistry
Get registered StreamScopes and the name(s) each is registered with.
getSubscriberIdleReconnectInterval() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the subscriber idle reconnect interval.
getTags() - Method in interface org.apache.edgent.graph.Connector
Returns the set of tags associated with this connector.
getTags() - Method in interface org.apache.edgent.graph.Edge
Returns the set of tags associated with this edge.
getTags() - Method in class org.apache.edgent.graph.spi.DirectEdge
 
getTags() - Method in class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
getTags() - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
getTags() - Method in interface org.apache.edgent.topology.TStream
Returns the set of tags associated with this stream.
getTarget() - Method in interface org.apache.edgent.graph.Edge
Returns the target vertex.
getTarget() - Method in class org.apache.edgent.graph.spi.DirectEdge
 
getTargetId() - Method in class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
getTargetInputPort() - Method in interface org.apache.edgent.graph.Edge
Returns the target input port index.
getTargetInputPort() - Method in class org.apache.edgent.graph.spi.DirectEdge
 
getTargetInputPort() - Method in class org.apache.edgent.runtime.etiao.graph.model.EdgeType
 
getTester() - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
getTester() - Method in interface org.apache.edgent.topology.Topology
Get the tester for this topology.
getTime() - Method in class org.apache.edgent.topology.spi.graph.TWindowTimeImpl
 
getTriggerPolicy() - Method in interface org.apache.edgent.window.Window
Returns the window's trigger policy.
getTrustStore() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the SSL trust store path.
getTrustStorePassword() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the SSL trust store path password.
getTuplePredicate() - Method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
Get the tuple predicate configuration value.
getTuplePredicate() - Method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
Get the tuple predicate configuration value.
getUnit() - Method in interface org.apache.edgent.execution.mbeans.PeriodMXBean
Get the time unit for PeriodMXBean.getPeriod().
getUnit() - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
getUnit() - Method in class org.apache.edgent.topology.spi.graph.TWindowTimeImpl
 
getUserName() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the username to use for authentication with the server.
getVertices() - Method in interface org.apache.edgent.graph.Graph
Return an unmodifiable view of all vertices in this graph.
getVertices() - Method in class org.apache.edgent.runtime.etiao.graph.DirectGraph
 
getVertices() - Method in class org.apache.edgent.runtime.etiao.graph.model.GraphType
 
getWillDestination() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get a Last Will and Testament message's destination topic.
getWillPayload() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get a Last Will and Testament message's payload.
getWillQOS() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get a Last Will and Testament message's QOS.
getWillRetained() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get a Last Will and Testament message's "retained" setting.
getWindow() - Method in interface org.apache.edgent.window.Partition
Return the window in which this partition is contained.
graph() - Method in interface org.apache.edgent.graph.Connector
Gets the Graph for this Connector.
Graph - Interface in org.apache.edgent.graph
A generic directed graph of vertices, connectors and edges.
graph() - Method in interface org.apache.edgent.graph.Vertex
Get the vertice's Graph.
graph() - Method in class org.apache.edgent.providers.direct.DirectTopology
 
graph() - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
graph() - Method in class org.apache.edgent.runtime.etiao.graph.ExecutableVertex
 
graph() - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
graph() - Method in interface org.apache.edgent.topology.Topology
Get the underlying graph.
graphSnapshot() - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Takes a current snapshot of the running graph and returns it in JSON format.
graphSnapshot() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
GraphTopology<X extends Tester> - Class in org.apache.edgent.topology.spi.graph
Topology implementation that provides basic functions for implementing source streams backed by a Graph.
GraphTopology(String) - Constructor for class org.apache.edgent.topology.spi.graph.GraphTopology
 
GraphType - Class in org.apache.edgent.runtime.etiao.graph.model
A generic directed graph of vertices, connectors and edges.
GraphType(Graph) - Constructor for class org.apache.edgent.runtime.etiao.graph.model.GraphType
Create an instance of GraphType.
GraphType(Graph, IdMapper<String>) - Constructor for class org.apache.edgent.runtime.etiao.graph.model.GraphType
Create an instance of GraphType using the specified IdMapper to generate unique object identifiers.
GraphType() - Constructor for class org.apache.edgent.runtime.etiao.graph.model.GraphType
Default constructor of GraphType.
greaterThan(T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range (lowerEndpoint..*) (exclusive/OPEN)

H

handleResults(T, ResultSet, Exception, Consumer<R>) - Method in interface org.apache.edgent.connectors.jdbc.ResultsHandler
Process the ResultSet and add 0 or more tuples to consumer.
hasActiveNonDaemonThreads() - Method in class org.apache.edgent.runtime.etiao.ThreadFactoryTracker
Check to see if there are non daemon user threads that have not yet completed.
hasActiveTasks() - Method in class org.apache.edgent.runtime.etiao.Executable
Check whether there are user tasks still active.
hasActiveTasks() - Method in class org.apache.edgent.runtime.etiao.TrackingScheduledExecutor
Determines whether there are tasks which have started and not completed.
hashCode() - Method in class org.apache.edgent.analytics.sensors.Range
 
hasLowerEndpoint() - Method in class org.apache.edgent.analytics.sensors.Range
 
hasMvAggregate(JsonObject, String, String, JsonUnivariateAggregate) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Check if an aggregation result from a multi-variable aggregation is present.
hasUpperEndpoint() - Method in class org.apache.edgent.analytics.sensors.Range
 
HeartBeat - Class in org.apache.edgent.connectors.iot
An IoT device heartbeat event generator.
hookGenerateFinalFilePath(Path) - Method in class org.apache.edgent.connectors.file.CompressedFileWriterPolicy
 
hookGenerateFinalFilePath(Path) - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
Generate the final file path for the active file.
hookGenerateNextActiveFilePath() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
Generate the path for the next active file.
hookRenameFile(Path, Path) - Method in class org.apache.edgent.connectors.file.CompressedFileWriterPolicy
 
hookRenameFile(Path, Path) - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
"Rename" the active file to the final path.
HttpClients - Class in org.apache.edgent.connectors.http
Creation of HTTP Clients.
HttpClients() - Constructor for class org.apache.edgent.connectors.http.HttpClients
 
httpEvents(TStream<JsonObject>, Function<JsonObject, String>, UnaryOperator<JsonObject>) - Method in class org.apache.edgent.connectors.iotp.IotpDevice
Publish a stream's tuples as device events using the WIoTP HTTP protocol.
httpEvents(TStream<JsonObject>, String) - Method in class org.apache.edgent.connectors.iotp.IotpDevice
Publish a stream's tuples as device events using the WIoTP HTTP protocol.
HttpResponders - Class in org.apache.edgent.connectors.http
Functions to process HTTP requests.
HttpResponders() - Constructor for class org.apache.edgent.connectors.http.HttpResponders
 
HttpStreams - Class in org.apache.edgent.connectors.http
HTTP streams.
HttpStreams() - Constructor for class org.apache.edgent.connectors.http.HttpStreams
 

I

ID_PREFIX - Static variable in class org.apache.edgent.runtime.etiao.EtiaoJob
Prefix used by job unique identifiers.
ID_PREFIX - Static variable in class org.apache.edgent.runtime.etiao.Invocation
Prefix used by oplet unique identifiers.
identity() - Static method in class org.apache.edgent.function.Functions
Returns the identity function that returns its single argument.
increment(double) - Method in interface org.apache.edgent.analytics.math3.json.JsonUnivariateAggregator
Add a value to the aggregation.
increment(double) - Method in class org.apache.edgent.analytics.math3.stat.JsonStorelessStatistic
 
increment(double) - Method in class org.apache.edgent.analytics.math3.stat.StorelessStatistic
 
increment(double) - Method in interface org.apache.edgent.analytics.math3.UnivariateAggregator
Add a value to the aggregation.
initialize(String, Flushable, Closeable) - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
initialize(OpletContext<T, Void>) - Method in class org.apache.edgent.connectors.pubsub.oplets.Publish
 
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet
 
initialize(OpletContext<I, O>) - Method in class org.apache.edgent.oplet.core.AbstractOplet
 
initialize(OpletContext<T, U>) - Method in class org.apache.edgent.oplet.core.FanIn
 
initialize(OpletContext<Void, T>) - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
initialize(OpletContext<I, O>) - Method in class org.apache.edgent.oplet.core.Pipe
 
initialize(OpletContext<Void, T>) - Method in class org.apache.edgent.oplet.core.Source
 
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.oplet.core.Split
 
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.oplet.core.Union
 
initialize(OpletContext<Void, T>) - Method in class org.apache.edgent.oplet.functional.SupplierPeriodicSource
 
initialize(OpletContext<Void, T>) - Method in class org.apache.edgent.oplet.functional.SupplierSource
 
initialize(OpletContext<I, O>) - Method in interface org.apache.edgent.oplet.Oplet
Initialize the oplet.
initialize(OpletContext<T, List<T>>) - Method in class org.apache.edgent.oplet.plumbing.Barrier
 
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.oplet.plumbing.Isolate
 
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.oplet.plumbing.PressureReliever
 
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.oplet.plumbing.UnorderedIsolate
 
initialize(OpletContext<T, U>) - Method in class org.apache.edgent.oplet.window.Aggregate
 
initialize() - Method in class org.apache.edgent.runtime.etiao.Executable
Initializes the invocations.
initialize(JobContext, RuntimeServices) - Method in class org.apache.edgent.runtime.etiao.Invocation
Initialize the invocation.
initialize(OpletContext<T, T>) - Method in class org.apache.edgent.streamscope.oplets.StreamScope
 
inputOn(Integer...) - Static method in class org.apache.edgent.connectors.http.HttpResponders
Return the input tuple on specified codes.
inputOn200() - Static method in class org.apache.edgent.connectors.http.HttpResponders
Return the input tuple on OK.
insert(N, int, int) - Method in interface org.apache.edgent.graph.Graph
Add a new unconnected Vertex into the graph.
insert(OP, int, int) - Method in class org.apache.edgent.runtime.etiao.graph.DirectGraph
 
insert(T) - Method in interface org.apache.edgent.window.Partition
Offers a tuple to be inserted into the partition.
insert(T) - Method in interface org.apache.edgent.window.Window
Attempts to insert the tuple into its partition.
InsertionTimeList<T> - Class in org.apache.edgent.window
A window contents list that maintains insertion time.
InsertionTimeList() - Constructor for class org.apache.edgent.window.InsertionTimeList
 
insertionTimeList() - Static method in class org.apache.edgent.window.Policies
 
inTransition() - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
Invocation<T extends Oplet<I,O>,I,O> - Class in org.apache.edgent.runtime.etiao
An Oplet invocation in the context of the ETIAO runtime.
Invocation(String, T, int, int) - Constructor for class org.apache.edgent.runtime.etiao.Invocation
 
InvocationContext<I,O> - Class in org.apache.edgent.runtime.etiao
Context information for the Oplet's execution context.
InvocationContext(String, JobContext, RuntimeServices, int, List<? extends Consumer<O>>, List<OutputPortContext>) - Constructor for class org.apache.edgent.runtime.etiao.InvocationContext
Creates an InvocationContext with the specified parameters.
InvocationType<I,O> - Class in org.apache.edgent.runtime.etiao.graph.model
Generic type for an oplet invocation instance.
InvocationType(Oplet<I, O>) - Constructor for class org.apache.edgent.runtime.etiao.graph.model.InvocationType
 
IOT_START - Static variable in interface org.apache.edgent.connectors.iot.Events
An IotProvider has started.
IotDevice - Interface in org.apache.edgent.connectors.iot
A generic IoT device IoT hub connector.
IotDevicePubSub - Class in org.apache.edgent.apps.iot
Application sharing an IotDevice through publish-subscribe.
IotDevicePubSub() - Constructor for class org.apache.edgent.apps.iot.IotDevicePubSub
 
IotGateway - Interface in org.apache.edgent.connectors.iot
A generic IoT gateway device IoT hub connector.
IotpDevice - Class in org.apache.edgent.connectors.iotp
A Device Connector to IBM Watson IoT Platform (WIoTP).
IotpDevice(Topology, Properties) - Constructor for class org.apache.edgent.connectors.iotp.IotpDevice
Create a connector for the IoT device specified by options.
IotpDevice(Topology, File) - Constructor for class org.apache.edgent.connectors.iotp.IotpDevice
Create a connector for the IoT device specified by optionsFile.
IotpDevice(Topology, DeviceClient) - Constructor for class org.apache.edgent.connectors.iotp.IotpDevice
Create a connector using the supplied WIoTP DeviceClient.
IotpGateway - Class in org.apache.edgent.connectors.iotp
An IoT Gateway Device Connector to IBM Watson IoT Platform (WIoTP).
IotpGateway(Topology, Properties) - Constructor for class org.apache.edgent.connectors.iotp.IotpGateway
Create a connector for the IoT gateway device specified by options.
IotpGateway(Topology, File) - Constructor for class org.apache.edgent.connectors.iotp.IotpGateway
Create a connector for the IoT gateway device specified by optionsFile.
IotpGateway(Topology, GatewayClient) - Constructor for class org.apache.edgent.connectors.iotp.IotpGateway
Create a connector using the supplied WIoTP DeviceClient.
IotProvider - Class in org.apache.edgent.providers.iot
A provider that supports sharing of a single connection to an IoT message hub and access to control MBeans via IoT device commands.
IotProvider(Function<Topology, IotDevice>) - Constructor for class org.apache.edgent.providers.iot.IotProvider
Create an IotProvider that uses its own DirectProvider.
IotProvider(String, Function<Topology, IotDevice>) - Constructor for class org.apache.edgent.providers.iot.IotProvider
Create an IotProvider that uses its own DirectProvider.
IotProvider(String, DirectProvider, Function<Topology, IotDevice>) - Constructor for class org.apache.edgent.providers.iot.IotProvider
Create an IotProvider that uses the passed in DirectProvider.
IotProvider(String, TopologyProvider, DirectSubmitter<Topology, Job>, Function<Topology, IotDevice>) - Constructor for class org.apache.edgent.providers.iot.IotProvider
Create an IotProvider.
isCleanSession() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Get the clean session setting.
isConnected() - Method in interface org.apache.edgent.graph.Connector
Was connect() called on this connector?
isControlServiceMBean(Class<?>) - Static method in class org.apache.edgent.execution.services.Controls
Test to see if an interface represents a valid control service MBean.
isEnabled() - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Is tuple capture enabled?
isEnabled() - Method in class org.apache.edgent.streamscope.StreamScope
Is tuple capture enabled?
isEnabled() - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
isImmutable(Object) - Static method in class org.apache.edgent.function.Functions
See if the functional logic is immutable.
isImmutableClass(Class<?>) - Static method in class org.apache.edgent.function.Functions
See if a function class is immutable.
Isolate<T> - Class in org.apache.edgent.oplet.plumbing
Isolate upstream processing from downstream processing guaranteeing tuple order.
Isolate() - Constructor for class org.apache.edgent.oplet.plumbing.Isolate
Create a new Isolate oplet.
Isolate(int) - Constructor for class org.apache.edgent.oplet.plumbing.Isolate
Create a new Isolate oplet.
isolate(TStream<T>, boolean) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Isolate upstream processing from downstream processing.
isolate(TStream<T>, int) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Isolate upstream processing from downstream processing.
isOpen() - Method in class org.apache.edgent.topology.plumbing.Valve
Get the valve state
isPaused() - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Is capture paused?
isPaused() - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
Is capture paused?
isPaused() - Method in class org.apache.edgent.streamscope.StreamScopeBean
 

J

JdbcStreams - Class in org.apache.edgent.connectors.jdbc
JdbcStreams is a streams connector to a database via the JDBC API java.sql package.
JdbcStreams(Topology, CheckedSupplier<DataSource>, CheckedFunction<DataSource, Connection>) - Constructor for class org.apache.edgent.connectors.jdbc.JdbcStreams
Create a connector that uses a JDBC DataSource object to get a database connection.
JMX_DOMAIN - Static variable in class org.apache.edgent.providers.development.DevelopmentProvider
JMX domains that this provider uses to register MBeans.
JMXControlService - Class in org.apache.edgent.runtime.jmxcontrol
Control service that registers control objects as MBeans in a JMX server.
JMXControlService(String, Hashtable<String, String>) - Constructor for class org.apache.edgent.runtime.jmxcontrol.JMXControlService
JMX control service using the platform MBean server.
Job - Interface in org.apache.edgent.execution
Actions and states for execution of an Edgent job.
Job.Action - Enum in org.apache.edgent.execution
Actions which trigger Job.State transitions.
Job.Health - Enum in org.apache.edgent.execution
Enumeration for the summarized health indicator of the graph nodes.
Job.State - Enum in org.apache.edgent.execution
States of a graph job.
JOB_HOLD_AFTER_CLOSE_SECS - Static variable in class org.apache.edgent.execution.services.Controls
Number of seconds a JobMXBean control is held registered with the ControlService after a job gets closed.
JOB_NAME - Static variable in interface org.apache.edgent.execution.Configs
JOB_NAME is used to identify the submission configuration property containing the job name.
JobContext - Interface in org.apache.edgent.oplet
Information about an oplet invocation's job.
JobEvents - Class in org.apache.edgent.runtime.jobregistry
A source of job event tuples.
JobEvents() - Constructor for class org.apache.edgent.runtime.jobregistry.JobEvents
 
JobMonitorApp - Class in org.apache.edgent.apps.runtime
Job monitoring application.
JobMonitorApp(TopologyProvider, DirectSubmitter<Topology, Job>, String) - Constructor for class org.apache.edgent.apps.runtime.JobMonitorApp
Constructs a JobMonitorApp with the specified name in the context of the specified provider.
JobMXBean - Interface in org.apache.edgent.execution.mbeans
Control interface for a job.
JobRegistry - Class in org.apache.edgent.runtime.jobregistry
Maintains a set of registered jobs and a set of listeners.
JobRegistry() - Constructor for class org.apache.edgent.runtime.jobregistry.JobRegistry
Creates a new JobRegistry.
JobRegistryService - Interface in org.apache.edgent.execution.services
Job registry service.
JobRegistryService.EventType - Enum in org.apache.edgent.execution.services
Job event types.
join(Function<T, K>, TWindow<U, K>, BiFunction<T, List<U>, J>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
join(Function<T, K>, TWindow<U, K>, BiFunction<T, List<U>, J>) - Method in interface org.apache.edgent.topology.TStream
Join this stream with a partitioned window of type U with key type K.
joinLast(Function<T, K>, TStream<U>, Function<U, K>, BiFunction<T, U, J>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
joinLast(Function<T, K>, TStream<U>, Function<U, K>, BiFunction<T, U, J>) - Method in interface org.apache.edgent.topology.TStream
Join this stream with the last tuple seen on a stream of type U with partitioning.
json() - Static method in class org.apache.edgent.connectors.http.HttpResponders
A HTTP response handler for application/json.
JsonAnalytics - Class in org.apache.edgent.analytics.math3.json
Apache Common Math analytics for streams with JSON tuples.
JsonAnalytics() - Constructor for class org.apache.edgent.analytics.math3.json.JsonAnalytics
 
JsonControlService - Class in org.apache.edgent.runtime.jsoncontrol
Control service that accepts control instructions as JSON objects.
JsonControlService() - Constructor for class org.apache.edgent.runtime.jsoncontrol.JsonControlService
 
JsonFunctions - Class in org.apache.edgent.topology.json
Utilities for use of JSON and Json Objects in a streaming topology.
JsonFunctions() - Constructor for class org.apache.edgent.topology.json.JsonFunctions
 
JsonStorelessStatistic - Class in org.apache.edgent.analytics.math3.stat
JSON univariate aggregator implementation wrapping a StorelessUnivariateStatistic.
JsonStorelessStatistic(Statistic, StorelessUnivariateStatistic) - Constructor for class org.apache.edgent.analytics.math3.stat.JsonStorelessStatistic
 
JsonUnivariateAggregate - Interface in org.apache.edgent.analytics.math3.json
Univariate aggregate for a JSON tuple.
JsonUnivariateAggregator - Interface in org.apache.edgent.analytics.math3.json
Univariate aggregator for JSON tuples.
Jsr356WebSocketClient - Class in org.apache.edgent.connectors.wsclient.javax.websocket
A connector for sending and receiving messages to a WebSocket Server.
Jsr356WebSocketClient(Topology, Properties) - Constructor for class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Create a new Web Socket Client connector.
Jsr356WebSocketClient(Topology, Properties, Supplier<WebSocketContainer>) - Constructor for class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Create a new Web Socket Client connector.

K

KafkaConsumer - Class in org.apache.edgent.connectors.kafka
KafkaConsumer is a connector for creating a stream of tuples by subscribing to Apache Kafka messaging system topics.
KafkaConsumer(Topology, Supplier<Map<String, Object>>) - Constructor for class org.apache.edgent.connectors.kafka.KafkaConsumer
Create a consumer connector for subscribing to Kafka topics and creating tuples from the received messages.
KafkaConsumer.ByteConsumerRecord - Interface in org.apache.edgent.connectors.kafka
A Kafka record with byte[] typed key and value members
KafkaConsumer.ConsumerRecord<K,V> - Interface in org.apache.edgent.connectors.kafka
A received Kafka record
KafkaConsumer.StringConsumerRecord - Interface in org.apache.edgent.connectors.kafka
A Kafka record with String typed key and value members
KafkaProducer - Class in org.apache.edgent.connectors.kafka
KafkaProducer is a connector for publishing a stream of tuples to Apache Kafka messaging system topics.
KafkaProducer(Topology, Supplier<Map<String, Object>>) - Constructor for class org.apache.edgent.connectors.kafka.KafkaProducer
Create a producer connector for publishing tuples to Kafka topics.s
key() - Method in interface org.apache.edgent.connectors.kafka.KafkaConsumer.ConsumerRecord
 
KEY_JOBID - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
The jobId property key.
KEY_NAME - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
The name property key.
KEY_OPID - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
The opId (oplet id) property key.
KEY_TYPE - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
The type property key.

L

last(int, Function<T, K>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
last(long, TimeUnit, Function<T, K>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
last(int, Function<T, K>) - Method in interface org.apache.edgent.topology.TStream
Declare a partitioned window that continually represents the last count tuples on this stream for each partition.
last(long, TimeUnit, Function<T, K>) - Method in interface org.apache.edgent.topology.TStream
Declare a partitioned window that continually represents the last time seconds of tuples on this stream for each partition.
lastNProcessOnInsert(int, Function<T, K>) - Static method in class org.apache.edgent.window.Windows
Return a window that maintains the last count tuples inserted with processing triggered on every insert.
lessThan(T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range (*..upperEndpoint) (exclusive/OPEN)
listIterator(int) - Method in class org.apache.edgent.window.InsertionTimeList
 
LoadBalancedSplitter<T> - Class in org.apache.edgent.topology.plumbing
A Load Balanced Splitter function.
LoadBalancedSplitter(int) - Constructor for class org.apache.edgent.topology.plumbing.LoadBalancedSplitter
Create a new splitter.
lookup(String, String, int) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeRegistryMXBean
Get the StreamScopeMXBean registered for the specified stream
lookup(String) - Method in class org.apache.edgent.streamscope.StreamScopeRegistry
Lookup a StreamScope
lookup(String, String, int) - Method in class org.apache.edgent.streamscope.StreamScopeRegistryBean
 
lowerBoundType() - Method in class org.apache.edgent.analytics.sensors.Range
Get the BoundType for the lowerEndpoint.
lowerEndpoint() - Method in class org.apache.edgent.analytics.sensors.Range
Get the range's lower endpoint.

M

Map<I,O> - Class in org.apache.edgent.oplet.functional
Map an input tuple to 0-1 output tuple
Map(Function<I, O>) - Constructor for class org.apache.edgent.oplet.functional.Map
 
map(Function<T, U>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
map(Function<T, U>) - Method in interface org.apache.edgent.topology.TStream
Declare a new stream that maps (or transforms) each tuple from this stream into one (or zero) tuple of a different type U.
METRIC_NAME - Static variable in class org.apache.edgent.metrics.oplets.CounterOp
 
METRIC_NAME - Static variable in class org.apache.edgent.metrics.oplets.RateMeter
 
MetricObjectNameFactory - Class in org.apache.edgent.metrics
A factory of metric ObjectName instances.
MetricObjectNameFactory() - Constructor for class org.apache.edgent.metrics.MetricObjectNameFactory
 
Metrics - Class in org.apache.edgent.metrics
This interface contains utility methods for manipulating metrics.
Metrics() - Constructor for class org.apache.edgent.metrics.Metrics
 
MetricsSetup - Class in org.apache.edgent.metrics
Utility helpers for configuring and starting a Metric JmxReporter or a ConsoleReporter.
mkAggregationSpec(String, JsonUnivariateAggregate...) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Create an aggregation specification.
mkStreamId(String, String, int) - Static method in class org.apache.edgent.streamscope.StreamScopeRegistry
Make a streamId for the specified stream.
modify(UnaryOperator<T>) - Method in class org.apache.edgent.topology.spi.AbstractTStream
Declare a new stream that modifies each tuple from this stream into one (or zero) tuple of the same type T.
modify(UnaryOperator<T>) - Method in interface org.apache.edgent.topology.TStream
Declare a new stream that modifies each tuple from this stream into one (or zero) tuple of the same type T.
MqttConfig - Class in org.apache.edgent.connectors.mqtt
MQTT broker connector configuration.
MqttConfig() - Constructor for class org.apache.edgent.connectors.mqtt.MqttConfig
Create a new configuration.
MqttConfig(String, String) - Constructor for class org.apache.edgent.connectors.mqtt.MqttConfig
Create a new configuration.
MqttDevice - Class in org.apache.edgent.connectors.mqtt.iot
An MQTT based Edgent IotDevice connector.
MqttDevice(Topology, Properties) - Constructor for class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Create an MqttDevice connector.
MqttDevice(Topology, Properties, MqttConfig) - Constructor for class org.apache.edgent.connectors.mqtt.iot.MqttDevice
Create an MqttDevice connector.
MqttStreams - Class in org.apache.edgent.connectors.mqtt
MqttStreams is a connector to a MQTT messaging broker for publishing and subscribing to topics.
MqttStreams(Topology, String, String) - Constructor for class org.apache.edgent.connectors.mqtt.MqttStreams
Create a connector to the specified server.
MqttStreams(Topology, Supplier<MqttConfig>) - Constructor for class org.apache.edgent.connectors.mqtt.MqttStreams
Create a connector with the specified configuration.
mvAggregate(TWindow<JsonObject, K>, String, String, List<Pair<String, JsonUnivariateAggregate[]>>) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Aggregate against multiple Numeric variables contained in an JSON object.
mvAggregateList(String, String, List<Pair<String, JsonUnivariateAggregate[]>>) - Static method in class org.apache.edgent.analytics.math3.json.JsonAnalytics
Create a Function that aggregates multiple Numeric variables contained in an JSON object.
MvResultMap - Class in org.apache.edgent.analytics.math3
Aggregation results for multiple aggregated variables.
MvResultMap() - Constructor for class org.apache.edgent.analytics.math3.MvResultMap
Create a new MvResultMap.

N

N - Static variable in interface org.apache.edgent.analytics.math3.json.JsonUnivariateAggregate
JSON key used for representation of the number of tuples that were aggregated.
name() - Method in interface org.apache.edgent.analytics.math3.json.JsonUnivariateAggregate
Name of the aggregate.
name() - Method in interface org.apache.edgent.analytics.math3.UnivariateAggregate
Name of the aggregate.
nameForStreamAlias(String) - Static method in class org.apache.edgent.streamscope.StreamScopeRegistry
create a registration name for a stream alias
nameForStreamId(String) - Static method in class org.apache.edgent.streamscope.StreamScopeRegistry
Create a registration name for a stream id.
nanoTime() - Method in class org.apache.edgent.streamscope.StreamScope.Sample
Capture time in nanoTime.
newAgeBasedConfig(long, long) - Static method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
same as newConfig(0, 0, ageSe, periodMsecc)
newAggregateFileSizeBasedConfig(long) - Static method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
same as newConfig(0, aggregateFileSize, 0, 0)
newConfig(long, int, long, Predicate<T>) - Static method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
Create a new configuration.
newConfig(int, long, Predicate<T>) - Static method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
Create a new configuration.
newConfig(int, long, long, long) - Static method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
Create a new configuration.
newCountBasedConfig(int) - Static method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
same as newConfig(0, cntTuples, 0, null)
newCountBasedConfig(int) - Static method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
same as newConfig(cntTuples, 0, null)
newFileCountBasedConfig(int) - Static method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
same as newConfig(fileCount, 0, 0, 0)
newFileSizeBasedConfig(long) - Static method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
same as newConfig(fileSize, 0, 0, null)
newImplicitConfig() - Static method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
Create a new configuration.
newPredicateBasedConfig(Predicate<T>) - Static method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
same as newConfig(0, 0, 0, tuplePredicate)
newPredicateBasedConfig(Predicate<T>) - Static method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
same as newConfig(0, 0, tuplePredicate)
newScheduler(ThreadFactory, BiConsumer<Object, Throwable>) - Static method in class org.apache.edgent.runtime.etiao.TrackingScheduledExecutor
Creates an TrackingScheduledExecutor using the supplied thread factory and a completion handler.
newTester() - Method in class org.apache.edgent.providers.direct.DirectTopology
 
newTester() - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
newThread(Runnable) - Method in class org.apache.edgent.runtime.etiao.ThreadFactoryTracker
Return a thread.
newTimeBasedConfig(long) - Static method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
same as newConfig(0, 0, periodMsec, null)
newTimeBasedConfig(long) - Static method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
same as newConfig(0, periodMsec, null)
newTopology(String) - Method in class org.apache.edgent.providers.direct.DirectProvider
 
newTopology() - Method in class org.apache.edgent.providers.iot.IotProvider
Create a new topology with a generated name.
newTopology(String) - Method in class org.apache.edgent.providers.iot.IotProvider
Create a new topology with a given name.
newTopology(String) - Method in class org.apache.edgent.topology.spi.AbstractTopologyProvider
 
newTopology() - Method in class org.apache.edgent.topology.spi.AbstractTopologyProvider
 
newTopology(String) - Method in interface org.apache.edgent.topology.TopologyProvider
Create a new topology with a given name.
newTopology() - Method in interface org.apache.edgent.topology.TopologyProvider
Create a new topology with a generated name.
noAuthentication() - Static method in class org.apache.edgent.connectors.http.HttpClients
Create HTTP client with no authentication.

O

of(T...) - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
of(T...) - Method in interface org.apache.edgent.topology.Topology
Declare a stream of objects.
offset() - Method in interface org.apache.edgent.connectors.kafka.KafkaConsumer.ConsumerRecord
 
OP_KEY - Static variable in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
Key for the operation name.
open(T, T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range (lowerEndpoint..upperEndpoint) (both exclusive/OPEN)
openClosed(T, T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range (lowerEndpoint..upperEndpoint] (exclusive/OPEN,inclusive/CLOSED)
Oplet<I,O> - Interface in org.apache.edgent.oplet
Generic API for an oplet that processes streaming data on 0-N input ports and produces 0-M output streams on its output ports.
OpletContext<I,O> - Interface in org.apache.edgent.oplet
Context information for the Oplet's invocation context.
options() - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
INTERNAL USE ONLY.
org.apache.edgent.analytics.math3 - package org.apache.edgent.analytics.math3
Analytics using Apache Commons Math.
org.apache.edgent.analytics.math3.json - package org.apache.edgent.analytics.math3.json
JSON analytics using Apache Commons Math.
org.apache.edgent.analytics.math3.stat - package org.apache.edgent.analytics.math3.stat
Statistical algorithms using Apache Commons Math.
org.apache.edgent.analytics.sensors - package org.apache.edgent.analytics.sensors
Analytics focused on handling sensor data.
org.apache.edgent.apps.iot - package org.apache.edgent.apps.iot
Applications for use in an Internet of Things environment.
org.apache.edgent.apps.runtime - package org.apache.edgent.apps.runtime
Applications which provide monitoring and failure recovery to other Edgent applications.
org.apache.edgent.connectors.command - package org.apache.edgent.connectors.command
Command / OS Process connector.
org.apache.edgent.connectors.csv - package org.apache.edgent.connectors.csv
Utilities for handling Comma Separated Value strings.
org.apache.edgent.connectors.file - package org.apache.edgent.connectors.file
File stream connector.
org.apache.edgent.connectors.http - package org.apache.edgent.connectors.http
HTTP stream connector.
org.apache.edgent.connectors.iot - package org.apache.edgent.connectors.iot
Edgent IoT device and IoT Gateway device connector API to an IoT message hub.
org.apache.edgent.connectors.iotp - package org.apache.edgent.connectors.iotp
IBM Watson IoT Platform stream connector.
org.apache.edgent.connectors.jdbc - package org.apache.edgent.connectors.jdbc
JDBC based database stream connector.
org.apache.edgent.connectors.kafka - package org.apache.edgent.connectors.kafka
Apache Kafka enterprise messaging hub stream connector.
org.apache.edgent.connectors.mqtt - package org.apache.edgent.connectors.mqtt
MQTT (lightweight messaging protocol for small sensors and mobile devices) stream connector.
org.apache.edgent.connectors.mqtt.iot - package org.apache.edgent.connectors.mqtt.iot
An MQTT based IotDevice connector.
org.apache.edgent.connectors.pubsub - package org.apache.edgent.connectors.pubsub
Publish subscribe model between jobs.
org.apache.edgent.connectors.pubsub.oplets - package org.apache.edgent.connectors.pubsub.oplets
Oplets supporting publish subscribe service.
org.apache.edgent.connectors.pubsub.service - package org.apache.edgent.connectors.pubsub.service
Publish subscribe service.
org.apache.edgent.connectors.serial - package org.apache.edgent.connectors.serial
Serial port connector API.
org.apache.edgent.connectors.wsclient - package org.apache.edgent.connectors.wsclient
A generic WebSocket Client Connector API for sending and receiving messages to a WebSocket Server.
org.apache.edgent.connectors.wsclient.javax.websocket - package org.apache.edgent.connectors.wsclient.javax.websocket
A JSR356 based WebSocket Client Connector for sending and receiving messages to a WebSocket Server.
org.apache.edgent.execution - package org.apache.edgent.execution
Execution of Edgent topologies and graphs.
org.apache.edgent.execution.mbeans - package org.apache.edgent.execution.mbeans
Management MBeans for execution.
org.apache.edgent.execution.services - package org.apache.edgent.execution.services
Execution services.
org.apache.edgent.function - package org.apache.edgent.function
Functional interfaces for lambda expressions.
org.apache.edgent.graph - package org.apache.edgent.graph
Low-level graph building API.
org.apache.edgent.graph.spi - package org.apache.edgent.graph.spi
 
org.apache.edgent.graph.spi.execution - package org.apache.edgent.graph.spi.execution
 
org.apache.edgent.metrics - package org.apache.edgent.metrics
Metric utility methods, oplets, and reporters which allow an application to expose metric values, for example via JMX.
org.apache.edgent.metrics.oplets - package org.apache.edgent.metrics.oplets
 
org.apache.edgent.oplet - package org.apache.edgent.oplet
Oplets API.
org.apache.edgent.oplet.core - package org.apache.edgent.oplet.core
Core primitive oplets.
org.apache.edgent.oplet.functional - package org.apache.edgent.oplet.functional
Oplets that process tuples using functions.
org.apache.edgent.oplet.plumbing - package org.apache.edgent.oplet.plumbing
Oplets that control the flow of tuples.
org.apache.edgent.oplet.window - package org.apache.edgent.oplet.window
Oplets using windows.
org.apache.edgent.providers.development - package org.apache.edgent.providers.development
Execution of a streaming topology in a development environment .
org.apache.edgent.providers.direct - package org.apache.edgent.providers.direct
Direct execution of a streaming topology.
org.apache.edgent.providers.iot - package org.apache.edgent.providers.iot
Iot provider that allows multiple applications to share an IotDevice.
org.apache.edgent.runtime.appservice - package org.apache.edgent.runtime.appservice
 
org.apache.edgent.runtime.etiao - package org.apache.edgent.runtime.etiao
A runtime for executing an Edgent streaming topology, designed as an embeddable library so that it can be executed in a simple Java application.
org.apache.edgent.runtime.etiao.graph - package org.apache.edgent.runtime.etiao.graph
 
org.apache.edgent.runtime.etiao.graph.model - package org.apache.edgent.runtime.etiao.graph.model
 
org.apache.edgent.runtime.etiao.mbeans - package org.apache.edgent.runtime.etiao.mbeans
 
org.apache.edgent.runtime.jmxcontrol - package org.apache.edgent.runtime.jmxcontrol
 
org.apache.edgent.runtime.jobregistry - package org.apache.edgent.runtime.jobregistry
 
org.apache.edgent.runtime.jsoncontrol - package org.apache.edgent.runtime.jsoncontrol
Control service that takes a Json message and invokes an operation on a control service MBean.
org.apache.edgent.streamscope - package org.apache.edgent.streamscope
Stream Oscilloscope - package for instrumenting streams to capture tuples.
org.apache.edgent.streamscope.mbeans - package org.apache.edgent.streamscope.mbeans
Stream Oscilloscope ControlService Management Bean interfaces.
org.apache.edgent.streamscope.oplets - package org.apache.edgent.streamscope.oplets
Stream Oscilloscope underlying implementation oplets.
org.apache.edgent.topology - package org.apache.edgent.topology
Functional api to build a streaming topology.
org.apache.edgent.topology.json - package org.apache.edgent.topology.json
Utilities for use of JSON in a streaming topology.
org.apache.edgent.topology.mbeans - package org.apache.edgent.topology.mbeans
Controls for executing topologies.
org.apache.edgent.topology.plumbing - package org.apache.edgent.topology.plumbing
Plumbing for a streaming topology.
org.apache.edgent.topology.services - package org.apache.edgent.topology.services
Services for topologies.
org.apache.edgent.topology.spi - package org.apache.edgent.topology.spi
 
org.apache.edgent.topology.spi.functions - package org.apache.edgent.topology.spi.functions
 
org.apache.edgent.topology.spi.graph - package org.apache.edgent.topology.spi.graph
 
org.apache.edgent.topology.spi.tester - package org.apache.edgent.topology.spi.tester
 
org.apache.edgent.topology.tester - package org.apache.edgent.topology.tester
Testing for a streaming topology.
org.apache.edgent.window - package org.apache.edgent.window
Window API.
OutputPortContext - Interface in org.apache.edgent.oplet
Information about an oplet output port.
outsideOf(Range<T>) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Predicate whose test(v) behaves like ! range.test(v)

P

parallel(TStream<T>, int, ToIntFunction<T>, BiFunction<TStream<T>, Integer, TStream<R>>) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Perform an analytic pipeline on tuples in parallel.
parallelBalanced(TStream<T>, int, BiFunction<TStream<T>, Integer, TStream<R>>) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Perform an analytic pipeline on tuples in parallel.
parallelMap(TStream<T>, int, ToIntFunction<T>, BiFunction<T, Integer, U>) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Perform an analytic function on tuples in parallel.
ParameterSetter<T> - Interface in org.apache.edgent.connectors.jdbc
Function that sets parameters in a JDBC SQL PreparedStatement.
parseCsv(String) - Static method in class org.apache.edgent.connectors.csv.Csv
Parse a CSV string into its fields using comma for the field separator.
parseCsv(String, char) - Static method in class org.apache.edgent.connectors.csv.Csv
Parse a CSV string into its fields using the specified field separator.
partition() - Method in interface org.apache.edgent.connectors.kafka.KafkaConsumer.ConsumerRecord
 
Partition<T,K,L extends List<T>> - Interface in org.apache.edgent.window
A partition within a Window.
PartitionedState<K,S> - Class in org.apache.edgent.window
Maintain partitioned state.
PartitionedState(Supplier<S>) - Constructor for class org.apache.edgent.window.PartitionedState
Construct with an initial state function.
peek(N) - Method in interface org.apache.edgent.graph.Connector
Inserts a Peek oplet between an output port and its connections.
peek(T) - Method in class org.apache.edgent.metrics.oplets.CounterOp
 
peek(T) - Method in class org.apache.edgent.metrics.oplets.RateMeter
 
Peek<T> - Class in org.apache.edgent.oplet.core
Oplet that allows a peek at each tuple and always forwards a tuple onto its single output port.
Peek() - Constructor for class org.apache.edgent.oplet.core.Peek
 
peek(T) - Method in class org.apache.edgent.oplet.core.Peek
 
Peek<T> - Class in org.apache.edgent.oplet.functional
Functional peek oplet.
Peek(Consumer<T>) - Constructor for class org.apache.edgent.oplet.functional.Peek
Peek oplet using a function to peek.
peek(T) - Method in class org.apache.edgent.oplet.functional.Peek
 
peek(Consumer<T>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
peek(Consumer<T>) - Method in interface org.apache.edgent.topology.TStream
Declare a stream that contains the same contents as this stream while peeking at each element using peeker.
peekAll(Supplier<? extends Peek<?>>, Predicate<Vertex<?, ?, ?>>) - Method in interface org.apache.edgent.graph.Graph
Insert Peek oplets returned by the specified Supplier into the outputs of all of the oplets which satisfy the specified Predicate and where the output's Connector.isConnected() is true.
peekAll(Supplier<? extends Peek<?>>, Predicate<Vertex<?, ?, ?>>) - Method in class org.apache.edgent.graph.spi.AbstractGraph
 
periodicSource(Topology, ProcessBuilder, long, TimeUnit) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Create a TStream<String> from a periodically run command's output.
PeriodicSource<T> - Class in org.apache.edgent.oplet.core
 
PeriodicSource(long, TimeUnit) - Constructor for class org.apache.edgent.oplet.core.PeriodicSource
 
PeriodMXBean - Interface in org.apache.edgent.execution.mbeans
Control mbean interface for an entity having an a time period control.
pipe(Connector<C>, N) - Method in interface org.apache.edgent.graph.Graph
Create a new connected Vertex associated with the specified Oplet.
pipe(Connector<C>, N) - Method in class org.apache.edgent.graph.spi.AbstractGraph
 
Pipe<I,O> - Class in org.apache.edgent.oplet.core
Pipe oplet with a single input and output.
Pipe() - Constructor for class org.apache.edgent.oplet.core.Pipe
 
pipe(Pipe<T, U>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
pipe(Pipe<T, U>) - Method in interface org.apache.edgent.topology.TStream
Declare a stream that contains the output of the specified Pipe oplet applied to this stream.
PlumbingStreams - Class in org.apache.edgent.topology.plumbing
Plumbing utilities for TStream.
PlumbingStreams() - Constructor for class org.apache.edgent.topology.plumbing.PlumbingStreams
 
Policies - Class in org.apache.edgent.window
Common window policies.
Policies() - Constructor for class org.apache.edgent.window.Policies
 
poll(Supplier<T>, long, TimeUnit) - Method in class org.apache.edgent.topology.spi.graph.GraphTopology
 
poll(Supplier<T>, long, TimeUnit) - Method in interface org.apache.edgent.topology.Topology
Declare a new source stream that calls data.get() periodically.
postJson(TStream<JsonObject>, Supplier<CloseableHttpClient>, Function<JsonObject, String>, UnaryOperator<JsonObject>) - Static method in class org.apache.edgent.connectors.http.HttpStreams
Make an HTTP POST request with JsonObject.
Predicate<T> - Interface in org.apache.edgent.function
Predicate function.
PREFIX_JOBID - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
The prefix of the job id as serialized in the metric name.
PREFIX_OPID - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
The prefix of the oplet id as serialized in the metric name.
PressureReliever<T,K> - Class in org.apache.edgent.oplet.plumbing
Relieve pressure on upstream oplets by discarding tuples.
PressureReliever(int, Function<T, K>) - Constructor for class org.apache.edgent.oplet.plumbing.PressureReliever
Pressure reliever that maintains up to count most recent tuples per key.
pressureReliever(TStream<T>, Function<T, K>, int) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
Relieve pressure on upstream processing by discarding tuples.
print() - Method in class org.apache.edgent.topology.spi.AbstractTStream
Utility method to print the contents of this stream to System.out at runtime.
print() - Method in interface org.apache.edgent.topology.TStream
Utility method to print the contents of this stream to System.out at runtime.
process() - Method in class org.apache.edgent.oplet.core.ProcessSource
 
process() - Method in class org.apache.edgent.oplet.functional.SupplierSource
 
process() - Method in interface org.apache.edgent.window.Partition
Invoke the WindowProcessor's processWindow method.
processOnInsert() - Static method in class org.apache.edgent.window.Policies
Returns a trigger policy that triggers processing on every insert.
ProcessSource<T> - Class in org.apache.edgent.oplet.core
 
ProcessSource() - Constructor for class org.apache.edgent.oplet.core.ProcessSource
 
processWhenFullAndEvict(int) - Static method in class org.apache.edgent.window.Policies
Returns a trigger policy that triggers when the size of a partition equals or exceeds a value, and then evicts its contents.
ProviderPubSub - Class in org.apache.edgent.connectors.pubsub.service
Publish subscribe service allowing exchange of streams between jobs in a provider.
ProviderPubSub() - Constructor for class org.apache.edgent.connectors.pubsub.service.ProviderPubSub
 
publish(TStream<T>, Function<T, String>, Function<T, String>, Function<T, String>, Function<T, Integer>) - Method in class org.apache.edgent.connectors.kafka.KafkaProducer
Publish the stream of tuples as Kafka key/value records to the specified partitions of the specified topics.
publish(TStream<String>, String) - Method in class org.apache.edgent.connectors.kafka.KafkaProducer
Publish the stream of tuples as Kafka key/value records to the specified partitions of the specified topics.
publish(TStream<T>, Function<T, String>, Function<T, byte[]>, Function<T, Integer>, Function<T, Boolean>) - Method in class org.apache.edgent.connectors.mqtt.MqttStreams
Publish a stream's tuples as MQTT messages.
publish(TStream<String>, String, int, boolean) - Method in class org.apache.edgent.connectors.mqtt.MqttStreams
Publish a TStream<String> stream's tuples as MQTT messages.
Publish<T> - Class in org.apache.edgent.connectors.pubsub.oplets
Publish a stream to a PublishSubscribeService service.
Publish(String, Class<? super T>) - Constructor for class org.apache.edgent.connectors.pubsub.oplets.Publish
 
publish(TStream<T>, String, Class<? super T>) - Static method in class org.apache.edgent.connectors.pubsub.PublishSubscribe
Publish this stream to a topic.
publishBytes(TStream<T>, Function<T, byte[]>, Function<T, byte[]>, Function<T, String>, Function<T, Integer>) - Method in class org.apache.edgent.connectors.kafka.KafkaProducer
Publish the stream of tuples as Kafka key/value records to the specified topic partitions.
PublishSubscribe - Class in org.apache.edgent.connectors.pubsub
Publish subscribe model.
PublishSubscribe() - Constructor for class org.apache.edgent.connectors.pubsub.PublishSubscribe
 
PublishSubscribeService - Interface in org.apache.edgent.connectors.pubsub.service
Publish subscribe service.
putJson(TStream<JsonObject>, Supplier<CloseableHttpClient>, Function<JsonObject, String>, UnaryOperator<JsonObject>) - Static method in class org.apache.edgent.connectors.http.HttpStreams
Make an HTTP PUT request with JsonObject.

Q

QoS - Interface in org.apache.edgent.connectors.iot
Device event quality of service levels.
quickstart(Topology, String) - Static method in class org.apache.edgent.connectors.iotp.IotpDevice
Create an IotpDevice connector to the Quickstart service.
QUICKSTART_DEVICE_TYPE - Static variable in class org.apache.edgent.connectors.iotp.IotpDevice
Device type identifier ("iotsamples-edgent") used when using the Quickstart service.

R

Range<T extends Comparable<?>> - Class in org.apache.edgent.analytics.sensors
A generic immutable range of values and a way to check a value for containment in the range.
range(T, Range.BoundType, T, Range.BoundType) - Static method in class org.apache.edgent.analytics.sensors.Range
Create a new Range<T>
Range.BoundType - Enum in org.apache.edgent.analytics.sensors
Exclude or include an endpoint value in the range.
Ranges - Class in org.apache.edgent.analytics.sensors
Convenience functions and utility operations on Range.
Ranges() - Constructor for class org.apache.edgent.analytics.sensors.Ranges
 
rateMeter(TStream<T>) - Static method in class org.apache.edgent.metrics.Metrics
Measure current tuple throughput and calculate one-, five-, and fifteen-minute exponentially-weighted moving averages.
RateMeter<T> - Class in org.apache.edgent.metrics.oplets
A metrics oplet which measures current tuple throughput and one-, five-, and fifteen-minute exponentially-weighted moving averages.
RateMeter() - Constructor for class org.apache.edgent.metrics.oplets.RateMeter
 
receive() - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Create a stream of JsonObject tuples from received JSON WebSocket text messages.
receive() - Method in interface org.apache.edgent.connectors.wsclient.WebSocketClient
Create a stream of JsonObject tuples from received JSON WebSocket text messages.
receiveBytes() - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Create a stream of byte[] tuples from received WebSocket binary messages.
receiveBytes() - Method in interface org.apache.edgent.connectors.wsclient.WebSocketClient
Create a stream of byte[] tuples from received WebSocket binary messages.
receiver() - Method in class org.apache.edgent.oplet.plumbing.Barrier
 
receiveString() - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Create a stream of String tuples from received WebSocket text messages.
receiveString() - Method in interface org.apache.edgent.connectors.wsclient.WebSocketClient
Create a stream of String tuples from received WebSocket text messages.
register(String, StreamScope<?>) - Method in class org.apache.edgent.streamscope.StreamScopeRegistry
Register a StreamScope by name
register(ServiceContainer) - Static method in class org.apache.edgent.streamscope.StreamScopeSetup
Perform the registrations needed to use the streamscope package.
registerApplicationService() - Method in class org.apache.edgent.providers.iot.IotProvider
 
registerControl(String, String, String, Class<T>, T) - Method in interface org.apache.edgent.execution.services.ControlService
Register a control MBean.
registerControl(ControlService, EtiaoJob) - Static method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
Factory method which creates an EtiaoJobBean instance to control the specified EtiaoJob and registers it with the specified ControlService.
registerControl(String, String, String, Class<T>, T) - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
Register a control object as an MBean.
registerControl(String, String, String, Class<T>, T) - Method in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
Register a control MBean.
registerControlService() - Method in class org.apache.edgent.providers.iot.IotProvider
 
registerJar(String, String) - Method in class org.apache.edgent.runtime.appservice.AppService
Create a new class loader for the jar and register any topology application that is registered as a service provider.
registerJar(String, String) - Method in class org.apache.edgent.runtime.appservice.AppServiceControl
 
registerJar(String, String) - Method in interface org.apache.edgent.topology.mbeans.ApplicationServiceMXBean
Register a jar file containing applications with the application service.
registerJar(String, String) - Method in interface org.apache.edgent.topology.services.ApplicationService
Register a jar file containing new applications.
registerPartitionProcessor(BiConsumer<List<T>, K>) - Method in interface org.apache.edgent.window.Window
Register a WindowProcessor.
registerPreferencesService() - Method in class org.apache.edgent.providers.iot.IotProvider
 
registerPublishSubscribeService() - Method in class org.apache.edgent.providers.iot.IotProvider
 
registerScheduledExecutorService(ScheduledExecutorService) - Method in interface org.apache.edgent.window.Window
Register a ScheduledExecutorService.
registerTopology(String, BiConsumer<IotDevice, JsonObject>) - Method in class org.apache.edgent.providers.iot.IotProvider
Register an application that uses an IotDevice.
registerTopology(String, BiConsumer<IotDevice, JsonObject>, boolean, JsonObject) - Method in class org.apache.edgent.providers.iot.IotProvider
Register an application that uses an IotDevice.
registerTopology(String, BiConsumer<Topology, JsonObject>) - Method in class org.apache.edgent.runtime.appservice.AppService
 
registerTopology(String, BiConsumer<Topology, JsonObject>) - Method in interface org.apache.edgent.topology.services.ApplicationService
Add a topology that can be started though a control mbean.
registerWith(MBeanServer) - Method in class org.apache.edgent.metrics.MetricsSetup
Use the specified MBeanServer with this metric setup.
Regression - Enum in org.apache.edgent.analytics.math3.stat
Univariate regression aggregates.
Regression2 - Enum in org.apache.edgent.analytics.math3.stat
Univariate regression aggregates.
removeJob(String) - Method in interface org.apache.edgent.execution.services.JobRegistryService
Removes the job specified by the given identifier.
removeJob(String) - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
removeListener(BiConsumer<JobRegistryService.EventType, Job>) - Method in interface org.apache.edgent.execution.services.JobRegistryService
Removes a handler from this registry's collection of listeners.
removeListener(BiConsumer<JobRegistryService.EventType, Job>) - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
removeService(Class<T>) - Method in class org.apache.edgent.execution.services.ServiceContainer
Removes the specified service from this ServiceContainer.
removeState(K) - Method in class org.apache.edgent.window.PartitionedState
 
removeSubscriber(String, Consumer<?>) - Method in class org.apache.edgent.connectors.pubsub.service.ProviderPubSub
 
removeSubscriber(String, Consumer<?>) - Method in interface org.apache.edgent.connectors.pubsub.service.PublishSubscribeService
 
requests(TStream<T>, Supplier<CloseableHttpClient>, Function<T, String>, Function<T, String>, BiFunction<T, CloseableHttpResponse, R>) - Static method in class org.apache.edgent.connectors.http.HttpStreams
Make an HTTP request for each tuple on a stream.
requestsWithBody(TStream<T>, Supplier<CloseableHttpClient>, Function<T, String>, Function<T, String>, Function<T, HttpEntity>, BiFunction<T, CloseableHttpResponse, R>) - Static method in class org.apache.edgent.connectors.http.HttpStreams
Make an HTTP request with body for each tuple.
RESERVED_ID_PREFIX - Static variable in interface org.apache.edgent.connectors.iot.IotDevice
Device event and command identifiers starting with "edgent" are reserved for use by Edgent.
RESERVED_TOPIC_PREFIX - Static variable in class org.apache.edgent.connectors.pubsub.PublishSubscribe
Topics that start with "edgent/" are reserved for use by Edgent.
result(JsonElement, JsonObject) - Method in interface org.apache.edgent.analytics.math3.json.JsonUnivariateAggregator
Place the result of the aggregation into the result object.
result(JsonElement, JsonObject) - Method in class org.apache.edgent.analytics.math3.stat.JsonStorelessStatistic
 
ResultMap - Class in org.apache.edgent.analytics.math3
Aggregation results for a single aggregated variable.
ResultMap() - Constructor for class org.apache.edgent.analytics.math3.ResultMap
Create a new ResultMap.
ResultsHandler<T,R> - Interface in org.apache.edgent.connectors.jdbc
Handle the results of executing an SQL statement.
roundRobinSplitter(int) - Static method in class org.apache.edgent.topology.plumbing.PlumbingStreams
A round-robin splitter ToIntFunction
run() - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
run() - Method in class org.apache.edgent.oplet.core.ProcessSource
 
RuntimeServices - Interface in org.apache.edgent.execution.services
At runtime a container provides services to executing elements such as oplets and functions.
runWithFinal(Runnable, Runnable) - Static method in class org.apache.edgent.function.Functions
Wrap a Runnable with a final action that is always called when action.run() completes.

S

scheduleEvictIfEmpty(long, TimeUnit) - Static method in class org.apache.edgent.window.Policies
A policy which schedules a future partition eviction if the partition is empty.
scheduleEvictOnFirstInsert(long, TimeUnit) - Static method in class org.apache.edgent.window.Policies
A policy which schedules a future partition eviction on the first insert.
send(TStream<JsonObject>) - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Send a stream's JsonObject tuples as JSON in a WebSocket text message.
send(TStream<JsonObject>) - Method in interface org.apache.edgent.connectors.wsclient.WebSocketClient
Send a stream's JsonObject tuples as JSON in a WebSocket text message.
sendBytes(TStream<byte[]>) - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Send a stream's byte[] tuples in a WebSocket binary message.
sendBytes(TStream<byte[]>) - Method in interface org.apache.edgent.connectors.wsclient.WebSocketClient
Send a stream's byte[] tuples in a WebSocket binary message.
sendString(TStream<String>) - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
Send a stream's String tuples in a WebSocket text message.
sendString(TStream<String>) - Method in interface org.apache.edgent.connectors.wsclient.WebSocketClient
Send a stream's String tuples in a WebSocket text message.
SerialDevice - Interface in org.apache.edgent.connectors.serial
Access to a device (or devices) connected by a serial port.
SerialPort - Interface in org.apache.edgent.connectors.serial
Serial port runtime access.
ServiceContainer - Class in org.apache.edgent.execution.services
Provides a container for services.
ServiceContainer() - Constructor for class org.apache.edgent.execution.services.ServiceContainer
 
setActionTimeToWaitMillis(long) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Maximum time to wait for an action (e.g., publish message) to complete.
setCaptureByCount(int) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Capture the first and every nth tuple
setCaptureByCount(int) - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
Capture the first and every nth tuple
setCaptureByCount(int) - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
setCaptureByPredicate(Predicate<T>) - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
Capture a tuple if the predicate test of the tuple returns true.
setCaptureByTime(long, TimeUnit) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Capture the 1st tuple and then the next tuple after period unit time has elapsed since the previous captured tuple.
setCaptureByTime(long, TimeUnit) - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
Capture the 1st tuple and then the next tuple after period unit time has elapsed since the previous captured tuple.
setCaptureByTime(long, TimeUnit) - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
setCleanSession(boolean) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Clean Session.
setClientId(String) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Connection Client Id.
setConnectionTimeout(int) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Connection timeout.
setContext(int, OutputPortContext) - Method in class org.apache.edgent.runtime.etiao.Invocation
Set the specified output port's context.
setDestination(Consumer<T>) - Method in class org.apache.edgent.runtime.etiao.SettableForwarder
Change the destination.
setEnabled(boolean) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Enable or disable tuple capture.
setEnabled(boolean) - Method in class org.apache.edgent.streamscope.StreamScope
Enable or disable tuple capture.
setEnabled(boolean) - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
setExternalCallbackHandler(GatewayCallback) - Method in class org.apache.edgent.connectors.iotp.IotpGateway
Set an external WIoTP GatewayCallback handler.
setHealth(Job.Health) - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
setIdleTimeout(int) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Idle connection timeout.
setInitializer(Consumer<SerialPort>) - Method in interface org.apache.edgent.connectors.serial.SerialDevice
Set the initialization function for this port.
setKeepAliveInterval(int) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Connection Keep alive.
setKeyStore(String) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Set the SSL key store path.
setKeyStorePassword(char[]) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Set the SSL key store password.
setLastError(String) - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
setMaxRetentionCount(int) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Set the maximum number of tuples to retain.
setMaxRetentionCount(int) - Method in class org.apache.edgent.streamscope.StreamScope.BufferManager
Set the maximum number of tuples to retain.
setMaxRetentionCount(int) - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
setMaxRetentionTime(long, TimeUnit) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Set the maximum retention time of a tuple.
setMaxRetentionTime(long, TimeUnit) - Method in class org.apache.edgent.streamscope.StreamScope.BufferManager
Set the maximum retention time of a tuple.
setMaxRetentionTime(long, TimeUnit) - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
setNextState(Job.State) - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
setOpen(boolean) - Method in class org.apache.edgent.topology.plumbing.Valve
Set the valve state
setParameters(T, PreparedStatement) - Method in interface org.apache.edgent.connectors.jdbc.ParameterSetter
Set 0 or more parameters in a JDBC PreparedStatement.
setPassword(char[]) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Set the password to use for authentication with the server.
setPaused(boolean) - Method in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
Set capture paused control
setPaused(boolean) - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
Set capture paused control
setPaused(boolean) - Method in class org.apache.edgent.streamscope.StreamScopeBean
 
setPauseOn(Predicate<T>) - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
Set a pause-on predicate.
setPeriod(long, TimeUnit) - Method in class org.apache.edgent.analytics.sensors.Deadtime
Set the deadtime period
setPeriod(long) - Method in interface org.apache.edgent.execution.mbeans.PeriodMXBean
Set the period.
setPeriod(long, TimeUnit) - Method in interface org.apache.edgent.execution.mbeans.PeriodMXBean
Set the period and unit
setPeriod(long) - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
setPeriod(long, TimeUnit) - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
setPersistence(MqttClientPersistence) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
QoS 1 and 2 in-flight message persistence.
setReceiver(BiFunction<T, Integer, U>) - Method in class org.apache.edgent.oplet.core.FanIn
Set the receiver function.
setServerURLs(String[]) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
MQTT Server URLs
setSinker(Consumer<T>) - Method in class org.apache.edgent.oplet.core.Sink
Set the sink function.
setState(K, S) - Method in class org.apache.edgent.window.PartitionedState
Set the current state for key.
setSubscriberIdleReconnectInterval(int) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Subscriber idle reconnect interval.
SettableForwarder<T> - Class in org.apache.edgent.runtime.etiao
A forwarding Streamer whose destination can be changed.
SettableForwarder() - Constructor for class org.apache.edgent.runtime.etiao.SettableForwarder
Create with the destination set to Functions.discard().
SettableForwarder(Consumer<T>) - Constructor for class org.apache.edgent.runtime.etiao.SettableForwarder
Create with the specified destination.
setTarget(int, Consumer<O>) - Method in class org.apache.edgent.runtime.etiao.Invocation
Disconnects the specified port and reconnects it to the specified target.
setTrustStore(String) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Set the SSL trust store path.
setTrustStorePassword(char[]) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Set the SSL trust store password.
setUserName(String) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Set the username to use for authentication with the server.
setWill(String, byte[], int, boolean) - Method in class org.apache.edgent.connectors.mqtt.MqttConfig
Last Will and Testament.
shouldCycle() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
shouldFlush() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
shutdown() - Method in class org.apache.edgent.runtime.etiao.ThreadFactoryTracker
This initiates an orderly shutdown in which no new tasks will be accepted but previously submitted tasks continue to be executed.
shutdownNow() - Method in class org.apache.edgent.runtime.etiao.ThreadFactoryTracker
Interrupts all user treads and briefly waits for each thread to finish execution.
SingleMetricAbstractOplet<T> - Class in org.apache.edgent.metrics.oplets
Base for metrics oplets which use a single metric object.
SingleMetricAbstractOplet(String) - Constructor for class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet
 
singleton(T) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range [endpoint..endpoint] (both inclusive/CLOSED)
sink(TStream<String>, ProcessBuilder) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Sink a TStream<String> to a command's input.
Sink<T> - Class in org.apache.edgent.oplet.core
Sink a stream by processing each tuple through a Consumer.
Sink() - Constructor for class org.apache.edgent.oplet.core.Sink
Create a Sink that discards all tuples.
Sink(Consumer<T>) - Constructor for class org.apache.edgent.oplet.core.Sink
Create a Sink oplet.
sink(Consumer<T>) - Method in class org.apache.edgent.topology.spi.AbstractTStream
 
sink(Sink<T>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
sink(Consumer<T>) - Method in interface org.apache.edgent.topology.TStream
Sink (terminate) this stream using a function.
sink(Sink<T>) - Method in interface org.apache.edgent.topology.TStream
Sink (terminate) this stream using a oplet.
size() - Method in class org.apache.edgent.window.InsertionTimeList
 
source(N) - Method in interface org.apache.edgent.graph.Graph
Create a new unconnected Vertex associated with the specified source Oplet.
source(N) - Method in class org.apache.edgent.graph.spi.AbstractGraph
 
Source<T> - Class in org.apache.edgent.oplet.core
 
Source() - Constructor for class org.apache.edgent.oplet.core.Source
 
source(Topology, BiFunction<JobRegistryService.EventType, Job, T>) - Static method in class org.apache.edgent.runtime.jobregistry.JobEvents
Declares a stream populated by JobRegistryService events.
source(Supplier<Iterable<T>>) - Method in class org.apache.edgent.topology.spi.graph.GraphTopology
 
source(Supplier<Iterable<T>>) - Method in interface org.apache.edgent.topology.Topology
Declare a new source stream that iterates over the return of Iterable<T> get() from data.
sourceStream(N) - Method in class org.apache.edgent.topology.spi.graph.GraphTopology
 
Split<T> - Class in org.apache.edgent.oplet.core
Split a stream into multiple streams depending on the result of a splitter function.
Split(ToIntFunction<T>) - Constructor for class org.apache.edgent.oplet.core.Split
 
split(int, ToIntFunction<T>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
split(Class<E>, Function<T, E>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
split(int, ToIntFunction<T>) - Method in interface org.apache.edgent.topology.TStream
Split a stream's tuples among n streams as specified by splitter.
split(Class<E>, Function<T, E>) - Method in interface org.apache.edgent.topology.TStream
Split a stream's tuples among enumClass.size streams as specified by splitter.
start() - Method in class org.apache.edgent.oplet.core.FanIn
 
start() - Method in class org.apache.edgent.oplet.core.FanOut
 
start() - Method in class org.apache.edgent.oplet.core.PeriodicSource
 
start() - Method in class org.apache.edgent.oplet.core.Pipe
 
start() - Method in class org.apache.edgent.oplet.core.ProcessSource
 
start() - Method in class org.apache.edgent.oplet.core.Sink
 
start() - Method in class org.apache.edgent.oplet.core.Split
 
start() - Method in class org.apache.edgent.oplet.core.Union
 
start() - Method in class org.apache.edgent.oplet.functional.Events
 
start() - Method in interface org.apache.edgent.oplet.Oplet
Start the oplet.
start() - Method in class org.apache.edgent.oplet.plumbing.Barrier
 
start() - Method in class org.apache.edgent.oplet.plumbing.Isolate
 
start() - Method in class org.apache.edgent.providers.iot.IotProvider
Start this provider by starting its system applications and any autoSubmit-enabled registered applications.
start() - Method in class org.apache.edgent.runtime.etiao.Executable
Starts all the invocations.
start() - Method in class org.apache.edgent.runtime.etiao.Invocation
Start the oplet.
startConsoleReporter() - Method in class org.apache.edgent.metrics.MetricsSetup
Starts the metric ConsoleReporter polling every second.
startCSVReporter(String) - Method in class org.apache.edgent.metrics.MetricsSetup
Starts the metric CsvReporter.
startJMXReporter(String) - Method in class org.apache.edgent.metrics.MetricsSetup
Starts the metric JMXReporter.
stateChange(Job.Action) - Method in interface org.apache.edgent.execution.Job
Initiates an execution state change.
stateChange(Job.Action) - Method in interface org.apache.edgent.execution.mbeans.JobMXBean
Initiates an execution state change.
stateChange(Job.Action) - Method in class org.apache.edgent.graph.spi.execution.AbstractGraphJob
 
stateChange(Job.Action) - Method in class org.apache.edgent.runtime.etiao.EtiaoJob
 
stateChange(Job.Action) - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
StatementSupplier - Interface in org.apache.edgent.connectors.jdbc
Function that supplies a JDBC SQL PreparedStatement.
Statistic - Enum in org.apache.edgent.analytics.math3.stat
Statistic implementations.
Statistic2 - Enum in org.apache.edgent.analytics.math3.stat
Statistic implementations.
StorelessStatistic - Class in org.apache.edgent.analytics.math3.stat
Univariate aggregator implementation wrapping a StorelessUnivariateStatistic.
StorelessStatistic(Statistic2, StorelessUnivariateStatistic) - Constructor for class org.apache.edgent.analytics.math3.stat.StorelessStatistic
 
streamAliasFromName(String) - Static method in class org.apache.edgent.streamscope.StreamScopeRegistry
Extract the stream alias from a name
streamContents(TStream<T>, T...) - Method in interface org.apache.edgent.topology.tester.Tester
Return a condition that evaluates if stream has submitted tuples matching values in the same order.
streamIdFromName(String) - Static method in class org.apache.edgent.streamscope.StreamScopeRegistry
Extract the streamId from the name.
StreamScope<T> - Class in org.apache.edgent.streamscope.oplets
A Stream "oscilloscope" oplet.
StreamScope(Consumer<T>) - Constructor for class org.apache.edgent.streamscope.oplets.StreamScope
Create a new instance.
StreamScope<T> - Class in org.apache.edgent.streamscope
A Stream "oscilloscope" for capturing stream tuples for analysis / debug.
StreamScope() - Constructor for class org.apache.edgent.streamscope.StreamScope
Create a new instance.
StreamScope.BufferManager<T> - Class in org.apache.edgent.streamscope
Control the retention of captured tuples.
StreamScope.Sample<T> - Class in org.apache.edgent.streamscope
A captured tuple.
StreamScope.TriggerManager<T> - Class in org.apache.edgent.streamscope
Control what triggers capturing of tuples.
StreamScopeBean - Class in org.apache.edgent.streamscope
Implementation of StreamScopeMXBean.
StreamScopeBean(StreamScope<?>) - Constructor for class org.apache.edgent.streamscope.StreamScopeBean
 
StreamScopeMXBean - Interface in org.apache.edgent.streamscope.mbeans
A Stream "oscilloscope" for capturing stream tuples for analysis / debug.
StreamScopeRegistry - Class in org.apache.edgent.streamscope
A registry for Stream "oscilloscope" StreamScope instances.
StreamScopeRegistry() - Constructor for class org.apache.edgent.streamscope.StreamScopeRegistry
 
StreamScopeRegistryBean - Class in org.apache.edgent.streamscope
An implementation of StreamScopeRegistryMXBean.
StreamScopeRegistryBean(StreamScopeRegistry, ControlService) - Constructor for class org.apache.edgent.streamscope.StreamScopeRegistryBean
 
StreamScopeRegistryMXBean - Interface in org.apache.edgent.streamscope.mbeans
A registry for StreamScopeMXBean instances.
StreamScopeSetup - Class in org.apache.edgent.streamscope
Utility helpers for StreamScope setup and management.
strings(String...) - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
strings(String...) - Method in interface org.apache.edgent.topology.Topology
Declare a stream of strings.
submit() - Method in class org.apache.edgent.apps.runtime.JobMonitorApp
Submits the application topology.
submit(E) - Method in interface org.apache.edgent.execution.Submitter
Submit an executable.
submit(E, JsonObject) - Method in interface org.apache.edgent.execution.Submitter
Submit an executable.
submit(U) - Method in class org.apache.edgent.oplet.core.FanIn
Submit a tuple to single output.
submit(O) - Method in class org.apache.edgent.oplet.core.Pipe
Submit a tuple to single output.
submit(T) - Method in class org.apache.edgent.oplet.core.Source
Submit a tuple to single output.
submit(Topology, JsonObject) - Method in class org.apache.edgent.providers.development.DevelopmentProvider
 
submit(Topology) - Method in class org.apache.edgent.providers.direct.DirectProvider
 
submit(Topology, JsonObject) - Method in class org.apache.edgent.providers.direct.DirectProvider
 
submit(Topology) - Method in class org.apache.edgent.providers.iot.IotProvider
Submit an executable.
submit(Topology, JsonObject) - Method in class org.apache.edgent.providers.iot.IotProvider
Submit an executable.
submit(String, String) - Method in class org.apache.edgent.runtime.appservice.AppServiceControl
 
submit(String, String) - Method in interface org.apache.edgent.topology.mbeans.ApplicationServiceMXBean
Submit an application registered with the application service.
submitApplication(String, ControlService) - Static method in class org.apache.edgent.apps.runtime.JobMonitorApp
Submits an application using an ApplicationServiceMXBean control registered with the specified ControlService.
Submitter<E,J extends Job> - Interface in org.apache.edgent.execution
An interface for submission of an executable.
subscribe(Function<KafkaConsumer.StringConsumerRecord, T>, String...) - Method in class org.apache.edgent.connectors.kafka.KafkaConsumer
Subscribe to the specified topics and yield a stream of tuples from the published Kafka records.
subscribe(String, int, BiFunction<String, byte[], T>) - Method in class org.apache.edgent.connectors.mqtt.MqttStreams
Subscribe to the MQTT topic(s) and create a stream of tuples of type T.
subscribe(String, int) - Method in class org.apache.edgent.connectors.mqtt.MqttStreams
Subscribe to the MQTT topic(s) and create a TStream<String>.
subscribe(TopologyElement, String, Class<T>) - Static method in class org.apache.edgent.connectors.pubsub.PublishSubscribe
Subscribe to a published topic.
subscribeBytes(Function<KafkaConsumer.ByteConsumerRecord, T>, String...) - Method in class org.apache.edgent.connectors.kafka.KafkaConsumer
Subscribe to the specified topics and yield a stream of tuples from the published Kafka records.
sum(Collection<? extends Number>) - Static method in class org.apache.edgent.analytics.math3.Aggregations
Perform a sum of numbers treated as double values, accumulating in a double.
sumInts(Collection<? extends Number>) - Static method in class org.apache.edgent.analytics.math3.Aggregations
Perform a sum of numbers treated as long values, accumulating in a long.
Supplier<T> - Interface in org.apache.edgent.function
Function that supplies a value.
SupplierPeriodicSource<T> - Class in org.apache.edgent.oplet.functional
 
SupplierPeriodicSource(long, TimeUnit, Supplier<T>) - Constructor for class org.apache.edgent.oplet.functional.SupplierPeriodicSource
 
SupplierSource<T> - Class in org.apache.edgent.oplet.functional
 
SupplierSource() - Constructor for class org.apache.edgent.oplet.functional.SupplierSource
 
SupplierSource(Supplier<Iterable<T>>) - Constructor for class org.apache.edgent.oplet.functional.SupplierSource
 
synchronizedBiFunction(BiFunction<T, U, R>) - Static method in class org.apache.edgent.function.Functions
Return a thread-safe version of a BiFunction function.
synchronizedConsumer(Consumer<T>) - Static method in class org.apache.edgent.function.Functions
Return a thread-safe version of a Consumer function.
synchronizedFunction(Function<T, R>) - Static method in class org.apache.edgent.function.Functions
Return a thread-safe version of a Function function.
synchronizedSupplier(Supplier<T>) - Static method in class org.apache.edgent.function.Functions
Return a thread-safe version of a Supplier function.
SYSTEM_APP_PREFIX - Static variable in interface org.apache.edgent.topology.services.ApplicationService
Prefix ("edgent") reserved for system application names.

T

tag(String...) - Method in interface org.apache.edgent.graph.Connector
Adds the specified tags to the connector.
tag(String...) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
tag(String...) - Method in interface org.apache.edgent.topology.TStream
Adds the specified tags to the stream.
test(T) - Method in class org.apache.edgent.analytics.sensors.Deadtime
Test the deadtime predicate.
test(T) - Method in class org.apache.edgent.analytics.sensors.Range
Predicate.test() implementation.
test(T) - Method in interface org.apache.edgent.function.Predicate
Test a value against a predicate.
test(T) - Method in class org.apache.edgent.topology.plumbing.Valve
Test the state of the valve, value is ignored.
Tester - Interface in org.apache.edgent.topology.tester
A Tester adds the ability to test a topology in a test framework such as JUnit.
textFileReader(TStream<String>) - Static method in class org.apache.edgent.connectors.file.FileStreams
Declare a stream containing the lines read from the files whose pathnames correspond to each tuple on the pathnames stream.
textFileReader(TStream<String>, Function<String, String>, BiFunction<String, Exception, String>) - Static method in class org.apache.edgent.connectors.file.FileStreams
Declare a stream containing the lines read from the files whose pathnames correspond to each tuple on the pathnames stream.
textFileWriter(TStream<String>, Supplier<String>) - Static method in class org.apache.edgent.connectors.file.FileStreams
Write the contents of a stream to files.
textFileWriter(TStream<String>, Supplier<String>, Supplier<IFileWriterPolicy<String>>) - Static method in class org.apache.edgent.connectors.file.FileStreams
Write the contents of a stream to files subject to the control of a file writer policy.
ThreadFactoryTracker - Class in org.apache.edgent.runtime.etiao
Tracks threads created for executing user tasks.
timestamp() - Method in class org.apache.edgent.streamscope.StreamScope.Sample
Capture time in msec since the epoch.
ToDoubleFunction<T> - Interface in org.apache.edgent.function
Function that returns a double primitive.
ToIntFunction<T> - Interface in org.apache.edgent.function
Function that returns a int primitive.
toJson(List<String>, String...) - Static method in class org.apache.edgent.connectors.csv.Csv
Create a JsonObject containing the specified fieldNames properties each with its corresponding value from fields.
toJsonObject() - Static method in class org.apache.edgent.analytics.math3.MvResultMap
Returns a Function whose apply(MvResultMap) converts the value to a JsonObject.
toJsonObject() - Static method in class org.apache.edgent.analytics.math3.ResultMap
Returns a Function whose apply(ResultMap) converts the value to a JsonObject.
tokenize(String) - Static method in class org.apache.edgent.connectors.command.CommandStreams
Tokenize the specified cmdString in the exact same manner as done by Runtime.exec(String).
topic() - Method in interface org.apache.edgent.connectors.kafka.KafkaConsumer.ConsumerRecord
 
topology() - Method in class org.apache.edgent.connectors.iotp.IotpDevice
 
topology() - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
topology() - Method in class org.apache.edgent.connectors.mqtt.iot.MqttDevice
 
topology() - Method in class org.apache.edgent.connectors.mqtt.MqttStreams
Get the Topology the connector is associated with.
topology() - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.Jsr356WebSocketClient
 
topology() - Method in class org.apache.edgent.topology.spi.AbstractTopology
 
topology() - Method in class org.apache.edgent.topology.spi.AbstractTStream
 
topology() - Method in class org.apache.edgent.topology.spi.graph.AbstractTWindow
 
Topology - Interface in org.apache.edgent.topology
A declaration of a topology of streaming data.
topology() - Method in interface org.apache.edgent.topology.TopologyElement
Topology this element is contained in.
TopologyBuilder - Interface in org.apache.edgent.topology.services
Represents an topology that can be built.
TopologyElement - Interface in org.apache.edgent.topology
An element of a Topology.
TopologyProvider - Interface in org.apache.edgent.topology
Provider (factory) for creating topologies.
toString() - Method in class org.apache.edgent.analytics.sensors.Deadtime
Returns a String for development/debug support.
toString() - Method in class org.apache.edgent.analytics.sensors.Range
Yields "<lowerBoundType><lowerEndpoint>..<upperEndpoint><upperBoundType>".
toString() - Method in class org.apache.edgent.connectors.file.FileWriterCycleConfig
 
toString() - Method in class org.apache.edgent.connectors.file.FileWriterFlushConfig
 
toString() - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 
toString() - Method in class org.apache.edgent.connectors.file.FileWriterRetentionConfig
 
toString() - Method in class org.apache.edgent.connectors.iotp.IotpDevice
 
toString() - Method in class org.apache.edgent.connectors.iotp.IotpGateway
 
toString() - Method in class org.apache.edgent.runtime.etiao.graph.ExecutableVertex
For debug.
toString() - Method in class org.apache.edgent.runtime.etiao.Invocation
For debug.
toString() - Method in class org.apache.edgent.streamscope.StreamScope.BufferManager
 
toString() - Method in class org.apache.edgent.streamscope.StreamScope.Sample
 
toString() - Method in class org.apache.edgent.streamscope.StreamScope
 
toString() - Method in class org.apache.edgent.streamscope.StreamScope.TriggerManager
 
toString() - Method in class org.apache.edgent.topology.plumbing.Valve
Returns a String for development/debug support.
toString() - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
Intended only as a debug aid and content is not guaranteed.
toStringUnsigned() - Method in class org.apache.edgent.analytics.sensors.Range
Return a String treating the endpoints as an unsigned value.
TrackingScheduledExecutor - Class in org.apache.edgent.runtime.etiao
Extends a ScheduledThreadPoolExecutor with the ability to track scheduled tasks and cancel them in case a task completes abruptly due to an exception.
TriggerManager() - Constructor for class org.apache.edgent.streamscope.StreamScope.TriggerManager
 
triggerMgr() - Method in class org.apache.edgent.streamscope.StreamScope
TSink<T> - Interface in org.apache.edgent.topology
Termination point (sink) for a stream.
TStream<T> - Interface in org.apache.edgent.topology
A TStream is a declaration of a continuous sequence of tuples.
tuple() - Method in class org.apache.edgent.streamscope.StreamScope.Sample
The captured tuple.
tupleCount(TStream<?>, long) - Method in interface org.apache.edgent.topology.tester.Tester
Return a condition that evaluates if stream has submitted exactly expectedCount number of tuples.
TWindow<T,K> - Interface in org.apache.edgent.topology
Partitioned window of tuples.
TWindowImpl<T,K> - Class in org.apache.edgent.topology.spi.graph
 
TWindowTimeImpl<T,K> - Class in org.apache.edgent.topology.spi.graph
 
TYPE - Static variable in interface org.apache.edgent.execution.mbeans.JobMXBean
TYPE is used to identify this bean as a job bean when building the bean's ObjectName.
TYPE - Static variable in interface org.apache.edgent.streamscope.mbeans.StreamScopeMXBean
TYPE is used to identify this bean as a StreamScope bean when building the bean's ObjectName.
TYPE - Static variable in interface org.apache.edgent.streamscope.mbeans.StreamScopeRegistryMXBean
TYPE is used to identify this bean as a StreamScopeRegistry bean when building the bean's ObjectName.
TYPE - Static variable in interface org.apache.edgent.topology.mbeans.ApplicationServiceMXBean
 
TYPE - Static variable in interface org.apache.edgent.topology.TStream
TYPE is used to identify ControlService mbeans registered for for a TStream.
TYPE_KEY - Static variable in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
Key for the type of the control MBean in a JSON request.
TYPE_PREFIX - Static variable in class org.apache.edgent.metrics.MetricObjectNameFactory
Prefix of all metric types.

U

UnaryOperator<T> - Interface in org.apache.edgent.function
Function that returns the same type as its argument.
Union<T> - Class in org.apache.edgent.oplet.core
Union oplet, merges multiple input ports into a single output port.
Union() - Constructor for class org.apache.edgent.oplet.core.Union
 
union(TStream<T>) - Method in class org.apache.edgent.topology.spi.AbstractTStream
Declare a stream that will contain all tuples from this stream and other.
union(Set<TStream<T>>) - Method in class org.apache.edgent.topology.spi.graph.ConnectorStream
 
union(TStream<T>) - Method in interface org.apache.edgent.topology.TStream
Declare a stream that will contain all tuples from this stream and other.
union(Set<TStream<T>>) - Method in interface org.apache.edgent.topology.TStream
Declare a stream that will contain all tuples from this stream and all the streams in others.
uniquify(String) - Method in interface org.apache.edgent.oplet.OpletContext
Creates a unique name within the context of the current runtime.
uniquify(String) - Method in class org.apache.edgent.runtime.etiao.AbstractContext
Creates a unique name within the context of the current runtime.
UnivariateAggregate - Interface in org.apache.edgent.analytics.math3
Univariate aggregate for a tuple.
UnivariateAggregator - Interface in org.apache.edgent.analytics.math3
Univariate aggregator for tuples.
UnorderedIsolate<T> - Class in org.apache.edgent.oplet.plumbing
Isolate upstream processing from downstream processing without guaranteeing tuple order.
UnorderedIsolate() - Constructor for class org.apache.edgent.oplet.plumbing.UnorderedIsolate
 
unpartitioned() - Static method in class org.apache.edgent.function.Functions
Returns a constant function that returns zero (0).
unpartitioned() - Static method in class org.apache.edgent.topology.json.JsonFunctions
Returns a constant function that returns a zero (0) JsonElement.
unregister(String) - Method in interface org.apache.edgent.execution.services.ControlService
unregister(String) - Method in class org.apache.edgent.runtime.jmxcontrol.JMXControlService
 
unregister(String) - Method in class org.apache.edgent.runtime.jsoncontrol.JsonControlService
unregister(String) - Method in class org.apache.edgent.streamscope.StreamScopeRegistry
remove the specific name registration.
unregister(StreamScope<?>) - Method in class org.apache.edgent.streamscope.StreamScopeRegistry
remove all name registrations of the StreamScope.
unwrap(Class<C>) - Method in class org.apache.edgent.function.WrappedFunction
Unwrap to find the outermost function that is an instance of clazz.
unwrap(Class<C>, Object) - Static method in class org.apache.edgent.function.WrappedFunction
Unwrap a function object to find the outermost function that implements clazz.
updateJob(Job) - Method in interface org.apache.edgent.execution.services.JobRegistryService
Notifies listeners that the specified registered job has been updated.
updateJob(Job) - Method in class org.apache.edgent.runtime.jobregistry.JobRegistry
 
upperBoundType() - Method in class org.apache.edgent.analytics.sensors.Range
Get the BoundType for the upperEndpoint.
upperEndpoint() - Method in class org.apache.edgent.analytics.sensors.Range
Get the range's upper endpoint.

V

valid() - Method in interface org.apache.edgent.topology.tester.Condition
 
value() - Method in interface org.apache.edgent.connectors.kafka.KafkaConsumer.ConsumerRecord
 
valueOf(String) - Static method in enum org.apache.edgent.analytics.math3.stat.Regression
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.analytics.math3.stat.Regression2
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.analytics.math3.stat.Statistic
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.analytics.math3.stat.Statistic2
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.analytics.sensors.Range.BoundType
Returns the enum constant of this type with the specified name.
valueOf(String, Function<String, T>) - Static method in class org.apache.edgent.analytics.sensors.Range
Create a Range from a String produced by toString().
valueOf(String) - Static method in enum org.apache.edgent.execution.Job.Action
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.execution.Job.Health
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.execution.Job.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.edgent.execution.services.JobRegistryService.EventType
Returns the enum constant of this type with the specified name.
valueOfBigDecimal(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<BigDecimal>.toString() value.
valueOfBigInteger(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<BigInteger>.toString() value.
valueOfBoolean(String) - Static method in class org.apache.edgent.topology.json.JsonFunctions
Create a JsonObject with a Boolean property.
valueOfByte(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Byte>.toString() value.
valueOfCharacter(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Character>.toString() value.
valueOfCharacter(String) - Static method in class org.apache.edgent.topology.json.JsonFunctions
Create a JsonObject with a Character property.
valueOfDouble(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Double>.toString() value.
valueOfFloat(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Float>.toString() value.
valueOfInteger(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Integer>.toString() value.
valueOfLong(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Long>.toString() value.
valueOfNumber(String) - Static method in class org.apache.edgent.topology.json.JsonFunctions
Create a JsonObject with a Number property.
valueOfShort(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<Short>.toString() value.
valueOfString(String) - Static method in class org.apache.edgent.analytics.sensors.Ranges
Create a Range from a Range<String>.toString() value.
valueOfString(String) - Static method in class org.apache.edgent.topology.json.JsonFunctions
Create a JsonObject with a String property.
values() - Static method in enum org.apache.edgent.analytics.math3.stat.Regression
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.analytics.math3.stat.Regression2
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.analytics.math3.stat.Statistic
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.analytics.math3.stat.Statistic2
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.analytics.sensors.Range.BoundType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.execution.Job.Action
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.execution.Job.Health
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.execution.Job.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.edgent.execution.services.JobRegistryService.EventType
Returns an array containing the constants of this enum type, in the order they are declared.
Valve<T> - Class in org.apache.edgent.topology.plumbing
A generic "valve" Predicate.
Valve() - Constructor for class org.apache.edgent.topology.plumbing.Valve
Create a new Valve Predicate
Valve(boolean) - Constructor for class org.apache.edgent.topology.plumbing.Valve
Create a new Valve Predicate
verify(TStream<T>) - Method in class org.apache.edgent.topology.spi.AbstractTStream
 
Vertex<N extends Oplet<C,P>,C,P> - Interface in org.apache.edgent.graph
A Vertex in a graph.
VertexType<I,O> - Class in org.apache.edgent.runtime.etiao.graph.model
A VertexType in a graph.
VertexType(Vertex<? extends Oplet<?, ?>, ?, ?>, IdMapper<String>) - Constructor for class org.apache.edgent.runtime.etiao.graph.model.VertexType
 
VertexType() - Constructor for class org.apache.edgent.runtime.etiao.graph.model.VertexType
 

W

wasRegistered() - Method in class org.apache.edgent.runtime.etiao.mbeans.EtiaoJobBean
 
WebSocketClient - Interface in org.apache.edgent.connectors.wsclient
A generic connector for sending and receiving messages to a WebSocket Server.
Window<T,K,L extends List<T>> - Interface in org.apache.edgent.window
Partitioned window of tuples.
window(BiFunction<Partition<T, K, L>, T, Boolean>, BiConsumer<Partition<T, K, L>, T>, Consumer<Partition<T, K, L>>, BiConsumer<Partition<T, K, L>, T>, Function<T, K>, Supplier<L>) - Static method in class org.apache.edgent.window.Windows
Create a window using the passed in policies.
Windows - Class in org.apache.edgent.window
Factory to create Window implementations.
Windows() - Constructor for class org.apache.edgent.window.Windows
 
withRegistry(ServiceContainer, MetricRegistry) - Static method in class org.apache.edgent.metrics.MetricsSetup
Returns a new MetricsSetup for configuring metrics.
WrappedFunction<F> - Class in org.apache.edgent.function
A wrapped function.
WrappedFunction(F) - Constructor for class org.apache.edgent.function.WrappedFunction
 
wrote(T, long) - Method in class org.apache.edgent.connectors.file.FileWriterPolicy
 

Z

zero() - Static method in class org.apache.edgent.function.Functions
Returns a constant function that returns zero (0).
A B C D E F G H I J K L M N O P Q R S T U V W Z 
Skip navigation links

Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.