Every PreparedStatement created by the SQLstream JDBC driver implements the StreamingPreparedStatement interface. The following code shows the setRowtimeBound method. java
interface StreamingPreparedStatement extends
       java.sql.PreparedStatement, StreamingStatement {
  void setRowtimeBound(Timestamp bound)
;
}
However, the setRowtimeBound method is only meaningful for INSERT EXPEDITED prepared statements. A SQLException is thrown if setRowtimeBound is called on other prepared queries. Example usages:
long nextRowDelay = 5000L;
pstmt.setRowtimeBound(new Timestamp(System.currentTimeMillis() +
nextRowDelay))
or
long nextRowDelay = 5000L;
java.sql.Timestamp ts = <some retrieved value>
pstmt.setRowtimeBound(new Timestamp(ts.getTime() + nextRowDelay));
setRowtimeBound(Timestamp bound) sets a rowtime bound, which has a single attribute, a timestamp.
public interface StreamingPreparedStatement extends PreparedStatement, StreamingStatement Aspen streaming prepared statement interface. This interface extends PreparedStatement and StreamingStatement to include methods for sending rowtime bounds.
Fields inherited from interface com.sqlstream.jdbc.StreamingStatement TIMEOUT_NO_WAIT
Fields inherited from interface java.sql.Statement CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO
Modifier and Type | Method and Description |
---|---|
void | setRowtimeBound(Timestamp bound) |
Sets the rowtime bound for the current stream. | |
Sets the rowtime bound for the current stream. |
Method | Detail |
---|---|
setRowtimeBound | void setRowtimeBound(Timestamp bound) |
          throws SQLException | |
Sets the rowtime bound for the current stream. The caller thereby indicates that no more tuples will be written to the stream until the UTC time specified by bound. | |
Parameters: | |
bound - earliest time (UTC) at which next tuple will be written | |
Throws: | |
SQLException | |
         Calendar cal) | |
          throws SQLException | |
Sets the rowtime bound for the current stream. The caller thereby indicates that no more tuples will be written to the stream until the time specified by bound and cal. Implementation note: cal is currently ignored and this method behaves exactly as setRowtimeBound(Timestamp). | |
Parameters: | |
bound - earliest time at which next tuple will be written | |
cal - Calendar context for the bound Timestamp | |
Throws: | |
SQLException |