[14/77] [partial] incubator-edgent-website git commit: EDGENT[334] update website for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/execution/package-use.html -- diff --git a/site/javadoc/r1.1.0/org/apache/edgent/execution/package-use.html b/site/javadoc/r1.1.0/org/apache/edgent/execution/package-use.html new file mode 100644 index 000..5469b20 --- /dev/null +++ b/site/javadoc/r1.1.0/org/apache/edgent/execution/package-use.html @@ -0,0 +1,603 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + +Uses of Package org.apache.edgent.execution (Edgent v1.1.0) + + + + + + + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + + +Uses of Packageorg.apache.edgent.execution + + + + + +Packages that use org.apache.edgent.execution + +Package +Description + + + +org.apache.edgent.apps.runtime + +Applications which provide monitoring and failure recovery to other + Edgent applications. + + + +org.apache.edgent.execution + +Execution of Edgent topologies and graphs. + + + +org.apache.edgent.execution.mbeans + +Management MBeans for execution. + + + +org.apache.edgent.execution.services + +Execution services. + + + +org.apache.edgent.graph.spi.execution + + + +org.apache.edgent.providers.development + +Execution of a streaming topology in a development environment . + + + +org.apache.edgent.providers.direct + +Direct execution of a streaming topology. + + + +org.apache.edgent.providers.iot + +Iot provider that allows multiple applications to + share an IotDevice. + + + +org.apache.edgent.runtime.appservice + + + +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.mbeans + + + +org.apache.edgent.runtime.jobregistry + + + +org.apache.edgent.samples.connectors + +General support for connector samples. + + + +org.apache.edgent.topology.spi.tester + + + +org.apache.edgent.topology.tester + +Testing for a streaming topology. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.apps.runtime + +Class and Description + + + +DirectSubmitter +An interface for submission of an executable + that is executed directly within the current + virtual machine. + + + +Job +Actions and states for execution of an Edgent job. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.execution + +Class and Description + + + +Job +Actions and states for execution of an Edgent job. + + + +Job.Action +Actions which trigger Job.State transitions. + + + +Job.Health +Enumeration for the summarized health indicator of the graph nodes. + + + +Job.State +States of a graph job. + + + +Submitter +An interface for submission of an executable. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.execution.mbeans + +Class and Description + + + +Job.Action +Actions which trigger Job.State transitions. + + + +Job.Health +Enumeration for the summarized health indicator of the graph nodes. + + + +Job.State +States of a graph job. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.execution.services + +Class and Description + + + +Job +Actions and states for execution of an Edgent job. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.graph.spi.execution + +Class and Description + + + +Job +Actions and states for execution of an Edgent job. + + + +Job.Action +Actions which trigger Job.State transitions. + + + +Job.Health +Enumeration for the summarized health indicator of the graph nodes. + + + +Job.State +States of a graph job. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.providers.development + +Class and Description + + + +DirectSubmitter +An interface for submission of an executable + that is executed directly within the current + virtual machine. + + + +Job +Actions and states for execution of an Edgent job. + + + +Submitter +An interface for submission of an executable. + + + + + + + + + +Classes in org.apache.edgent.execution used by org.apache.edgent.providers.direct + +Class and Description + + + +DirectSubmitter +An interface for submission of an executable + that is executed directly within the current + virtual machine. + + +
[29/77] [partial] incubator-edgent-website git commit: EDGENT[334] update website for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/connectors/iotp/IotpGateway.html
--
diff --git
a/site/javadoc/r1.1.0/org/apache/edgent/connectors/iotp/IotpGateway.html
b/site/javadoc/r1.1.0/org/apache/edgent/connectors/iotp/IotpGateway.html
new file mode 100644
index 000..1ab45ce
--- /dev/null
+++ b/site/javadoc/r1.1.0/org/apache/edgent/connectors/iotp/IotpGateway.html
@@ -0,0 +1,999 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+IotpGateway (Edgent v1.1.0)
+
+
+
+
+
+
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+
+
+org.apache.edgent.connectors.iotp
+Class IotpGateway
+
+
+
+java.lang.Object
+
+
+org.apache.edgent.connectors.iotp.IotpGateway
+
+
+
+
+
+
+
+All Implemented Interfaces:
+IotDevice, IotGateway, TopologyElement
+
+
+
+public class IotpGateway
+extends java.lang.Object
+implements IotGateway
+An IoT Gateway Device Connector to IBM Watson IoT Platform
(WIoTP).
+
+ This class is incubating and is subject to change.
+
+ See IotpDevice
for common WIoTP documentation references.
+
+ IotpGateway establishes its own WIoTP
GatewayCallback
+ handler in its embedded or the passed in WIoTP GatewayClient.
+ An application can use
+ setExternalCallbackHandler
+ to also receive and process callbacks.
+
+ Limitations:
+
+ IotProvider and PublishSubscribeService do not
yet support
+ the gateway model. An IotProvider may be initialized with an IotpGateway
+ but the PublishSubscribeService mechanism will only publish events and receive
+ commands for the gateway device, not any of its connected devices.
+
+
+
+
+
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields
+
+Modifier and Type
+Field and Description
+
+
+static java.lang.String
+ATTR_DEVICE_ID
+WIoTP Device Id identifier key.
+
+
+
+static java.lang.String
+ATTR_DEVICE_TYPE
+WIoTP Device Type identifier key.
+
+
+
+
+
+
+
+Fields inherited from interfaceorg.apache.edgent.connectors.iot.IotDevice
+CMD_DEVICE,
CMD_FORMAT,
CMD_ID,
CMD_PAYLOAD,
CMD_TS,
RESERVED_ID_PREFIX
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors
+
+Constructor and Description
+
+
+IotpGateway(Topologytopology,
+ java.io.FileoptionsFile)
+Create a connector for the IoT gateway device specified by
optionsFile.
+
+
+
+IotpGateway(Topologytopology,
+ com.ibm.iotf.client.gateway.GatewayClientgatewayClient)
+Create a connector using the supplied WIoTP
DeviceClient.
+
+
+
+IotpGateway(Topologytopology,
+ java.util.Propertiesoptions)
+Create a connector for the IoT gateway device specified by
options.
+
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All MethodsInstance MethodsConcrete Methods
+
+Modifier and Type
+Method and Description
+
+
+TStreamcom.google.gson.JsonObject
+commands(java.lang.String...commands)
+Create a stream of device commands as JSON objects.
+
+
+
+TStreamcom.google.gson.JsonObject
+commandsForDevice(java.util.Setjava.lang.StringfqDeviceIds,
+ java.lang.String...commands)
+Create a stream of device commands as JSON objects.
+
+
+
+TStreamcom.google.gson.JsonObject
+commandsForDevice(java.lang.StringfqDeviceId,
+ java.lang.String...commands)
+Create a stream of device commands as JSON objects.
+
+
+
+TStreamcom.google.gson.JsonObject
+commandsForType(java.lang.StringdeviceTypeId,
+ java.lang.String...commands)
+Create a stream of device commands as JSON objects.
+
+
+
+TSinkcom.google.gson.JsonObject
+events(TStreamcom.google.gson.JsonObjectstream,
+ Functioncom.google.gson.JsonObject,java.lang.StringeventId,
+ UnaryOperatorcom.google.gson.JsonObjectpayload,
+ Functioncom.google.gson.JsonObject,java.lang.Integerqos)
+Publish a stream's tuples as device events.
+
+
+
+TSinkcom.google.gson.JsonObject
+events(TStreamcom.google.gson.JsonObjectstream,
+ java.lang.StringeventId,
+
[23/77] [partial] incubator-edgent-website git commit: EDGENT[334] update website for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/connectors/mqtt/iot/MqttDevice.html
--
diff --git
a/site/javadoc/r1.1.0/org/apache/edgent/connectors/mqtt/iot/MqttDevice.html
b/site/javadoc/r1.1.0/org/apache/edgent/connectors/mqtt/iot/MqttDevice.html
new file mode 100644
index 000..24b6dda
--- /dev/null
+++ b/site/javadoc/r1.1.0/org/apache/edgent/connectors/mqtt/iot/MqttDevice.html
@@ -0,0 +1,630 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+MqttDevice (Edgent v1.1.0)
+
+
+
+
+
+
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+
+
+org.apache.edgent.connectors.mqtt.iot
+Class MqttDevice
+
+
+
+java.lang.Object
+
+
+org.apache.edgent.connectors.mqtt.iot.MqttDevice
+
+
+
+
+
+
+
+All Implemented Interfaces:
+IotDevice, TopologyElement
+
+
+
+public class MqttDevice
+extends java.lang.Object
+implements IotDevice
+An MQTT based Edgent IotDevice connector.
+
+ The MQTT IotDevice is an abstraction on top of
+ the MqttStreams
connector.
+
+ The connector doesn't presume a particular pattern for
+ Device MQTT "event" topic and "command" topics though default
+ patterns are provided.
+
+ Connector configuration Properties fall into two categories:
+
+ MQTT Device abstraction properties
+ Base MQTT connector properties - see MqttConfig.fromProperties(Properties)
+
+
+ Device properties
+
+ mqttDevice.id - Required. An identifier that uniquely identifies
+ the device in the device event and device command MQTT topic namespaces.
+
+ mqttDevice.topic.prefix - A optional prefix that by default is used when
+ composing device event and command MQTT topics, and the client's MQTT
+ clientId. The default is no prefix.
+ mqttDevice.event.topic.pattern - Optional. The topic pattern used
+ for MQTT device event topics.
+ Defaults to
{mqttDevice.topic.prefix}id/{mqttDevice.id}/evt/{EVENTID}/fmt/json
+ The pattern must include {EVENTID} and must end with "/fmt/json".
+
+ mqttDevice.command.topic.pattern - Optional. The topic pattern used
+ for MQTT device command topics.
+ Defaults to
{mqttDevice.topic.prefix}id/{mqttDevice.id}/cmd/{COMMAND}/fmt/json
+ The pattern must include {COMMAND} and must end with "/fmt/json".
+
+ mqttDevice.command.qos - An optional MQTT QoS value for commands.
Defaults to 0.
+ mqttDevice.events.retain - Optional MQTT "retain" behavior for published
events. Defaults to false.
+ mqttDevice.mqtt.clientId - Optional value to use for the MQTT clientId.
+ Defaults to {mqttDevice.topic.prefix}id/{mqttDevice.id}.
+
+ Sample use:
+
+ // assuming a properties file containing at least:
+ // mqttDevice.id=012345678
+ // mqtt.serverURLs=tcp://myMqttBrokerHost:1883
+
+ String propsPath = path to properties file;
+ Properties properties = new Properties();
+ properties.load(Files.newBufferedReader(new File(propsPath).toPath()));
+
+ Topology t = new DirectProvider();
+ MqttDevice mqttDevice = new MqttDevice(t, properties);
+
+ // publish JSON "status" device event tuples every hour
+ TStreamJsonObject myStatusEvents = t.poll(myGetStatusAsJson(), 1,
TimeUnit.HOURS);
+ mqttDevice.events(myStatusEvents, "status", QoS.FIRE_AND_FORGET);
+
+ // handle a device command. In this example the payload is expected
+ // to be JSON and have a "value" property containing the new threshold.
+ mqttDevice.command("setSensorThreshold")
+ .sink(json -
setSensorThreshold(json.get(CMD_PAYLOAD).getAsJsonObject().get("value").getAsString());
+
+
+
+
+
+
+
+
+
+
+
+
+Field Summary
+
+
+
+
+Fields inherited from interfaceorg.apache.edgent.connectors.iot.IotDevice
+CMD_DEVICE,
CMD_FORMAT,
CMD_ID,
CMD_PAYLOAD,
CMD_TS,
RESERVED_ID_PREFIX
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors
+
+Constructor and Description
+
+
+MqttDevice(Topologytopology,
+ java.util.Propertiesproperties)
+Create an MqttDevice connector.
+
[15/77] [partial] incubator-edgent-website git commit: EDGENT[334] update website for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/PeriodMXBean.html
--
diff --git
a/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/PeriodMXBean.html
b/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/PeriodMXBean.html
new file mode 100644
index 000..ec6b906
--- /dev/null
+++ b/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/PeriodMXBean.html
@@ -0,0 +1,310 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+PeriodMXBean (Edgent v1.1.0)
+
+
+
+
+
+
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+
+
+org.apache.edgent.execution.mbeans
+Interface PeriodMXBean
+
+
+
+
+
+
+All Known Implementing Classes:
+PeriodicSource, SupplierPeriodicSource
+
+
+
+public interface PeriodMXBean
+Control mbean interface for an entity having an a time
period control.
+
+ This mbean lacks a TYPE declaration because it's
+ a generic control interface applicable to a variety of
+ object types (e.g., a stream or window).
+ The type of the associated object is to be used when
+ registering instances of this mbean with the
+ ControlService.
+
+
+See Also:
+Topology.poll(org.apache.edgent.function.Supplier,
long, TimeUnit)
+
+
+
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All MethodsInstance MethodsAbstract Methods
+
+Modifier and Type
+Method and Description
+
+
+long
+getPeriod()
+Get the period.
+
+
+
+java.util.concurrent.TimeUnit
+getUnit()
+Get the time unit for getPeriod().
+
+
+
+void
+setPeriod(longperiod)
+Set the period.
+
+
+
+void
+setPeriod(longperiod,
+ java.util.concurrent.TimeUnitunit)
+Set the period and unit
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Method Detail
+
+
+
+
+
+getPeriod
+longgetPeriod()
+Get the period.
+
+Returns:
+period
+
+
+
+
+
+
+
+
+getUnit
+java.util.concurrent.TimeUnitgetUnit()
+Get the time unit for getPeriod().
+
+Returns:
+time unit
+
+
+
+
+
+
+
+
+setPeriod
+voidsetPeriod(longperiod)
+Set the period.
+
+Parameters:
+period - the period
+
+
+
+
+
+
+
+
+setPeriod
+voidsetPeriod(longperiod,
+ java.util.concurrent.TimeUnitunit)
+Set the period and unit
+
+Parameters:
+period - the period
+unit - the TimeUnit of period
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+http://edgent.incubator.apache.org;>Apache
Edgent (incubating)
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+Copyright 2017 The Apache Software
Foundation. All Rights Reserved - 4744f56-20170226-1707
+
+
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/class-use/JobMXBean.html
--
diff --git
a/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/class-use/JobMXBean.html
b/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/class-use/JobMXBean.html
new file mode 100644
index 000..a0e3104
--- /dev/null
+++
b/site/javadoc/r1.1.0/org/apache/edgent/execution/mbeans/class-use/JobMXBean.html
@@ -0,0 +1,168 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+Uses of Interface org.apache.edgent.execution.mbeans.JobMXBean (Edgent
v1.1.0)
+
+
+
+
+
+
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
[21/77] [partial] incubator-edgent-website git commit: EDGENT[334] update website for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/connectors/pubsub/service/ProviderPubSub.html
--
diff --git
a/site/javadoc/r1.1.0/org/apache/edgent/connectors/pubsub/service/ProviderPubSub.html
b/site/javadoc/r1.1.0/org/apache/edgent/connectors/pubsub/service/ProviderPubSub.html
new file mode 100644
index 000..9c2a630
--- /dev/null
+++
b/site/javadoc/r1.1.0/org/apache/edgent/connectors/pubsub/service/ProviderPubSub.html
@@ -0,0 +1,348 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+ProviderPubSub (Edgent v1.1.0)
+
+
+
+
+
+
+var methods = {"i0":10,"i1":10,"i2":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+
+
+org.apache.edgent.connectors.pubsub.service
+Class ProviderPubSub
+
+
+
+java.lang.Object
+
+
+org.apache.edgent.connectors.pubsub.service.ProviderPubSub
+
+
+
+
+
+
+
+All Implemented Interfaces:
+PublishSubscribeService
+
+
+
+public class ProviderPubSub
+extends java.lang.Object
+implements PublishSubscribeService
+Publish subscribe service allowing exchange of streams
between jobs in a provider.
+
+
+
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors
+
+Constructor and Description
+
+
+ProviderPubSub()
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All MethodsInstance MethodsConcrete Methods
+
+Modifier and Type
+Method and Description
+
+
+Tvoid
+addSubscriber(java.lang.Stringtopic,
+ java.lang.ClassTstreamType,
+ ConsumerTsubscriber)
+Add a subscriber to a published topic.
+
+
+
+TConsumerT
+getPublishDestination(java.lang.Stringtopic,
+ java.lang.Class? super TstreamType)
+Get the destination for a publisher.
+
+
+
+void
+removeSubscriber(java.lang.Stringtopic,
+Consumer?subscriber)
+
+
+
+
+
+
+Methods inherited from classjava.lang.Object
+clone, equals, finalize, getClass, hashCode, notify, notifyAll,
toString, wait, wait, wait
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Constructor Detail
+
+
+
+
+
+ProviderPubSub
+publicProviderPubSub()
+
+
+
+
+
+
+
+
+
+Method Detail
+
+
+
+
+
+addSubscriber
+publicTvoidaddSubscriber(java.lang.Stringtopic,
+ java.lang.ClassTstreamType,
+ ConsumerTsubscriber)
+Description copied from
interface:PublishSubscribeService
+Add a subscriber to a published topic.
+
+Specified by:
+addSubscriberin
interfacePublishSubscribeService
+Type Parameters:
+T - Tuple type
+Parameters:
+topic - Topic to subscribe to.
+streamType - Type of the stream.
+subscriber - How to deliver published tuples to the
subscriber.
+
+
+
+
+
+
+
+
+getPublishDestination
+publicTConsumerTgetPublishDestination(java.lang.Stringtopic,
+ java.lang.Class? super
TstreamType)
+Description copied from
interface:PublishSubscribeService
+Get the destination for a publisher.
+ A publisher calls destination.accept(tuple) to publish
+ tuple to the topic.
+
+Specified by:
+getPublishDestinationin
interfacePublishSubscribeService
+Type Parameters:
+T - Tuple type
+Parameters:
+topic - Topic tuples will be published to.
+streamType - Type of the stream
+Returns:
+Consumer that is used to publish tuples.
+
+
+
+
+
+
+
+
+removeSubscriber
+publicvoidremoveSubscriber(java.lang.Stringtopic,
+ Consumer?subscriber)
+
+Specified by:
+removeSubscriberin
interfacePublishSubscribeService
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+http://edgent.incubator.apache.org;>Apache
Edgent (incubating)
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+Copyright 2017 The Apache Software
[35/77] [partial] incubator-edgent-website git commit: EDGENT[334] update website for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterFlushConfig.html -- diff --git a/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterFlushConfig.html b/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterFlushConfig.html new file mode 100644 index 000..3f87864 --- /dev/null +++ b/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterFlushConfig.html @@ -0,0 +1,222 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + +Uses of Class org.apache.edgent.connectors.file.FileWriterFlushConfig (Edgent v1.1.0) + + + + + + + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + + +Uses of Classorg.apache.edgent.connectors.file.FileWriterFlushConfig + + + + + +Packages that use FileWriterFlushConfig + +Package +Description + + + +org.apache.edgent.connectors.file + +File stream connector. + + + + + + + + + + +Uses of FileWriterFlushConfig in org.apache.edgent.connectors.file + +Methods in org.apache.edgent.connectors.file that return FileWriterFlushConfig + +Modifier and Type +Method and Description + + + +FileWriterFlushConfigT +FileWriterPolicy.getFlushConfig() +Get the policy's active file flush configuration + + + +static TFileWriterFlushConfigT +FileWriterFlushConfig.newConfig(intcntTuples, + longperiodMsec, + PredicateTtuplePredicate) +Create a new configuration. + + + +static TFileWriterFlushConfigT +FileWriterFlushConfig.newCountBasedConfig(intcntTuples) +same as newConfig(cntTuples, 0, null) + + + +static TFileWriterFlushConfigT +FileWriterFlushConfig.newImplicitConfig() +Create a new configuration. + + + +static TFileWriterFlushConfigT +FileWriterFlushConfig.newPredicateBasedConfig(PredicateTtuplePredicate) +same as newConfig(0, 0, tuplePredicate) + + + +static TFileWriterFlushConfigT +FileWriterFlushConfig.newTimeBasedConfig(longperiodMsec) +same as newConfig(0, periodMsec, null) + + + + + +Constructors in org.apache.edgent.connectors.file with parameters of type FileWriterFlushConfig + +Constructor and Description + + + +CompressedFileWriterPolicy(FileWriterFlushConfigTflushConfig, + FileWriterCycleConfigTcycleConfig, + FileWriterRetentionConfigretentionConfig) + + +FileWriterPolicy(FileWriterFlushConfigTflushConfig, +FileWriterCycleConfigTcycleConfig, +FileWriterRetentionConfigretentionConfig) +Create a new file writer policy instance. + + + + + + + + + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + +http://edgent.incubator.apache.org;>Apache Edgent (incubating) + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + +Copyright 2017 The Apache Software Foundation. All Rights Reserved - 4744f56-20170226-1707 + + http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/dbd20469/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterPolicy.html -- diff --git a/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterPolicy.html b/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterPolicy.html new file mode 100644 index 000..13c3570 --- /dev/null +++ b/site/javadoc/r1.1.0/org/apache/edgent/connectors/file/class-use/FileWriterPolicy.html @@ -0,0 +1,170 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + +Uses of Class org.apache.edgent.connectors.file.FileWriterPolicy (Edgent v1.1.0) + + + + + + + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames
[66/77] incubator-edgent-website git commit: update changes to latest for release 1.1.0
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/4db39ee8/site/javadoc/latest/org/apache/edgent/metrics/oplets/class-use/SingleMetricAbstractOplet.html -- diff --git a/site/javadoc/latest/org/apache/edgent/metrics/oplets/class-use/SingleMetricAbstractOplet.html b/site/javadoc/latest/org/apache/edgent/metrics/oplets/class-use/SingleMetricAbstractOplet.html index 0df2ef4..8934fa6 100644 --- a/site/javadoc/latest/org/apache/edgent/metrics/oplets/class-use/SingleMetricAbstractOplet.html +++ b/site/javadoc/latest/org/apache/edgent/metrics/oplets/class-use/SingleMetricAbstractOplet.html @@ -1,10 +1,10 @@ http://www.w3.org/TR/html4/loose.dtd;> - + - -Uses of Class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet (Edgent v1.0.0) - + +Uses of Class org.apache.edgent.metrics.oplets.SingleMetricAbstractOplet (Edgent v1.1.0) + @@ -12,7 +12,7 @@