org.apache.beam.runners.dataflow.util

Class Structs

java.lang.Object

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

public final class Structs
extends java.lang.Object

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

getString

public static java.lang.String getString(java.util.Map<java.lang.String,java.lang.Object> map,
                                         java.lang.String name)

getString

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

getBytes

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

getBytes

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

getBoolean

public static java.lang.Boolean getBoolean(java.util.Map<java.lang.String,java.lang.Object> map,
                                           java.lang.String name)

getBoolean

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

getLong

public static java.lang.Long getLong(java.util.Map<java.lang.String,java.lang.Object> map,
                                     java.lang.String name)

getLong

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

getInt

public static java.lang.Integer getInt(java.util.Map<java.lang.String,java.lang.Object> map,
                                       java.lang.String name)

getInt

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

getStrings

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

getObject

public static java.util.Map<java.lang.String,java.lang.Object> getObject(java.util.Map<java.lang.String,java.lang.Object> map,
                                                                         java.lang.String name)

getObject

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

getListOfMaps

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

getDictionary

public static java.util.Map<java.lang.String,java.lang.Object> getDictionary(java.util.Map<java.lang.String,java.lang.Object> map,
                                                                             java.lang.String name)

getDictionary

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

addString

public static void addString(java.util.Map<java.lang.String,java.lang.Object> map,
                             java.lang.String name,
                             java.lang.String value)

addBoolean

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

addLong

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

addObject

public static void addObject(java.util.Map<java.lang.String,java.lang.Object> map,
                             java.lang.String name,
                             java.util.Map<java.lang.String,java.lang.Object> value)

addNull

public static void addNull(java.util.Map<java.lang.String,java.lang.Object> map,
                           java.lang.String name)

addLongs

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

addList

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

addStringList

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

addList

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

addDictionary

public static void addDictionary(java.util.Map<java.lang.String,java.lang.Object> map,
                                 java.lang.String name,
                                 java.util.Map<java.lang.String,java.lang.Object> value)

addDouble

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