IBM Streams 4.2.1

Namespace spl.compat

SPL standard and specialized toolkits > spl 1.3.0 > spl.compat

SPADE operators

The Stream Processing Application Declarative Engine (SPADE) language was introduced with the original release of IBM InfoSphere Streams. InfoSphere Streams V2.0 introduced a new Streams Programming Language (SPL) and new implementation of operators. Users of InfoSphere Streams V1.2 systems might want to do new development in SPL on a V2 Streams system, while leaving legacy code on a V1.2 Streams system. In some cases, users want to pass tuples from V1.2 to V2 or V2 to V1.2. This can be done for a subset of SPADE datatypes that are supported by SPL by connecting the two systems using TCP/IP connection. This uses two SPL operators V1TCPSink and V1TCPSource that know how to access V1.2 SPADE tuples. The SPL operators are connected to SPADE TCP Source or Sink operators, in order to pass the tuples between the systems.

Not all SPADE types are supported by SPL, and therefore cannot be passed between SPL and SPADE.

Supported Types

The following table contains SPADE types and the equivalent in SPL types for V1TCPSink and V1TCPSource:

Table 1. SPADE SPL types mapping

SPADE type

SPL type

Byte

int8

Short

int16

Integer

int32

Long

int64

Float

float32

Double

float64

Boolean

boolean

String

rstring

ByteList

list<int8>

ShortList

list<int16>

IntegerList

list<int32>

LongList

list<int64>

FloatList

list<float32>

DoubleList

list<float64>

BooleanList

list<boolean>

StringList

list<rstring>

ShortMatrix, IntegerMatrix, LongMatrix, FloatMatrix, DoubleMatrix, BooleanMatrix

Not supported by SPL. Not supported by V1TCPSource or V1TCPSink.

SPADE Tuples containing these supported types can be exported from a V1.2 instance and read by a V1TCPSource operator. SPL Tuples containing only types that map to SPADE types can be exported by using a V1TCPSink operator and read by a V1.2 instance.

Operators

  • V1TCPSink: The V1TCPSink operator writes binary data to a TCP socket that is connected to an InfoSphere Streams Version 1.2 TCP Source operator. It can be configured as a TCP server, which listens for a client connection, or as a TCP client, which initiates a connection to a server.
  • V1TCPSource: The V1TCPSource operator reads binary data from a TCP socket that is connected to a InfoSphere Streams Version 1.2 TCP Sink operator and creates tuples from that data.