public final BatchCreateReadSessionStreamsResponse batchCreateReadSessionStreams ( ReadSession session , int requestedStreams ) { BatchCreateReadSessionStreamsRequest request = BatchCreateReadSessionStreamsRequest . newBuilder ( ) . setSession ( session ) . setRequestedStreams ( requestedStreams ) . build ( ) ; return batchCreateReadSessionStreams ( request ) ; }
Creates additional streams for a ReadSession . This API can be used to dynamically adjust the parallelism of a batch processing task upwards by adding additional workers .