org.apache.storm.topology.twister2

Class EdgeFieldMap

java.lang.Object

java.util.AbstractMap<K,V>

java.util.HashMap<java.lang.String,Fields>

org.apache.storm.topology.twister2.EdgeFieldMap

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.Map<java.lang.String,Fields>, OutputFieldsDeclarer

public class EdgeFieldMap
extends java.util.HashMap<java.lang.String,Fields>
implements OutputFieldsDeclarer

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

java.util.AbstractMap.SimpleEntry<K,V>, java.util.AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

java.util.Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
EdgeFieldMap(java.lang.String defaultEdge)

Method Summary

Modifier and Type	Method and Description
void	declare(boolean direct, Fields fields)
void	declare(Fields fields) Uses default stream id.
void	declareStream(java.lang.String streamId, boolean direct, Fields fields)
void	declareStream(java.lang.String streamId, Fields fields)

Methods inherited from class java.util.HashMap

clear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, get, getOrDefault, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Methods inherited from class java.util.AbstractMap

equals, hashCode, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

equals, hashCode

Constructor Detail

EdgeFieldMap

public EdgeFieldMap(java.lang.String defaultEdge)

Method Detail

declare

public void declare(Fields fields)

Description copied from interface: OutputFieldsDeclarer

Uses default stream id.

Specified by:

declare in interface OutputFieldsDeclarer

declare

public void declare(boolean direct,
                    Fields fields)

Specified by:

declare in interface OutputFieldsDeclarer

declareStream

public void declareStream(java.lang.String streamId,
                          Fields fields)

Specified by:

declareStream in interface OutputFieldsDeclarer

declareStream

public void declareStream(java.lang.String streamId,
                          boolean direct,
                          Fields fields)

Specified by:

declareStream in interface OutputFieldsDeclarer