def sample_create_write_stream():
                # Create a client
                client = bigquery_storage_v1beta2.BigQueryWriteClient()

                # Initialize request argument(s)
                request = bigquery_storage_v1beta2.CreateWriteStreamRequest(
                    parent="parent_value",
                )

                # Make the request
                response = client.create_write_stream(request=request)

                # Handle the response
                print(response)