Explanation
This interface is used by a custom adaptor to send tuples to the SDP server.
The put method is used for sending tuples. Two types of put methods are available: one for sending multiple tuples in a batch and the other for sending a single tuple.
Method
The following table shows the StreamInput interface method list.
Return value | Method name | Function |
---|---|---|
void | close() | Closes the connection to the input stream queue. |
int | getFreeQueueSize() | Acquires the amount of free space in the input stream queue. |
int | getMaxQueueSize() | Acquires the maximum size of the input stream queue. |
boolean | isStarted() | In the data source mode, this method checks whether the input stream has started accepting new stream data. |
void | put(ArrayList<StreamTuple> tuple_list) | Sends multiple tuples. |
void | put(StreamTuple tuple) | Sends a single tuple. |
void | putEnd() | Notifies the input stream that the stream data input has ended. After an input completion notification is sent by this method and before a query group is resumed, if the put or putEnd method is executed, an exception is returned. |
Notes
None.