Package org.apache.beam.sdk.schemas.utils

Class YamlUtils

java.lang.Object

org.apache.beam.sdk.schemas.utils.YamlUtils

public class YamlUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
YamlUtils()

Method Summary

Modifier and Type	Method	Description
static Map<String,Object>	loadFromStream(InputStream inputStream)
static Row	toBeamRow(@Nullable String yamlString, Schema schema)
static Row	toBeamRow(@Nullable String yamlString, Schema schema, boolean convertNamesToCamelCase)
static Row	toBeamRow(@Nullable Map<String,Object> map, Schema rowSchema, boolean toCamelCase)
static String	yamlStringFromMap(@Nullable Map<String,Object> map)
static Map<String,Object>	yamlStringToMap(@Nullable String yaml)

Methods inherited from class java.lang.Object

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

Constructor Details

YamlUtils

public YamlUtils()

Method Details

toBeamRow

public static Row toBeamRow(@Nullable String yamlString,
 Schema schema)

toBeamRow

public static Row toBeamRow(@Nullable String yamlString,
 Schema schema,
 boolean convertNamesToCamelCase)

toBeamRow

public static Row toBeamRow(@Nullable Map<String,Object> map,
 Schema rowSchema,
 boolean toCamelCase)

yamlStringFromMap

public static String yamlStringFromMap(@Nullable Map<String,Object> map)

yamlStringToMap

public static Map<String,Object> yamlStringToMap(@Nullable String yaml)

loadFromStream

public static Map<String,Object> loadFromStream(InputStream inputStream)