Package org.apache.calcite.interpreter
Interface Sink
public interface Sink
Sink to which to send rows.
Corresponds to an output of a relational expression.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
end()
void
void
setSourceEnumerable
(Enumerable<Row> enumerable) Deprecated.
-
Method Details
-
send
- Throws:
InterruptedException
-
end
- Throws:
InterruptedException
-
setSourceEnumerable
Deprecated.This method is temporary. It will be removed without notice.- Throws:
InterruptedException
-