org.apache.beam.sdk.schemas

Class Schema

java.lang.Object

org.apache.beam.sdk.schemas.Schema

All Implemented Interfaces:

java.io.Serializable

@Experimental(value=SCHEMAS)
public class Schema
extends java.lang.Object
implements java.io.Serializable

Schema describes the fields in Row.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Schema.Builder Builder class for building Schema objects.
static class	Schema.Field Field of a row.
static class	Schema.FieldType A descriptor of a single field type.
static class	Schema.TypeName An enumerated list of type constructors.

Constructor Summary

Constructors

Constructor and Description
Schema(java.util.List<Schema.Field> fields)

Method Summary

Modifier and Type	Method and Description
static Schema.Builder	builder()
boolean	equals(java.lang.Object o) Returns true if two Schemas have the same fields in the same order.
boolean	equivalent(Schema other) Returns true if two Schemas have the same fields, but possibly in different orders.
Schema.Field	getField(int index) Return a field by index.
Schema.Field	getField(java.lang.String name)
int	getFieldCount() Return the count of fields.
java.util.List<java.lang.String>	getFieldNames() Return the list of all field names.
java.util.List<Schema.Field>	getFields()
RowCoder	getRowCoder() Return the coder for a Row with this schema.
boolean	hasField(java.lang.String fieldName) Returns true if fieldName exists in the schema, false otherwise.
int	hashCode()
int	indexOf(java.lang.String fieldName) Find the index of a given field.
java.lang.String	nameOf(int fieldIndex) Return the name of field by index.
static Schema	of(Schema.Field... fields)
static java.util.stream.Collector<Schema.Field,java.util.List<Schema.Field>,Schema>	toSchema() Collects a stream of Schema.Fields into a Schema.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Schema

public Schema(java.util.List<Schema.Field> fields)

Method Detail

builder

public static Schema.Builder builder()

of

public static Schema of(Schema.Field... fields)

equals

public boolean equals(java.lang.Object o)

Returns true if two Schemas have the same fields in the same order.

Overrides:

equals in class java.lang.Object

equivalent

public boolean equivalent(Schema other)

Returns true if two Schemas have the same fields, but possibly in different orders.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

getFields

public java.util.List<Schema.Field> getFields()

toSchema

public static java.util.stream.Collector<Schema.Field,java.util.List<Schema.Field>,Schema> toSchema()

Collects a stream of Schema.Fields into a Schema.

getRowCoder

public RowCoder getRowCoder()

Return the coder for a Row with this schema.

getFieldNames

public java.util.List<java.lang.String> getFieldNames()

Return the list of all field names.

getField

public Schema.Field getField(int index)

Return a field by index.

getField

public Schema.Field getField(java.lang.String name)

indexOf

public int indexOf(java.lang.String fieldName)

Find the index of a given field.

hasField

public boolean hasField(java.lang.String fieldName)

Returns true if fieldName exists in the schema, false otherwise.

nameOf

public java.lang.String nameOf(int fieldIndex)

Return the name of field by index.

getFieldCount

public int getFieldCount()

Return the count of fields.