public interface StreamingPreparedStatement extends StreamingStatement
This interface extends
PreparedStatement
and StreamingStatement
to include methods for sending rowtime bounds.
TIMEOUT_NO_WAIT
Modifier and Type | Method and Description |
---|---|
default void |
enableImplicitRowtime()
Causes rowtime to be set automatically.
|
void |
flush()
Flushes all rows to stream.
|
void |
notifyUdxOnCancel(java.lang.Runnable notifier) |
void |
setRowtimeBound(java.sql.Timestamp bound)
Sets the rowtime bound for the current stream.
|
void |
setRowtimeBound(java.sql.Timestamp bound,
java.util.Calendar cal)
Sets the rowtime bound for the current stream.
|
void |
setUdxExitWithoutWait(boolean noWait) |
getQueryTimeoutMillis, getRowtimeBound, getStatementId, setQueryTimeoutMillis
addBatch, cancel, clearBatch, clearWarnings, close, closeOnCompletion, execute, execute, execute, execute, executeBatch, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getConnection, getFetchDirection, getFetchSize, getGeneratedKeys, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout
void setRowtimeBound(java.sql.Timestamp bound) throws java.sql.SQLException
bound
.bound
- earliest time (UTC) at which next tuple will be writtenjava.sql.SQLException
void setRowtimeBound(java.sql.Timestamp bound, java.util.Calendar cal) throws java.sql.SQLException
bound
and cal
.
Implementation note: cal
is currently ignored and
this method behaves exactly as setRowtimeBound(Timestamp)
.bound
- earliest time at which next tuple will be writtencal
- Calendar context for the bound
Timestampjava.sql.SQLException
void flush() throws java.sql.SQLException
flush
in interface StreamingStatement
java.sql.SQLException
- if statement is closed.default void enableImplicitRowtime() throws java.sql.SQLException
java.sql.SQLException
void setUdxExitWithoutWait(boolean noWait)
void notifyUdxOnCancel(java.lang.Runnable notifier)
Copyright (C) 2003-2021 SQLstream, Inc.