Package org.apache.beam.sdk.providers

Class GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration

java.lang.Object

org.apache.beam.sdk.providers.GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration

Enclosing class:

GenerateSequenceSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration.Builder
static class	GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration.Rate

Constructor Summary

Constructors

Constructor	Description
GenerateSequenceConfiguration()

Method Summary

Modifier and Type	Method	Description
static GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration.Builder	builder()
abstract Long	getEnd()
abstract GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration.Rate	getRate()
abstract Long	getStart()
void	validate()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GenerateSequenceConfiguration

public GenerateSequenceConfiguration()

Method Details

builder

public static GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration.Builder builder()

getStart

@SchemaFieldDescription("The minimum number to generate (inclusive).")
public abstract Long getStart()

getEnd

@SchemaFieldDescription("The maximum number to generate (exclusive). Will be an unbounded sequence if left unspecified.")
@Nullable
public abstract Long getEnd()

getRate

@SchemaFieldDescription("Specifies the rate to generate a given number of elements per a given number of seconds. Applicable only to unbounded sequences.")
@Nullable
public abstract GenerateSequenceSchemaTransformProvider.GenerateSequenceConfiguration.Rate getRate()

validate

public void validate()