Field | Description/Action |
Alias | The alias for table or stream is assigned automatically when you select more than one table in the Name field. The default value is t1. Note: There cannot be more than two tables. It can be a combination of one stream and one table. |
Name | Select a table or a stream name. |
Type | Displays the type of source you select, that is, table or stream. |
Field | Description/Action |
WITHIN Type | Fixed or Interval. If you select Fixed as WITHIN Type, then the 'within' type integer will appear under input parameters of the service. This is equivalent to WITHIN N Timeunit. If you select Interval as WITHIN Type, then the 'within' type document will have before and after runtime parameters. This is equivalent to WITHIN(before Timeunit, after Timeunit). |
WITHIN Timeunit | The time unit for the window. Valid values like DAY, DAYS, HOUR, HOURS, SECONDS and so on. |
Field | Description/Action |
Column | The column name in the table or stream. |
Column Type | The column data type defined in the table or stream. |
Output Field Type | The data type of the output field. Adapter for Apache Kafka automatically converts table or stream-specific types to Java data types. |
Output Field | The name of the field containing the output from the SELECT operation. An output field name displays when you select an expression. You can also modify the output field names as required. |
LIMIT | Specifies the number of records to retrieve from the streams or tables. The default value is 1. Note: $limit overrides the design time depending on the given limit value. The service execution continues until the specified number of records are retrieved. |
GROUP BY | Selects the column in which GROUP BY needs to be applied. |
WINDOW | The type of window for the SELECT query such as SESSION, HOPPING, and TUMBLING. |
Window Time Unit | The time unit for the window. Valid values like DAY, DAYS, HOUR, HOURS, SECONDS and so on. |
Field | Description/Action |
AND/OR | The logical operator. |
Column | The name of the column you want to use in the WHERE clause. |
Operator | The operator used with the Column and Input Field. |
Input Field | The default value is ?, that acts as a placeholder for the variable so that you can set the input variable for that column at run time, or get input external to this adapter service. You can also type a fixed value in this field now or at run time. If you type a fixed value, be sure that it is valid, or an exception will be generated at run time. |
Field | Description |
Parameter | The number of the inserted row. |
Column (second occurrence of this field) | The name of the column you want to use in the WHERE clause. |
Input Field Type | The corresponding input field's Java type. |
Input Field (second occurrence of this field) | The name of the input field. By default the name combines the values of the Parameter and Column fields. However, you can also specify a custom value. |