org.apache.beam.runners.spark.structuredstreaming.translation

Class SchemaHelpers

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.SchemaHelpers

public class SchemaHelpers
extends java.lang.Object

A SchemaHelpers for the Spark Batch Runner.

Constructor Summary

Constructors

Constructor and Description
SchemaHelpers()

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.sql.types.StructType	binarySchema()

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaHelpers

public SchemaHelpers()

Method Detail

binarySchema

public static org.apache.spark.sql.types.StructType binarySchema()