Package org.apache.beam.runners.dataflow.util

Class Structs

java.lang.Object

org.apache.beam.runners.dataflow.util.Structs

public final class Structs
extends Object

A collection of static methods for manipulating datastructure representations transferred via the Dataflow API.

Method Summary

Modifier and Type	Method	Description
static void	addBoolean(Map<String,Object> map, String name, boolean value)
static void	addDictionary(Map<String,Object> map, String name, Map<String,Object> value)
static void	addDouble(Map<String,Object> map, String name, Double value)
static void	addList(Map<String,Object> map, String name, List<? extends Map<String,Object>> elements)
static <T extends Map<String, Object>> void	addList(Map<String,Object> map, String name, T[] elements)
static void	addLong(Map<String,Object> map, String name, long value)
static void	addLongs(Map<String,Object> map, String name, long... longs)
static void	addNull(Map<String,Object> map, String name)
static void	addObject(Map<String,Object> map, String name, Map<String,Object> value)
static void	addString(Map<String,Object> map, String name, String value)
static void	addStringList(Map<String,Object> map, String name, List<String> elements)
static Boolean	getBoolean(Map<String,Object> map, String name)
static @Nullable Boolean	getBoolean(Map<String,Object> map, String name, @Nullable Boolean defaultValue)
static byte[]	getBytes(Map<String,Object> map, String name)
static byte @Nullable []	getBytes(Map<String,Object> map, String name, byte @Nullable [] defaultValue)
static Map<String,Object>	getDictionary(Map<String,Object> map, String name)
static @Nullable Map<String,Object>	getDictionary(Map<String,Object> map, String name, @Nullable Map<String,Object> defaultValue)
static Integer	getInt(Map<String,Object> map, String name)
static @Nullable Integer	getInt(Map<String,Object> map, String name, @Nullable Integer defaultValue)
static @Nullable List<Map<String,Object>>	getListOfMaps(Map<String,Object> map, String name, @Nullable List<Map<String,Object>> defaultValue)
static Long	getLong(Map<String,Object> map, String name)
static @Nullable Long	getLong(Map<String,Object> map, String name, @Nullable Long defaultValue)
static Map<String,Object>	getObject(Map<String,Object> map, String name)
static @Nullable Map<String,Object>	getObject(Map<String,Object> map, String name, @Nullable Map<String,Object> defaultValue)
static String	getString(Map<String,Object> map, String name)
static String	getString(Map<String,Object> map, String name, @Nullable String defaultValue)
static @Nullable List<String>	getStrings(Map<String,Object> map, String name, @Nullable List<String> defaultValue)

Methods inherited from class java.lang.Object

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

Method Details

getString

public static String getString(Map<String,Object> map,
 String name)

getString

public static String getString(Map<String,Object> map,
 String name,
 @Nullable String defaultValue)

getBytes

public static byte[] getBytes(Map<String,Object> map,
 String name)

getBytes

public static byte @Nullable [] getBytes(Map<String,Object> map,
 String name,
 byte @Nullable [] defaultValue)

getBoolean

public static Boolean getBoolean(Map<String,Object> map,
 String name)

getBoolean

public static @Nullable Boolean getBoolean(Map<String,Object> map,
 String name,
 @Nullable Boolean defaultValue)

getLong

public static Long getLong(Map<String,Object> map,
 String name)

getLong

public static @Nullable Long getLong(Map<String,Object> map,
 String name,
 @Nullable Long defaultValue)

getInt

public static Integer getInt(Map<String,Object> map,
 String name)

getInt

public static @Nullable Integer getInt(Map<String,Object> map,
 String name,
 @Nullable Integer defaultValue)

getStrings

public static @Nullable List<String> getStrings(Map<String,Object> map,
 String name,
 @Nullable List<String> defaultValue)

getObject

public static Map<String,Object> getObject(Map<String,Object> map,
 String name)

getObject

public static @Nullable Map<String,Object> getObject(Map<String,Object> map,
 String name,
 @Nullable Map<String,Object> defaultValue)

getListOfMaps

public static @Nullable List<Map<String,Object>> getListOfMaps(Map<String,Object> map,
 String name,
 @Nullable List<Map<String,Object>> defaultValue)

getDictionary

public static Map<String,Object> getDictionary(Map<String,Object> map,
 String name)

getDictionary

public static @Nullable Map<String,Object> getDictionary(Map<String,Object> map,
 String name,
 @Nullable Map<String,Object> defaultValue)

addString

public static void addString(Map<String,Object> map,
 String name,
 String value)

addBoolean

public static void addBoolean(Map<String,Object> map,
 String name,
 boolean value)

addLong

public static void addLong(Map<String,Object> map,
 String name,
 long value)

addObject

public static void addObject(Map<String,Object> map,
 String name,
 Map<String,Object> value)

addNull

public static void addNull(Map<String,Object> map,
 String name)

addLongs

public static void addLongs(Map<String,Object> map,
 String name,
 long... longs)

addList

public static void addList(Map<String,Object> map,
 String name,
 List<? extends Map<String,Object>> elements)

addStringList

public static void addStringList(Map<String,Object> map,
 String name,
 List<String> elements)

addList

public static <T extends Map<String,
Object>> void addList(Map<String,Object> map,
 String name,
 T[] elements)

addDictionary

public static void addDictionary(Map<String,Object> map,
 String name,
 Map<String,Object> value)

addDouble

public static void addDouble(Map<String,Object> map,
 String name,
 Double value)