Index

_

__iadd__() (streamsx.ec.CustomMetric method)

__str__() (streamsx.spl.types.Timestamp method)

A

ActiveService (class in streamsx.rest_primitives) ActiveVersion (class in streamsx.rest_primitives) ActiveView (class in streamsx.rest_primitives) add() (streamsx.topology.context.JobConfig method) add_condition() (streamsx.topology.tester.Tester method)

ANALYTICS_SERVICE (streamsx.topology.context.ContextTypes attribute) as_string() (streamsx.topology.topology.Stream method) attribute() (streamsx.spl.op.Invoke method) (streamsx.spl.op.Map method) autonomous() (streamsx.topology.topology.Stream method)

B

Binary (streamsx.topology.schema.CommonSchema attribute) BUILD_ARCHIVE (streamsx.topology.context.ContextTypes 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) CommonSchema (class in streamsx.topology.schema) Condition (class in streamsx.topology.tester) ConfigParams (class in streamsx.rest) (class in streamsx.topology.context)

ConfiguredView (class in streamsx.rest_primitives) contents() (streamsx.topology.tester.Tester method) ContextTypes (class in streamsx.topology.context) Counter (streamsx.ec.MetricKind attribute) CustomMetric (class in streamsx.ec)

D

datetime() (streamsx.spl.types.Timestamp method) DISTRIBUTED (streamsx.topology.context.ContextTypes attribute)

Domain (class in streamsx.rest_primitives)

E

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) extend() (streamsx.topology.schema.CommonSchema method) (streamsx.topology.schema.StreamSchema method) ExtensionOperator (class in streamsx.topology.exop)

F

fail() (streamsx.topology.tester.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)

G

Gauge (streamsx.ec.MetricKind attribute) get_active_services() (streamsx.rest_primitives.Domain method) (streamsx.rest_primitives.Instance method) get_active_views() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_application_configuration() (in module streamsx.ec) get_configured_views() (streamsx.rest_primitives.Instance method) get_credentials() (streamsx.rest.VcapUtils static method) get_domain() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) (streamsx.rest_primitives.View method) get_domains() (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.StreamsConnection method) get_instance() (streamsx.rest_primitives.Job method) (streamsx.rest_primitives.View method) get_instances() (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Domain method) get_job() (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_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_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.StreamsConnection method) (streamsx.rest_primitives.Domain method) get_rest_api() (in module streamsx.st) get_rest_api_url_from_creds() (streamsx.rest.VcapUtils static method) get_streaming_analytics() (streamsx.rest.StreamsConnection method) get_vcap_services() (streamsx.rest.VcapUtils static method) get_view() (streamsx.rest.StreamsConnection method) get_view_items() (streamsx.rest_primitives.View method) get_view_obj() (in module streamsx.rest_primitives) get_views() (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method)

H

HASH_PARTITIONED (streamsx.topology.topology.Routing attribute)

Host (class in streamsx.rest_primitives)

I

identity() (in module streamsx.topology.functions) ignore() (in module streamsx.spl.spl) ImportedStream (class in streamsx.rest_primitives) initialize_rest() (streamsx.topology.topology.View method) Installation (class in streamsx.rest_primitives) Instance (class in streamsx.rest_primitives) 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) is_standalone() (in module streamsx.ec) isolate() (streamsx.topology.topology.Stream method)

J

Job (class in streamsx.rest_primitives) JOB_CONFIG (streamsx.topology.context.ConfigParams attribute) job_id() (in module streamsx.ec)

JobConfig (class in streamsx.topology.context) Json (streamsx.topology.schema.CommonSchema attribute) JUPYTER (streamsx.topology.context.ContextTypes attribute)

K

KEY_PARTITIONED (streamsx.topology.topology.Routing attribute)

L

local_channel() (in module streamsx.ec) local_max_channels() (in module streamsx.ec)

low_latency() (streamsx.topology.topology.Stream method)

M

machine_id (streamsx.spl.types.Timestamp attribute), [1] make_request() (streamsx.rest_primitives.StreamsRestClient method) Map (class in streamsx.spl.op) map (class in streamsx.spl.spl) map() (streamsx.topology.topology.Stream method)

max_channels() (in module streamsx.ec) Metric (class in streamsx.rest_primitives) MetricKind (class in streamsx.ec) MqttStreams (class in streamsx.topology.mqtt) multi_transform() (streamsx.topology.topology.Stream method)

N

name (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)

OpParam (class in streamsx.topology.param) output() (streamsx.spl.op.Invoke method) (streamsx.spl.op.Map method) (streamsx.spl.op.Source method)

P

parallel() (streamsx.topology.topology.Stream method) PE (class in streamsx.rest_primitives) pe_id() (in module streamsx.ec) PEConnection (class in streamsx.rest_primitives) pipe() (in module streamsx.spl.spl)

print() (streamsx.topology.topology.Stream method) print_flush() (in module streamsx.topology.functions) publish() (streamsx.topology.mqtt.MqttStreams method) (streamsx.topology.topology.Stream method) Python (streamsx.topology.schema.CommonSchema attribute)

R

Resource (class in streamsx.rest_primitives) ResourceAllocation (class in streamsx.rest_primitives) ResourceTag (class in streamsx.rest_primitives)

ROUND_ROBIN (streamsx.topology.topology.Routing attribute) Routing (class in streamsx.topology.topology)

S

schema() (streamsx.topology.schema.CommonSchema method) (streamsx.topology.schema.StreamSchema method) seconds (streamsx.spl.types.Timestamp attribute), [1] SERVICE_NAME (streamsx.rest.ConfigParams attribute) (streamsx.topology.context.ConfigParams attribute) set_streams_connection() (streamsx.topology.topology.View method) set_streams_connection_config() (streamsx.topology.topology.View method) setup_distributed() (streamsx.topology.tester.Tester static method) setup_standalone() (streamsx.topology.tester.Tester static method) setup_streaming_analytics() (streamsx.topology.tester.Tester method) Sink (class in streamsx.spl.op) 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.param.OpParam method) (streamsx.topology.schema.CommonSchema 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) stop_data_fetch() (streamsx.rest_primitives.View method) (streamsx.topology.topology.View method) str() (streamsx.topology.schema.CommonSchema method) (streamsx.topology.schema.StreamSchema method) Stream (class in streamsx.topology.topology) stream (streamsx.spl.op.Map attribute) (streamsx.spl.op.Source attribute) StreamingAnalyticsService (class in streamsx.rest_primitives) StreamSchema (class in streamsx.topology.schema) StreamsConnection (class in streamsx.rest)

StreamsRestClient (class in streamsx.rest_primitives) streamsx (module), [1] streamsx.ec (module) streamsx.rest (module) streamsx.rest_errors (module) streamsx.rest_primitives (module) streamsx.spl (module) streamsx.spl.op (module) streamsx.spl.spl (module) streamsx.spl.types (module) streamsx.st (module) streamsx.topology (module) streamsx.topology.context (module) streamsx.topology.exop (module) streamsx.topology.functions (module) streamsx.topology.mqtt (module) streamsx.topology.param (module) streamsx.topology.schema (module) streamsx.topology.tester (module) streamsx.topology.topology (module) String (streamsx.topology.schema.CommonSchema attribute) submit() (in module streamsx.topology.context) subscribe() (streamsx.topology.mqtt.MqttStreams method) (streamsx.topology.topology.Topology method)

T

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)

toolkit_dir() (in module streamsx.topology.param) Topology (class in streamsx.topology.topology) transform() (streamsx.topology.topology.Stream method) tuple() (streamsx.spl.types.Timestamp method) tuple_count() (streamsx.topology.tester.Tester method)

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) UnsupportedContextException

V

valid (streamsx.topology.tester.Condition attribute) value (streamsx.ec.CustomMetric attribute) VCAP_SERVICES (streamsx.rest.ConfigParams attribute) (streamsx.topology.context.ConfigParams attribute) VcapUtils (class in streamsx.rest) View (class in streamsx.rest_primitives) (class in streamsx.topology.topology)

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