|
SparkseePython3 6.1.0
|
Public Member Functions | |
| set_stream (self, stream, handler) | |
| Sets a query stream handler Query streams handlers are created and destroyed by the caller. | |
| set_dynamic (self, name, value) | |
| Sets the value for a dynamic paramater. | |
| execute (self, stmt, reiterable) | |
| Executes the given statement. | |
| close (self) | |
| Closes the Query instance. | |
| is_closed (self) | |
| Gets if the Query instance has been closed or not. | |
Query class.
| sparksee.Query.close | ( | self | ) |
Closes the Query instance.
It must be called to ensure the integrity of all data.
| sparksee.Query.execute | ( | self, | |
| stmt, | |||
| reiterable ) |
| sparksee.Query.is_closed | ( | self | ) |
| sparksee.Query.set_dynamic | ( | self, | |
| name, | |||
| value ) |
Sets the value for a dynamic paramater.
| name | [in] Parameter name |
| value | [in] Parameter value |
| sparksee.Query.set_stream | ( | self, | |
| stream, | |||
| handler ) |
Sets a query stream handler Query streams handlers are created and destroyed by the caller.
DeprecatedQueryStreams should be handled by a QueryStreamManager setup at database level instead.
| stream | [in] The stream name |
| handler | [in] Query stream handler |