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_pip_package() (streamsx.topology.topology.Topology method) add_toolkit() (in module streamsx.spl.toolkit) add_toolkit_dependency() (in module streamsx.spl.toolkit) aggregate() (streamsx.topology.topology.Window method) aliased_as() (streamsx.topology.topology.Stream method) all_ports_ready() (streamsx.spl.spl.PrimitiveOperator method) ApplicationBundle (class in streamsx.rest_primitives) ApplicationConfiguration (class in streamsx.rest_primitives)

applicationName (streamsx.rest_primitives.Job attribute) applicationResource (streamsx.rest_primitives.ResourceAllocation attribute) architecture (streamsx.rest_primitives.ActiveVersion attribute) (streamsx.rest_primitives.Installation attribute) as_dict() (streamsx.topology.schema.StreamSchema method) as_json() (streamsx.topology.topology.Stream method) as_overlays() (streamsx.topology.context.JobConfig method) as_string() (streamsx.topology.topology.Stream method) as_tuple() (streamsx.topology.schema.StreamSchema 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

BaseImage (class in streamsx.rest_primitives) batch() (streamsx.topology.topology.Stream method) batchSeconds() (streamsx.topology.topology.Stream method) Binary (streamsx.topology.schema.CommonSchema attribute) BROADCAST (streamsx.topology.topology.Routing attribute) buffer_size (streamsx.service.EndpointSink attribute) (streamsx.service.EndpointSource attribute) bufferCapacitySeconds (streamsx.rest_primitives.View attribute) bufferCapacityTuples (streamsx.rest_primitives.View attribute)

bufferCapacityUnits (streamsx.rest_primitives.View attribute) Buffered (streamsx.topology.topology.SubscribeConnection attribute) build() (in module streamsx.topology.context) BUILD_ARCHIVE (streamsx.topology.context.ContextTypes attribute) build_version (streamsx.rest_primitives.ActiveVersion attribute) buildPool (streamsx.rest_primitives.BaseImage attribute) BuildService (class in streamsx.build) 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) cancel_job_button() (streamsx.topology.context.SubmissionResult method) catch_exceptions() (streamsx.topology.topology.Stream method) category() (streamsx.spl.op.Invoke property) (streamsx.spl.op.Map property) (streamsx.spl.op.Sink property) (streamsx.spl.op.Source property) (streamsx.topology.topology.Sink property) (streamsx.topology.topology.Stream property) channel() (in module streamsx.ec) checkpoint_period() (streamsx.topology.topology.Topology property) collectionTime (streamsx.rest_primitives.ViewItem attribute) colocate() (streamsx.spl.op.Invoke method) (streamsx.spl.op.Map method) (streamsx.spl.op.Sink method) (streamsx.spl.op.Source method) (streamsx.topology.topology.Sink method) (streamsx.topology.topology.Stream method) comment() (streamsx.topology.context.JobConfig property)

CommonSchema (class in streamsx.topology.schema) complete() (streamsx.topology.topology.PendingStream method) Composite (class in streamsx.topology.composite) Condition (class in streamsx.topology.tester_runtime) ConfigParams (class in streamsx.topology.context) ConsistentRegionConfig (class in streamsx.topology.state) ConsistentRegionConfig.Trigger (class in streamsx.topology.state) consuming_reads (streamsx.service.EndpointSink attribute) contents() (streamsx.topology.tester.Tester method) ContextTypes (class in streamsx.topology.context) count() (streamsx.spl.types.Timestamp method) Counter (streamsx.ec.MetricKind attribute) CP4D_URL (streamsx.topology.context.ConfigParams attribute) create_application_configuration() (streamsx.rest_primitives.Instance method) create_submission_parameter() (streamsx.topology.topology.Topology method) creationTime (streamsx.rest_primitives.ApplicationConfiguration attribute) (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) delete() (streamsx.rest_primitives.ApplicationConfiguration method) dependencies() (streamsx.rest_primitives.Toolkit property) description (streamsx.rest_primitives.ApplicationConfiguration attribute) (streamsx.rest_primitives.Metric attribute) (streamsx.rest_primitives.ResourceTag attribute) (streamsx.rest_primitives.View attribute)

Direct (streamsx.topology.topology.SubscribeConnection attribute) display() (streamsx.rest_primitives.View method) (streamsx.topology.topology.View method) displayName (streamsx.rest_primitives.Resource attribute) DISTRIBUTED (streamsx.topology.context.ContextTypes attribute) Domain (class in streamsx.rest_primitives) domain_id() (in module streamsx.ec)

E

EDGE (streamsx.topology.context.ContextTypes attribute) EDGE_BUNDLE (streamsx.topology.context.ContextTypes attribute) 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) endpoint_documentation (streamsx.service.EndpointSink attribute) (streamsx.service.EndpointSource attribute) EndpointSink (class in streamsx.service) EndpointSource (class in streamsx.service) eventual_result() (streamsx.topology.tester.Tester method)

exclude_packages (streamsx.topology.topology.Topology attribute) 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.CommonSchema method) (streamsx.topology.schema.StreamSchema method) extracting() (in module streamsx.spl.spl)

F

fetch_tuples() (streamsx.rest_primitives.View method) (streamsx.topology.topology.View 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) ForEach (class in streamsx.topology.composite) from_datetime() (streamsx.spl.types.Timestamp static method) from_overlays() (streamsx.topology.context.JobConfig static method) from_time() (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_configurations() (streamsx.rest_primitives.Instance method) get_application_directory() (in module streamsx.ec) get_base_images() (streamsx.build.BuildService method) get_connections() (streamsx.rest_primitives.OperatorInputPort method) (streamsx.rest_primitives.OperatorOutputPort method) 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_host() (streamsx.rest_primitives.Operator method) (streamsx.rest_primitives.PE 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_input_ports() (streamsx.rest_primitives.Operator 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.Operator method) (streamsx.rest_primitives.PE method) (streamsx.rest_primitives.View method) get_job_group() (streamsx.rest_primitives.Job method)

get_job_groups() (streamsx.rest_primitives.Instance method) get_jobs() (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.ResourceAllocation method) get_metrics() (streamsx.rest_primitives.Operator method) (streamsx.rest_primitives.OperatorInputPort method) (streamsx.rest_primitives.OperatorOutputPort method) (streamsx.rest_primitives.PE method) (streamsx.rest_primitives.Resource 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_output_ports() (streamsx.rest_primitives.Operator method) get_pe() (streamsx.rest_primitives.Operator 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) (streamsx.rest_primitives.ResourceAllocation method) get_published_topics() (streamsx.rest_primitives.Instance method) get_resource() (streamsx.rest_primitives.PE method) (streamsx.rest_primitives.ResourceAllocation method) (streamsx.rest_primitives.RestResource method) get_resource_allocation() (streamsx.rest_primitives.PE method) get_resource_allocations() (streamsx.rest_primitives.Domain method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.Job method) get_resources() (streamsx.build.BuildService method) (streamsx.rest.StreamingAnalyticsConnection method) (streamsx.rest.StreamsConnection method) (streamsx.rest_primitives.Domain method) get_streaming_analytics() (streamsx.rest.StreamingAnalyticsConnection method) get_streams_version() (streamsx.topology.tester.Tester static method) get_submission_time_value() (in module streamsx.ec) get_toolkit() (streamsx.build.BuildService method) get_toolkits() (streamsx.build.BuildService method) get_view_items() (streamsx.rest_primitives.View method) 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.BaseImage attribute) (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.Resource attribute) (streamsx.rest_primitives.Toolkit attribute) (streamsx.rest_primitives.View attribute) ignore() (in module streamsx.spl.spl) ImportedStream (class in streamsx.rest_primitives) include_packages (streamsx.topology.topology.Topology attribute) index() (streamsx.spl.types.Timestamp method) indexWithinJob (streamsx.rest_primitives.Operator attribute) (streamsx.rest_primitives.PE attribute) indexWithinOperator (streamsx.rest_primitives.OperatorInputPort attribute) (streamsx.rest_primitives.OperatorOutputPort attribute)

input_port (class in streamsx.spl.spl) 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) (streamsx.rest_primitives.Resource attribute) is_active() (in module streamsx.ec) is_common() (in module streamsx.topology.schema) 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 property) 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) lastModifiedTime (streamsx.rest_primitives.ApplicationConfiguration attribute) lastSeconds() (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) machine_id() (streamsx.spl.types.Timestamp property) main_composite() (in module streamsx.spl.op) Map (class in streamsx.spl.op) map (class in streamsx.spl.spl) Map (class in streamsx.topology.composite) 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) minimum_streams_version() (streamsx.topology.tester.Tester static method) minimumOSBaseVersion (streamsx.rest_primitives.Installation attribute) minimumOSPatchVersion (streamsx.rest_primitives.Installation attribute)

N

name (streamsx.rest_primitives.ApplicationConfiguration attribute) (streamsx.rest_primitives.BaseImage attribute) (streamsx.rest_primitives.Host attribute) (streamsx.rest_primitives.Job attribute) (streamsx.rest_primitives.Metric attribute) (streamsx.rest_primitives.Operator attribute) (streamsx.rest_primitives.OperatorInputPort attribute) (streamsx.rest_primitives.OperatorOutputPort attribute) (streamsx.rest_primitives.ResourceTag attribute) (streamsx.rest_primitives.RestResource attribute) (streamsx.rest_primitives.Toolkit attribute) (streamsx.rest_primitives.Toolkit.Dependency attribute) (streamsx.rest_primitives.View attribute)

name() (streamsx.topology.topology.Stream property) (streamsx.topology.topology.Topology property) name_to_runtime_id (streamsx.topology.topology.Topology attribute) namespace() (streamsx.topology.topology.Topology property) nanoseconds (streamsx.spl.types.Timestamp attribute) nanoseconds() (streamsx.spl.types.Timestamp property) now() (streamsx.spl.types.Timestamp static method) null() (in module streamsx.spl.types)

O

of_definition() (streamsx.rest.StreamingAnalyticsConnection static method) of_endpoint() (streamsx.build.BuildService static method) (streamsx.rest_primitives.Instance static method) of_service() (streamsx.build.BuildService static method) (streamsx.rest_primitives.Instance static method) Operator (class in streamsx.rest_primitives) OPERATOR_DRIVEN (streamsx.topology.state.ConsistentRegionConfig.Trigger attribute) operator_driven() (streamsx.topology.state.ConsistentRegionConfig static method) OperatorConnection (class in streamsx.rest_primitives)

OperatorInputPort (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 property) (streamsx.spl.op.Map property) (streamsx.spl.op.Sink property) (streamsx.spl.op.Source property) partition() (streamsx.topology.topology.Window method) path (streamsx.rest_primitives.Toolkit 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) PERIODIC (streamsx.topology.state.ConsistentRegionConfig.Trigger attribute) periodic() (streamsx.topology.state.ConsistentRegionConfig static method) populate() (streamsx.service.EndpointSink method) (streamsx.service.EndpointSource method) (streamsx.topology.composite.ForEach method) (streamsx.topology.composite.Map method) (streamsx.topology.composite.Source method)

prefix (streamsx.rest_primitives.BaseImage attribute) primitive_operator (class in streamsx.spl.spl) PrimitiveOperator (class in 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 (streamsx.rest_primitives.ApplicationConfiguration attribute) properties_definition (streamsx.rest_primitives.ResourceTag attribute) publish() (streamsx.topology.topology.Stream method) PublishedTopic (class in streamsx.rest_primitives) punct_count() (streamsx.topology.tester.Tester method) punctor() (streamsx.topology.topology.Stream method) Python (streamsx.topology.schema.CommonSchema attribute)

R

raw_overlay() (streamsx.topology.context.JobConfig property) refresh() (streamsx.rest_primitives.ActiveService method) (streamsx.rest_primitives.ApplicationBundle method) (streamsx.rest_primitives.ApplicationConfiguration method) (streamsx.rest_primitives.BaseImage 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.OperatorInputPort 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.RestResource method) (streamsx.rest_primitives.Toolkit method) (streamsx.rest_primitives.View method) (streamsx.rest_primitives.ViewItem method) registry (streamsx.rest_primitives.BaseImage attribute) relocatable (streamsx.rest_primitives.PE attribute) require_streams_version() (streamsx.topology.tester.Tester static method) required (streamsx.rest_primitives.OperatorConnection attribute) (streamsx.rest_primitives.PEConnection attribute) requiredConnections (streamsx.rest_primitives.PE attribute) requiredProductVersion (streamsx.rest_primitives.Toolkit attribute) reserved (streamsx.rest_primitives.ResourceTag attribute) resets() (streamsx.topology.tester.Tester method) Resource (class in streamsx.rest_primitives) resource (streamsx.rest_primitives.RestResource attribute) resource_tags() (streamsx.spl.op.Invoke property) (streamsx.spl.op.Map property) (streamsx.spl.op.Sink property) (streamsx.spl.op.Source property) (streamsx.topology.topology.Sink property) (streamsx.topology.topology.Stream property)

resource_url() (streamsx.build.BuildService property) (streamsx.rest.StreamingAnalyticsConnection property) (streamsx.rest.StreamsConnection property) ResourceAllocation (class in streamsx.rest_primitives) ResourceTag (class in streamsx.rest_primitives) resourceType (streamsx.rest_primitives.ActiveService attribute) (streamsx.rest_primitives.BaseImage 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.OperatorInputPort attribute) (streamsx.rest_primitives.OperatorOutputPort attribute) (streamsx.rest_primitives.PE attribute) (streamsx.rest_primitives.PEConnection attribute) (streamsx.rest_primitives.ResourceAllocation attribute) (streamsx.rest_primitives.Toolkit attribute) (streamsx.rest_primitives.View attribute) (streamsx.rest_primitives.ViewItem attribute) restartable (streamsx.rest_primitives.PE attribute) restid (streamsx.rest_primitives.BaseImage attribute) RestResource (class in streamsx.rest_primitives) restrictedTags (streamsx.rest_primitives.Host attribute) result (streamsx.topology.tester.Tester attribute) retrieve_console_log() (streamsx.rest_primitives.PE method) retrieve_log_trace() (streamsx.rest_primitives.Job method) retrieve_trace() (streamsx.rest_primitives.PE method) Returns (streamsx.service.EndpointSink attribute) (streamsx.service.EndpointSource attribute) ROUND_ROBIN (streamsx.topology.topology.Routing attribute) Routing (class in streamsx.topology.topology) rstring() (in module streamsx.spl.types) run() (in module streamsx.topology.context) run_for() (streamsx.topology.tester.Tester method) runtime_id() (streamsx.topology.topology.Stream property)

S

SC_OPTIONS (streamsx.topology.context.ConfigParams attribute) schedulerStatus (streamsx.rest_primitives.ResourceAllocation attribute) schema (streamsx.rest_primitives.PublishedTopic attribute) (streamsx.service.EndpointSource attribute) schema() (streamsx.topology.schema.CommonSchema method) (streamsx.topology.schema.StreamSchema method) seconds (streamsx.spl.types.Timestamp attribute) seconds() (streamsx.spl.types.Timestamp property) SERVICE_DEFINITION (streamsx.topology.context.ConfigParams attribute) service_documentation (streamsx.service.EndpointSink attribute) (streamsx.service.EndpointSource attribute) SERVICE_NAME (streamsx.topology.context.ConfigParams attribute) services (streamsx.rest_primitives.Host attribute) session (streamsx.rest.StreamsConnection attribute) set_consistent() (streamsx.topology.topology.Stream method) set_event_time() (streamsx.topology.topology.Stream method) set_parallel() (streamsx.topology.topology.Stream method) 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) shutdown() (in module streamsx.ec) Sink (class in streamsx.spl.op) (class in streamsx.topology.topology) Source (class in streamsx.spl.op) source (class in streamsx.spl.spl) Source (class in streamsx.topology.composite) source() (streamsx.topology.topology.Topology method) SPACE_NAME (streamsx.topology.context.ConfigParams attribute) space_name() (streamsx.topology.context.JobConfig property) split() (streamsx.topology.topology.Stream method) SSL_VERIFY (streamsx.topology.context.ConfigParams attribute) STANDALONE (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.Resource 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 property) (streamsx.spl.op.Source property) 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() (streamsx.topology.topology.Topology property) 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.build (module) streamsx.ec (module) streamsx.rest (module) streamsx.rest_primitives (module) streamsx.service (module) streamsx.spl.op (module) streamsx.spl.spl (module) streamsx.spl.toolkit (module) streamsx.spl.types (module) streamsx.topology (module) streamsx.topology.composite (module) streamsx.topology.context (module) streamsx.topology.schema (module) streamsx.topology.state (module) streamsx.topology.tester (module) streamsx.topology.tester_runtime (module) streamsx.topology.topology (module) String (streamsx.topology.schema.CommonSchema attribute) style() (streamsx.topology.schema.StreamSchema property) submission_parameters() (streamsx.topology.context.JobConfig property) submission_result (streamsx.topology.tester.Tester attribute) SubmissionResult (class in streamsx.topology.context) submit() (in module streamsx.topology.context) (streamsx.spl.spl.PrimitiveOperator method) submit_job() (streamsx.rest_primitives.ApplicationBundle method) (streamsx.rest_primitives.Instance method) (streamsx.rest_primitives.StreamingAnalyticsService method) submit_punct() (streamsx.spl.spl.PrimitiveOperator method) submitTime (streamsx.rest_primitives.Job attribute) subscribe() (streamsx.topology.topology.Topology method) SubscribeConnection (class in streamsx.topology.topology)

T

tag (streamsx.rest_primitives.BaseImage attribute) (streamsx.rest_primitives.Host attribute) tags (streamsx.rest_primitives.Resource attribute) target_pe_count() (streamsx.topology.context.JobConfig property) test() (streamsx.topology.tester.Tester method) Tester (class in streamsx.topology.tester) Time (streamsx.ec.MetricKind attribute) time() (streamsx.spl.types.Timestamp method) time_interval() (streamsx.topology.topology.Stream method) Timestamp (class in streamsx.spl.types) Toolkit (class in streamsx.rest_primitives)

TOOLKIT (streamsx.topology.context.ContextTypes attribute) Toolkit.Dependency (class in streamsx.rest_primitives) topic (streamsx.rest_primitives.PublishedTopic attribute) Topology (class in streamsx.topology.topology) tracing() (streamsx.topology.context.JobConfig property) tracingLevel (streamsx.rest_primitives.PE attribute) trigger() (streamsx.topology.topology.Window method) tuple_check() (streamsx.topology.tester.Tester method) tuple_count() (streamsx.topology.tester.Tester method) type (streamsx.rest_primitives.ActiveService attribute) type_checking (streamsx.topology.topology.Topology 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) update() (streamsx.rest_primitives.ApplicationConfiguration method) update_operators() (streamsx.rest_primitives.Job method) upload_bundle() (streamsx.rest_primitives.Instance method) upload_toolkit() (streamsx.build.BuildService method)

V

value (streamsx.rest_primitives.Metric attribute) value() (streamsx.ec.CustomMetric property) VCAP_SERVICES (streamsx.topology.context.ConfigParams attribute) version (streamsx.rest_primitives.Toolkit attribute) (streamsx.rest_primitives.Toolkit.Dependency attribute)

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

W

Window (class in streamsx.topology.topology)

X

XML (streamsx.topology.schema.CommonSchema attribute)