blob: 1c536ce319d2977cfcefd02ec487ccf20393fa17 [file] [log] [blame]
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# NOTE: This file is autogenerated and should not be edited by hand.
# Configs are generated based on the expansion service
# configuration in /sdks/standard_expansion_services.yaml.
# Refer to gen_xlang_wrappers.py for more info.
#
# Last updated on: 2025-06-05
- default_service: sdks:java:io:expansion-service:shadowJar
description: 'Outputs a PCollection of Beam Rows, each containing a single INT64
number called "value". The count is produced from the given "start" value and
either up to the given "end" or until 2^63 - 1.
To produce an unbounded PCollection, simply do not specify an "end" value. Unbounded
sequences can specify a "rate" for output elements.
In all cases, the sequence of numbers is generated in parallel, so there is no
inherent ordering between the generated values'
destinations:
python: apache_beam/io
fields:
- description: The maximum number to generate (exclusive). Will be an unbounded
sequence if left unspecified.
name: end
nullable: true
type: int64
- description: Specifies the rate to generate a given number of elements per a given
number of seconds. Applicable only to unbounded sequences.
name: rate
nullable: true
type: Row(elements=<class 'int64'>, seconds=typing.Optional[int64])
- description: The minimum number to generate (inclusive).
name: start
nullable: false
type: int64
identifier: beam:schematransform:org.apache.beam:generate_sequence:v1
name: GenerateSequence
- default_service: sdks:java:io:expansion-service:shadowJar
description: ''
destinations:
python: apache_beam/io
fields:
- description: Decompression type to use when reading input files.
name: compression
nullable: false
type: str
- description: This option specifies whether and where to output unwritable rows.
name: error_handling
nullable: true
type: Row(output=<class 'str'>)
- description: Filename or file pattern used to find input files.
name: file_pattern
nullable: false
type: str
- description: Validate file pattern.
name: validate
nullable: false
type: boolean
identifier: beam:schematransform:org.apache.beam:tfrecord_read:v1
name: TfrecordRead
- default_service: sdks:java:io:expansion-service:shadowJar
description: ''
destinations:
python: apache_beam/io
fields:
- description: Option to indicate the output sink's compression type. Default is
NONE.
name: compression
nullable: false
type: str
- description: This option specifies whether and where to output unwritable rows.
name: error_handling
nullable: true
type: Row(output=<class 'str'>)
- description: The suffix of each file written, combined with prefix and shardTemplate.
name: filename_suffix
nullable: true
type: str
- description: Maximum number of writers created in a bundle before spilling to
shuffle.
name: max_num_writers_per_bundle
nullable: true
type: int32
- description: Whether to skip the spilling of data caused by having maxNumWritersPerBundle.
name: no_spilling
nullable: true
type: boolean
- description: The number of shards to use, or 0 for automatic.
name: num_shards
nullable: false
type: int32
- description: The directory to which files will be written.
name: output_prefix
nullable: false
type: str
- description: The shard template of each file written, combined with prefix and
suffix.
name: shard_template
nullable: true
type: str
identifier: beam:schematransform:org.apache.beam:tfrecord_write:v1
name: TfrecordWrite