7.7 StreamInput interface (common API)

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 valueMethod nameFunction
voidclose()Closes the connection to the input stream queue.
intgetFreeQueueSize()Acquires the amount of free space in the input stream queue.
intgetMaxQueueSize()Acquires the maximum size of the input stream queue.
booleanisStarted()In the data source mode, this method checks whether the input stream has started accepting new stream data.
voidput(ArrayList<StreamTuple> tuple_list)Sends multiple tuples.
voidput(StreamTuple tuple)Sends a single tuple.
voidputEnd()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