Package org.apache.beam.sdk.io.fileschematransform

Class LineReadSchemaTransformFormatProvider

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.LineReadSchemaTransformFormatProvider

All Implemented Interfaces:

FileReadSchemaTransformFormatProvider, Providers.Identifyable

@AutoService(FileReadSchemaTransformFormatProvider.class)
public class LineReadSchemaTransformFormatProvider
extends Object
implements FileReadSchemaTransformFormatProvider

A FileReadSchemaTransformFormatProvider that reads lines as Strings.

Constructor Summary

Constructors

Constructor	Description
LineReadSchemaTransformFormatProvider()

Method Summary

Modifier and Type	Method	Description
PTransform<PCollection<FileIO.ReadableFile>,PCollection<Row>>	buildTransform(FileReadSchemaTransformConfiguration configuration)
String	identifier()	Returns an id that uniquely represents this among others implementing its derived interface.

Methods inherited from class java.lang.Object

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

Constructor Details

LineReadSchemaTransformFormatProvider

public LineReadSchemaTransformFormatProvider()

Method Details

identifier

public String identifier()

Description copied from interface: Providers.Identifyable

Returns an id that uniquely represents this among others implementing its derived interface.

Specified by:

identifier in interface Providers.Identifyable

buildTransform

public PTransform<PCollection<FileIO.ReadableFile>,PCollection<Row>> buildTransform(FileReadSchemaTransformConfiguration configuration)

Specified by:

buildTransform in interface FileReadSchemaTransformFormatProvider