Sink (Apache Calcite API)

All Known Subinterfaces:

DruidConnectionImpl.RunnableQueueSink

All Known Implementing Classes:

Interpreter.DuplicatingSink, Interpreter.ListSink
```
public interface Sink
```
Sink to which to send rows.
Corresponds to an output of a relational expression.

Method Summary

All Methods Instance Methods Abstract Methods Deprecated Methods
Modifier and Type	Method	Description
`void`	`end()`
`void`	`send(Row row)`
`void`	`setSourceEnumerable(Enumerable<Row> enumerable)`	Deprecated.

Method Detail

send

void send(Row row)
   throws java.lang.InterruptedException

Throws:: java.lang.InterruptedException

end

void end()
  throws java.lang.InterruptedException

Throws:: java.lang.InterruptedException

setSourceEnumerable
```
@Deprecated
void setSourceEnumerable(Enumerable<Row> enumerable)
                  throws java.lang.InterruptedException
```
Deprecated.

This method is temporary. It will be removed without notice.

Throws:

java.lang.InterruptedException