@@ -92,7 +92,7 @@ public function __construct(Operation $operation, Session $session, array $optio
9292 * @param array $options [optional] Configuration Options
9393 * @return void
9494 */
95- public function close (array $ options = [])
95+ public function close (array $ options = []): void
9696 {
9797 $ this ->session ->delete ($ options );
9898 }
@@ -131,7 +131,7 @@ public function close(array $options = [])
131131 * }
132132 * @return ReadPartition[]
133133 */
134- public function partitionRead ($ table , KeySet $ keySet , array $ columns , array $ options = [])
134+ public function partitionRead ($ table , KeySet $ keySet , array $ columns , array $ options = []): array
135135 {
136136 return $ this ->operation ->partitionRead (
137137 $ this ->session ,
@@ -194,7 +194,7 @@ public function partitionRead($table, KeySet $keySet, array $columns, array $opt
194194 * }
195195 * @return QueryPartition[]
196196 */
197- public function partitionQuery ($ sql , array $ options = [])
197+ public function partitionQuery ($ sql , array $ options = []): array
198198 {
199199 return $ this ->operation ->partitionQuery (
200200 $ this ->session ,
@@ -218,11 +218,10 @@ public function partitionQuery($sql, array $options = [])
218218 * ```
219219 *
220220 * @param PartitionInterface $partition The partition to read.
221- * @param array $options Configuration Options.
222221 * @return Result
223222 * @throws \BadMethodCallException If an invalid partition type is given.
224223 */
225- public function executePartition (PartitionInterface $ partition, array $ options = [])
224+ public function executePartition (PartitionInterface $ partition): Result
226225 {
227226 if ($ partition instanceof QueryPartition) {
228227 return $ this ->executeQuery ($ partition );
@@ -243,7 +242,7 @@ public function executePartition(PartitionInterface $partition, array $options =
243242 *
244243 * @return string
245244 */
246- public function serialize ()
245+ public function serialize (): string
247246 {
248247 return base64_encode (json_encode ([
249248 'sessionName ' => $ this ->session ->name (),
@@ -269,7 +268,7 @@ public function __toString()
269268 * @param QueryPartition $partition The partition.
270269 * @return Result
271270 */
272- private function executeQuery (QueryPartition $ partition )
271+ private function executeQuery (QueryPartition $ partition ): Result
273272 {
274273 return $ this ->execute ($ partition ->sql (), [
275274 'partitionToken ' => $ partition ->token ()
@@ -282,7 +281,7 @@ private function executeQuery(QueryPartition $partition)
282281 * @param ReadPartition $partition The partition.
283282 * @return Result
284283 */
285- private function executeRead (ReadPartition $ partition )
284+ private function executeRead (ReadPartition $ partition ): Result
286285 {
287286 return $ this ->read ($ partition ->table (), $ partition ->keySet (), $ partition ->columns (), [
288287 'partitionToken ' => $ partition ->token ()
0 commit comments