IBM InfoSphere Streams Version 4.1.1

Operator control input port

SPL standard and specialized toolkits > com.ibm.streams.db 2.0.0 > Operator control input port

Many operators in the Database Toolkit provide the capability to specify an optional input port. This input port allows the configuration of the operator to be changed at run time without restarting or recompiling the application.

This input port is non-mutating and its punctuation mode is Oblivious. Final punctuations that are received on this port are not considered by the operator before it shuts down. Tuples received on this input port must contain either two rstring attributes or a map attribute, which contains two rstring elements. The coupled rstring elements represent a name and value configuration data pair:
  • The name attribute must contain a configuration option that supports runtime updates.
  • The value attribute must contain a new value that corresponds to the name attribute that is specified.
If map<rstring><rstring> is specified, updates to the name and value pairs in the map are processed atomically. For example, using a map ensures that no reconnection is made unless both the user name and password for a connection are updated. The following list contains the configuration options for operator control input ports:
  • connection.database:
    • Database names that are updated by using the input control port are not used until the next connection failure that follows the receipt of the updated password.
  • connection.user:
    • User IDs that are updated by using the input control port are not used until the next connection failure that follows the receipt of the updated password.
  • connection.password:
    • Passwords that are updated by using the input control port are not used until the next connection failure that follows the receipt of the updated password.
  • connection.reconnect:
    • Forces an immediate disconnection and reconnection after the control port receives this configuration option. The value attribute for this option is not required, and if it is specified, it is ignored.
    • This option overrides the behavior that is configured by the reconnectionPolicy parameter. If the connectionPolicy parameter is set to Deferred, this option forces an immediate disconnection but a reconnection does not occur until the next time that a connection is needed.
  • connection.disconnect:
    • Forces an immediate disconnection. The operator tries to reconnect the next time that a connection is needed. The value attribute for this option is not required, and if it is specified, it is ignored.
These options are supported for the following Database Toolkit operators:
  • DB2PartitionedAppend
  • DB2SplitDB
  • NetezzaLoad
  • ODBCAppend
  • ODBCEnrich
  • ODBCRun
  • ODBCSource