Properties reference: Streams connector

This topic lists all properties that you can set to configure the stage.

You can configure this stage in a dedicated configuration view. For more information, see the Selecting endpoint metadata in the InfoSphere Streams connector stage GUI topic.

Connection

For more information, see the Configuring the connection properties to connect to InfoSphere Streams name server (InfoSphere Streams connector) topic.

Connection name
Connection name is the value of the connectionName parameter in the DSSink or DSSource operator.
  • Type: string
Application scope
The name of the endpoint application scope defined by the InfoSphere Streams application main composite. This property is used in combination with the endpoint name property to look up entries in the Streams name server.
  • Type: string
Application name
Read only property that specifies the name of the Streams application providing the endpoint. It is the name of the main composite of the Streams application.
  • Type: string
Name server host
The InfoSphere Streams name server host.
  • Type: string
Name server port
The InfoSphere Streams name server port.
  • Type: integer
User name
The user name to connect to the InfoSphere Streams name server.
  • Type: string
Password
The password to use to connect to the InfoSphere Streams name server.
  • Type: protected string
Keystore file
The path to the keystore file containing the certificate for the InfoSphere Streams name server.
  • Type: string
Client authentication
If client authentication is enabled for the Streams Web Server, then this property should be set and a client certificate must be provided.
  • Type: boolean
Client certificate
The PKCS12 (p12) file that contains the client certificate.
  • Type: string
Certificate password
The password for the certificate file.
  • Type: protected string
Retry connection
If set to 'Yes' then the stage will repeatedly attempt to connect to the InfoSphere Streams job for the specified period to establish the initial connection.
  • Type: boolean
  • Default: true
Retry period
The total time period in seconds that the stage will try to connect.
  • Type: integer
  • Default: 60
  • Minimum: 1
Retry interval
The interval in seconds between attempts to connect.
  • Type: integer
  • Default: 5
  • Minimum: 1
Reconnect
Attempt to reconnect the connection to InfoSphere Streams if there is a connection failure.
  • Type: boolean
  • Default: true
Reconnect period
The total time period in seconds that the stage will try to connect after a connection failure.
  • Type: integer
  • Default: 60
  • Minimum: 1
Reconnect interval
The interval in seconds between attempts to connect after a connection failure.
  • Type: integer
  • Default: 5
  • Minimum: 1
Data receive timeout
The data receive timeout value specifies how long the connector will wait for incoming data before failing the job. Specify 0 to disable the receive timeout.
  • Type: integer
  • Default: 15
  • Minimum: 0

Usage

Transaction
Transaction properties
  • Type: category
Mark end of wave
Select 'Use record count' to generate an end-of-wave record after each wave of records where the number of records in each wave is specified in the Record count property. Select 'Map window punctuations' to generate an end-of-wave record when a window punctuation is received from Streams.
  • Type: selection
  • Default: No
  • Values:
    • No
    • Use record count
    • Map window punctuations
Record count
Number of records to include in a transactional wave
  • Type: integer
  • Default: 0
  • Minimum: 0
  • Maximum: 999999999
Schema reconciliation
Properties which define the action to take when the DataStage link schema does not exactly match the Streams tuple.
  • Type: category
Unmatched attribute
Select the action to take when the Streams tuple contains an attribute for which there is no corresponding column in the link schema.
  • Type: selection
  • Default: Warning
  • Values:
    • Ignore
    • Warning
    • Fail
Unmatched column
Select the action to take when the link schema contains a column for which there is no corresponding attribute in the Streams tuple.
  • Type: selection
  • Default: Warning
  • Values:
    • Ignore
    • Warning
    • Fail
Transaction
Transaction properties
  • Type: category
Send window punctuations
Select 'Yes' to send a window punctuation to Streams when an end-of-wave record is received.
  • Type: boolean
  • Default: false
Null values
Values to send to InfoSphere Streams to represent nulls.
  • Type: category
Integer
The value representing null for integer columns.
  • Type: integer
  • Default: 0
Decimal
The value representing null for decimal columns.
  • Type: decimal
  • Default: 0.0
String
The value representing null for string columns.
  • Type: string
Binary
The value representing null for binary columns. The value is specified as a hexadecimal string.
  • Type: string
  • Default: 00
Timestamp
The value representing null for timestamp columns. The value is a number of seconds since the Epoch.
  • Type: integer
  • Default: 0
XML
The value representing null for xml columns.
  • Type: string
Boolean
The value representing null for boolean columns.
  • Type: selection
  • Default: False
  • Values:
    • False
    • True