org.apache.beam.sdk.io.fileschematransform

Class JsonReadSchemaTransformFormatProvider

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.JsonReadSchemaTransformFormatProvider

All Implemented Interfaces:

FileReadSchemaTransformFormatProvider, Providers.Identifyable

@AutoService(value=FileReadSchemaTransformFormatProvider.class)
public class JsonReadSchemaTransformFormatProvider
extends java.lang.Object
implements FileReadSchemaTransformFormatProvider

A FileReadSchemaTransformFormatProvider that reads newline-delimited JSONs.

Constructor Summary

Constructors

Constructor and Description
JsonReadSchemaTransformFormatProvider()

Method Summary

Modifier and Type	Method and Description
PTransform<PCollection<FileIO.ReadableFile>,PCollection<Row>>	buildTransform(FileReadSchemaTransformConfiguration configuration)
java.lang.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 Detail

JsonReadSchemaTransformFormatProvider

public JsonReadSchemaTransformFormatProvider()

Method Detail

identifier

public java.lang.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