Adding an Input Stream or Window to a Project

Input streams and windows accept data from a source external to the project.

You can create an input stream or window by adding an adapter that supports schema discovery, and generating the stream or window to inherit the schema of the external data source automatically. You can then add columns as needed, and specify if they need an autogenerate clause. If an autogenerate clause is added, it can be used to automatically generate data for specified columns.

  1. In the Visual editor workspace, in the Palette menu under the Streams and Windows category, select either:
    • Input Stream input_stream.gif
    • Input Window input_window.gif
  2. Select a location in the diagram and click to add the shape.
  3. To set the name of the input stream or window, either:
    • Click to edit the shape name, or,
    • In verbose mode, click the Edit icon next to the name.
  4. Click Add Column column.gif to add each new column to the schema, then set key columns and edit column expressions.
  5. To delete columns, select them and press Delete.
  6. (Optional for windows, not permitted for streams) Select Set Keep Policy retention_window.gif and choose an option.
  7. (Optional) Double-click the policy to edit its parameters.
  8. (Optional for both windows and streams) Select Set Autogenerate retention_window.gif, choose the columns from the Candidate list (only columns with a datatype of Long will populate the Candidate list) and click Add.
    Note: You can also manually specify a column you want to add to the autogenerate list by clicking Add Column and entering in a column name. Only columns with a datatype of Long can be used.
  9. To remove columns from the autogenerate list, select them and click Remove.
  10. To set a From value for the autogenerate clause to start with, click Select and choose a variable or parameter from the list. You can also manually enter a variable or parameter that is used within a declare block of a column with a datatype of Long.
  11. Click OK when finished.
Related concepts
Specifying a Retention Policy
Related tasks
Editing Column Expressions for Windows, Streams, and Delta Streams
Setting an Aging Policy