Index

A

activateOption (streamsx.rest_primitives.View attribute) ActiveService (class in streamsx.rest_primitives) ActiveVersion (class in streamsx.rest_primitives) add() (streamsx.topology.context.JobConfig method) add_condition() (streamsx.topology.tester.Tester method) add_file_dependency() (streamsx.topology.topology.Topology method) add_toolkit() (in module streamsx.spl.toolkit) ANALYTICS_SERVICE (streamsx.topology.context.ContextTypes attribute) applicationName (streamsx.rest_primitives.Job attribute) applicationResource (streamsx.rest_primitives.ResourceAllocation attribute)

architecture (streamsx.rest_primitives.ActiveVersion attribute) (streamsx.rest_primitives.Installation attribute) args (streamsx.rest_errors.ViewNotFoundError attribute) as_json() (streamsx.topology.topology.Stream method) as_string() (streamsx.topology.topology.Stream method) attribute() (streamsx.spl.op.Invoke method) (streamsx.spl.op.Map method) (streamsx.spl.op.Sink method) (streamsx.spl.op.Source method) autonomous() (streamsx.topology.topology.Stream method)

B

Binary (streamsx.topology.schema.CommonSchema attribute) bufferCapacitySeconds (streamsx.rest_primitives.View attribute) bufferCapacityTuples (streamsx.rest_primitives.View attribute) bufferCapacityUnits (streamsx.rest_primitives.View attribute)

BUILD_ARCHIVE (streamsx.topology.context.ContextTypes attribute) build_version (streamsx.rest_primitives.ActiveVersion attribute) buildVersion (streamsx.rest_primitives.Installation attribute) BUNDLE (streamsx.topology.context.ContextTypes attribute)

C

cancel() (streamsx.rest_primitives.Job method) cancel_job() (streamsx.rest_primitives.StreamingAnalyticsService method) channel() (in module streamsx.ec) collectionTime (streamsx.rest_primitives.ViewItem attribute) CommonSchema (class in streamsx.topology.schema) complete() (streamsx.topology.topology.PendingStream method) Condition (class in streamsx.topology.tester_runtime) ConfigParams (class in streamsx.topology.context)

contents() (streamsx.topology.tester.Tester method) ContextTypes (class in streamsx.topology.context) Counter (streamsx.ec.MetricKind attribute) creationTime (streamsx.rest_primitives.Domain attribute) (streamsx.rest_primitives.Instance attribute) creationuser (streamsx.rest_primitives.Domain attribute) (streamsx.rest_primitives.Instance attribute) CustomMetric (class in streamsx.ec)

D

data (streamsx.rest_primitives.ViewItem attribute) datetime() (streamsx.spl.types.Timestamp method) definition_format_properties (streamsx.rest_primitives.ResourceTag attribute) description (streamsx.rest_primitives.Metric attribute) (streamsx.rest_primitives.ResourceTag attribute) (streamsx.rest_primitives.View attribute)

DISTRIBUTED (streamsx.topology.context.ContextTypes attribute) Domain (class in streamsx.rest_primitives) domain_id() (in module streamsx.ec)

E

edition_name (streamsx.rest_primitives.ActiveVersion attribute) editionName (streamsx.rest_primitives.Installation attribute) end_low_latency() (streamsx.topology.topology.Stream method) end_parallel() (streamsx.topology.topology.Stream method) ExportedStream (class in streamsx.rest_primitives) Expression (class in streamsx.spl.op)

expression() (streamsx.spl.op.Expression static method) (streamsx.spl.op.Invoke method) (streamsx.spl.op.Map method) (streamsx.spl.op.Sink method) (streamsx.spl.op.Source method) extend() (streamsx.topology.schema.StreamSchema method)

F

fail() (streamsx.topology.tester_runtime.Condition method) filter (class in streamsx.spl.spl) filter() (streamsx.topology.topology.Stream method) flat_map() (streamsx.topology.topology.Stream method) float32() (in module streamsx.spl.types) float64() (in module streamsx.spl.types)

for_each (class in streamsx.spl.spl) for_each() (streamsx.topology.topology.Stream method) FORCE_REMOTE_BUILD (streamsx.topology.context.ConfigParams attribute) from_datetime() (streamsx.spl.types.Timestamp static method) full_product_version (streamsx.rest_primitives.ActiveVersion attribute) fullProductVersion (streamsx.rest_primitives.Installation attribute)

G

Gauge (streamsx.ec.MetricKind attribute) get_active_services() (streamsx.rest_primitives.Domain method) (streamsx.rest_primitives.Instance method) get_application_configuration() (in module streamsx.ec) get_application_directory() (in module streamsx.ec) get_domain() (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) (streamsx.rest_primitives.View method) get_domains() (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) get_exported_streams() (streamsx.rest_primitives.Instance method) get_hosts() (streamsx.rest_primitives.Domain method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_imported_streams() (streamsx.rest_primitives.Instance method) get_installations() (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) get_instance() (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Job method) (streamsx.rest_primitives.View method) get_instance_status() (streamsx.rest_primitives.StreamingAnalyticsService method) get_instances() (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Domain method)

get_job() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.View method) get_jobs() (streamsx.rest_primitives.Instance method) get_metrics() (streamsx.rest_primitives.Operator method) get_operator_connections() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_operator_output_port() (streamsx.rest_primitives.ExportedStream method) get_operators() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_pe_connections() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_pes() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_published_topics() (streamsx.rest_primitives.Instance method) get_resource() (streamsx.rest_primitives.Resource method) get_resource_allocations() (streamsx.rest_primitives.Domain method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_resources() (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Domain method) get_streaming_analytics() (streamsx.rest.StreamingAnalyticsConnection method) get_view_items() (streamsx.rest_primitives.View method) get_view_obj() (in module streamsx.rest_primitives) get_views() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method)

H

HASH_PARTITIONED (streamsx.topology.topology.Routing attribute) health (streamsx.rest_primitives.Instance attribute) (streamsx.rest_primitives.Job attribute) (streamsx.rest_primitives.PE attribute)

Host (class in streamsx.rest_primitives)

I

id (streamsx.rest_primitives.Domain attribute) (streamsx.rest_primitives.Instance attribute) (streamsx.rest_primitives.Job attribute) (streamsx.rest_primitives.OperatorConnection attribute) (streamsx.rest_primitives.PE attribute) (streamsx.rest_primitives.PEConnection attribute) (streamsx.rest_primitives.View attribute) ignore() (in module streamsx.spl.spl) ImportedStream (class in streamsx.rest_primitives) indexWithinJob (streamsx.rest_primitives.Operator attribute) (streamsx.rest_primitives.PE attribute) indexWithinOperator (streamsx.rest_primitives.OperatorOutputPort attribute)

initialize_rest() (streamsx.topology.topology.View method) Installation (class in streamsx.rest_primitives) Instance (class in streamsx.rest_primitives) instance_id() (in module streamsx.ec) int16() (in module streamsx.spl.types) int32() (in module streamsx.spl.types) int64() (in module streamsx.spl.types) int8() (in module streamsx.spl.types) Invoke (class in streamsx.spl.op) ipAddress (streamsx.rest_primitives.Host attribute) is_complete() (streamsx.topology.topology.PendingStream method) is_standalone() (in module streamsx.ec) isolate() (streamsx.topology.topology.Stream method)

J

Job (class in streamsx.rest_primitives) job (streamsx.topology.context.SubmissionResult attribute) JOB_CONFIG (streamsx.topology.context.ConfigParams attribute)

job_id() (in module streamsx.ec) JobConfig (class in streamsx.topology.context) jobGroup (streamsx.rest_primitives.Job attribute) Json (streamsx.topology.schema.CommonSchema attribute)

K

KEY_PARTITIONED (streamsx.topology.topology.Routing attribute)

L

last() (streamsx.topology.topology.Stream method) lastTimeRetrieved (streamsx.rest_primitives.Metric attribute) launchCount (streamsx.rest_primitives.PE attribute) leader (streamsx.rest_primitives.ActiveService attribute)

local_channel() (in module streamsx.ec) local_check() (streamsx.topology.tester.Tester method) local_max_channels() (in module streamsx.ec) logicalOperatorName (streamsx.rest_primitives.View attribute) low_latency() (streamsx.topology.topology.Stream method)

M

machine_id (streamsx.spl.types.Timestamp attribute), [1] main() (in module streamsx.scripts.runner) Map (class in streamsx.spl.op) map (class in streamsx.spl.spl) map() (streamsx.topology.topology.Stream method) max_channels() (in module streamsx.ec) maximumTupleRate (streamsx.rest_primitives.View attribute) Metric (class in streamsx.rest_primitives)

MetricKind (class in streamsx.ec) metricKind (streamsx.rest_primitives.Metric attribute) metricType (streamsx.rest_primitives.Metric attribute) minimum_os_base_version (streamsx.rest_primitives.ActiveVersion attribute) minimum_os_patch_version (streamsx.rest_primitives.ActiveVersion attribute) minimumOSBaseVersion (streamsx.rest_primitives.Installation attribute) minimumOSPatchVersion (streamsx.rest_primitives.Installation attribute) MqttStreams (class in streamsx.topology.mqtt) multi_transform() (streamsx.topology.topology.Stream method)

N

name (streamsx.rest_primitives.Host attribute) (streamsx.rest_primitives.Job attribute) (streamsx.rest_primitives.Metric attribute) (streamsx.rest_primitives.Operator attribute) (streamsx.rest_primitives.OperatorOutputPort attribute) (streamsx.rest_primitives.Resource attribute) (streamsx.rest_primitives.ResourceTag attribute) (streamsx.rest_primitives.View attribute) (streamsx.topology.topology.Stream attribute) (streamsx.topology.topology.Topology attribute)

namespace (streamsx.topology.topology.Topology attribute) nanoseconds (streamsx.spl.types.Timestamp attribute), [1]

O

Operator (class in streamsx.rest_primitives) OperatorConnection (class in streamsx.rest_primitives) operatorKind (streamsx.rest_primitives.Operator attribute) OperatorOutputPort (class in streamsx.rest_primitives) optionalConnections (streamsx.rest_primitives.PE attribute)

output() (streamsx.spl.op.Invoke method) (streamsx.spl.op.Map method) (streamsx.spl.op.Sink method) (streamsx.spl.op.Source method) owner (streamsx.rest_primitives.Instance attribute)

P

parallel() (streamsx.topology.topology.Stream method) params (streamsx.spl.op.Invoke attribute) (streamsx.spl.op.Map attribute) (streamsx.spl.op.Sink attribute) (streamsx.spl.op.Source attribute) PE (class in streamsx.rest_primitives) pe_id() (in module streamsx.ec) PEConnection (class in streamsx.rest_primitives) PendingStream (class in streamsx.topology.topology) pendingTracingLevel (streamsx.rest_primitives.PE attribute) pipe() (in module streamsx.spl.spl) print() (streamsx.topology.topology.Stream method)

processId (streamsx.rest_primitives.ActiveService attribute) (streamsx.rest_primitives.PE attribute) processorCount (streamsx.rest_primitives.Host attribute) product_name (streamsx.rest_primitives.ActiveVersion attribute) product_version (streamsx.rest_primitives.ActiveVersion attribute) productName (streamsx.rest_primitives.Installation attribute) productVersion (streamsx.rest_primitives.Installation attribute) properties_definition (streamsx.rest_primitives.ResourceTag attribute) publish() (streamsx.topology.mqtt.MqttStreams method) (streamsx.topology.topology.Stream method) PublishedTopic (class in streamsx.rest_primitives) Python (streamsx.topology.schema.CommonSchema attribute)

R

refresh() (streamsx.rest_primitives.ActiveService method) (streamsx.rest_primitives.Domain method) (streamsx.rest_primitives.ExportedStream method) (streamsx.rest_primitives.Host method) (streamsx.rest_primitives.ImportedStream method) (streamsx.rest_primitives.Installation method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) (streamsx.rest_primitives.Metric method) (streamsx.rest_primitives.Operator method) (streamsx.rest_primitives.OperatorConnection method) (streamsx.rest_primitives.OperatorOutputPort method) (streamsx.rest_primitives.PE method) (streamsx.rest_primitives.PEConnection method) (streamsx.rest_primitives.Resource method) (streamsx.rest_primitives.ResourceAllocation method) (streamsx.rest_primitives.View method) (streamsx.rest_primitives.ViewItem method) relocatable (streamsx.rest_primitives.PE attribute) replaceTokenInFile() (in module streamsx.scripts.extract) required (streamsx.rest_primitives.OperatorConnection attribute) (streamsx.rest_primitives.PEConnection attribute) requiredConnections (streamsx.rest_primitives.PE attribute) reserved (streamsx.rest_primitives.ResourceTag attribute) Resource (class in streamsx.rest_primitives) resource_tags (streamsx.topology.topology.Stream attribute)

resource_url (streamsx.rest.StreamingAnalyticsConnection attribute) (streamsx.rest.StreamsConnection attribute) ResourceAllocation (class in streamsx.rest_primitives) ResourceTag (class in streamsx.rest_primitives) resourceType (streamsx.rest_primitives.ActiveService attribute) (streamsx.rest_primitives.Domain attribute) (streamsx.rest_primitives.ExportedStream attribute) (streamsx.rest_primitives.Host attribute) (streamsx.rest_primitives.ImportedStream attribute) (streamsx.rest_primitives.Installation attribute) (streamsx.rest_primitives.Instance attribute) (streamsx.rest_primitives.Job attribute) (streamsx.rest_primitives.Metric attribute) (streamsx.rest_primitives.Operator attribute) (streamsx.rest_primitives.OperatorConnection attribute) (streamsx.rest_primitives.OperatorOutputPort attribute) (streamsx.rest_primitives.PE attribute) (streamsx.rest_primitives.PEConnection attribute) (streamsx.rest_primitives.ResourceAllocation attribute) (streamsx.rest_primitives.View attribute) (streamsx.rest_primitives.ViewItem attribute) restartable (streamsx.rest_primitives.PE attribute) restrictedTags (streamsx.rest_primitives.Host attribute) ROUND_ROBIN (streamsx.topology.topology.Routing attribute) Routing (class in streamsx.topology.topology) rstring() (in module streamsx.spl.types)

S

schedulerStatus (streamsx.rest_primitives.ResourceAllocation attribute) schema (streamsx.rest_primitives.PublishedTopic attribute) schema() (streamsx.topology.schema.StreamSchema method) seconds (streamsx.spl.types.Timestamp attribute), [1] SERVICE_NAME (streamsx.topology.context.ConfigParams attribute) services (streamsx.rest_primitives.Host attribute) session (streamsx.rest.StreamsConnection attribute) setup_distributed() (streamsx.topology.tester.Tester static method) setup_standalone() (streamsx.topology.tester.Tester static method) setup_streaming_analytics() (streamsx.topology.tester.Tester static method) Sink (class in streamsx.spl.op) (class in streamsx.topology.topology) sink() (in module streamsx.spl.spl) (streamsx.topology.topology.Stream method) Source (class in streamsx.spl.op) source (class in streamsx.spl.spl) source() (streamsx.topology.topology.Topology method) spl_json() (streamsx.spl.op.Expression method) (streamsx.topology.schema.StreamSchema method) STANDALONE (streamsx.topology.context.ContextTypes attribute) STANDALONE_BUNDLE (streamsx.topology.context.ContextTypes attribute) start_data_fetch() (streamsx.rest_primitives.View method) (streamsx.topology.topology.View method) start_instance() (streamsx.rest_primitives.StreamingAnalyticsService method) startedBy (streamsx.rest_primitives.Job attribute) startTime (streamsx.rest_primitives.ActiveService attribute) (streamsx.rest_primitives.Instance attribute) status (streamsx.rest_primitives.ActiveService attribute) (streamsx.rest_primitives.Domain attribute) (streamsx.rest_primitives.Host attribute) (streamsx.rest_primitives.Instance attribute) (streamsx.rest_primitives.Job attribute) (streamsx.rest_primitives.PE attribute) (streamsx.rest_primitives.PEConnection attribute) (streamsx.rest_primitives.ResourceAllocation attribute) statusReason (streamsx.rest_primitives.PE attribute) stop_data_fetch() (streamsx.rest_primitives.View method) (streamsx.topology.topology.View method)

stop_instance() (streamsx.rest_primitives.StreamingAnalyticsService method) Stream (class in streamsx.topology.topology) stream (streamsx.spl.op.Map attribute) (streamsx.spl.op.Source attribute) STREAMING_ANALYTICS_SERVICE (streamsx.topology.context.ContextTypes attribute) StreamingAnalyticsConnection (class in streamsx.rest) StreamingAnalyticsService (class in streamsx.rest_primitives) streamName (streamsx.rest_primitives.OperatorOutputPort attribute) STREAMS_CONNECTION (streamsx.topology.context.ConfigParams attribute) streams_connection (streamsx.topology.tester.Tester attribute) StreamSchema (class in streamsx.topology.schema) StreamsConnection (class in streamsx.rest) streamsx (module), [1] streamsx.ec (module) streamsx.rest (module) streamsx.rest_errors (module) streamsx.rest_primitives (module) streamsx.scripts (module) streamsx.scripts.extract (module) streamsx.scripts.runner (module) streamsx.spl (module) streamsx.spl.op (module) streamsx.spl.spl (module) streamsx.spl.toolkit (module) streamsx.spl.types (module) streamsx.topology (module) streamsx.topology.context (module) streamsx.topology.mqtt (module) streamsx.topology.schema (module) streamsx.topology.tester (module) streamsx.topology.tester_runtime (module) streamsx.topology.topology (module) String (streamsx.topology.schema.CommonSchema attribute) submission_result (streamsx.topology.tester.Tester attribute) SubmissionResult (class in streamsx.topology.context) submit() (in module streamsx.topology.context) submitTime (streamsx.rest_primitives.Job attribute) subscribe() (streamsx.topology.mqtt.MqttStreams method) (streamsx.topology.topology.Topology method)

T

tag (streamsx.rest_primitives.Host attribute) target_pe_count (streamsx.topology.context.JobConfig attribute) test() (streamsx.topology.tester.Tester method) Tester (class in streamsx.topology.tester) Time (streamsx.ec.MetricKind attribute) time() (streamsx.spl.types.Timestamp method) Timestamp (class in streamsx.spl.types) TOOLKIT (streamsx.topology.context.ContextTypes attribute) topic (streamsx.rest_primitives.PublishedTopic attribute)

Topology (class in streamsx.topology.topology) tracing (streamsx.topology.context.JobConfig attribute) tracingLevel (streamsx.rest_primitives.PE attribute) transform() (streamsx.topology.topology.Stream method) trigger() (streamsx.topology.topology.Window method) tuple() (streamsx.spl.types.Timestamp method) tuple_check() (streamsx.topology.tester.Tester method) tuple_count() (streamsx.topology.tester.Tester method) type (streamsx.rest_primitives.ActiveService attribute)

U

uint16() (in module streamsx.spl.types) uint32() (in module streamsx.spl.types)

uint64() (in module streamsx.spl.types) uint8() (in module streamsx.spl.types) union() (streamsx.topology.topology.Stream method)

V

valid (streamsx.topology.tester_runtime.Condition attribute) value (streamsx.ec.CustomMetric attribute) (streamsx.rest_primitives.Metric attribute) VCAP_SERVICES (streamsx.topology.context.ConfigParams attribute)

View (class in streamsx.rest_primitives) (class in streamsx.topology.topology) view() (streamsx.topology.topology.Stream method) ViewItem (class in streamsx.rest_primitives) ViewNotFoundError

W

Window (class in streamsx.topology.topology)

with_traceback() (streamsx.rest_errors.ViewNotFoundError method)

X

XML (streamsx.topology.schema.CommonSchema attribute)