@@ -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 (string $ 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 (string $ sql , array $ options = []): array
198198 {
199199 return $ this ->operation ->partitionQuery (
200200 $ this ->session ,
@@ -222,7 +222,7 @@ public function partitionQuery($sql, array $options = [])
222222 * @return Result
223223 * @throws \BadMethodCallException If an invalid partition type is given.
224224 */
225- public function executePartition (PartitionInterface $ partition , array $ options = [])
225+ public function executePartition (PartitionInterface $ partition , array $ options = []): Result
226226 {
227227 if ($ partition instanceof QueryPartition) {
228228 return $ this ->executeQuery ($ partition );
@@ -243,7 +243,7 @@ public function executePartition(PartitionInterface $partition, array $options =
243243 *
244244 * @return string
245245 */
246- public function serialize ()
246+ public function serialize (): string
247247 {
248248 return base64_encode (json_encode ([
249249 'sessionName ' => $ this ->session ->name (),
@@ -269,7 +269,7 @@ public function __toString()
269269 * @param QueryPartition $partition The partition.
270270 * @return Result
271271 */
272- private function executeQuery (QueryPartition $ partition )
272+ private function executeQuery (QueryPartition $ partition ): Result
273273 {
274274 return $ this ->execute ($ partition ->sql (), [
275275 'partitionToken ' => $ partition ->token ()
@@ -282,7 +282,7 @@ private function executeQuery(QueryPartition $partition)
282282 * @param ReadPartition $partition The partition.
283283 * @return Result
284284 */
285- private function executeRead (ReadPartition $ partition )
285+ private function executeRead (ReadPartition $ partition ): Result
286286 {
287287 return $ this ->read ($ partition ->table (), $ partition ->keySet (), $ partition ->columns (), [
288288 'partitionToken ' => $ partition ->token ()
0 commit comments