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.

Organization of this section

close() method

getFreeQueueSize() method

getMaxQueueSize() method

isStarted() method

put(ArrayList<StreamTuple> tuple_list) method

put(StreamTuple tuple) method

putEnd() method