backtype.storm.topology
Class OutputFieldsGetter

java.lang.Object
  extended by backtype.storm.topology.OutputFieldsGetter
All Implemented Interfaces:
OutputFieldsDeclarer

public class OutputFieldsGetter
extends java.lang.Object
implements OutputFieldsDeclarer


Constructor Summary
OutputFieldsGetter()
           
 
Method Summary
 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)
           
 java.util.Map<java.lang.String,StreamInfo> getFieldsDeclaration()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

OutputFieldsGetter

public OutputFieldsGetter()
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

getFieldsDeclaration

public java.util.Map<java.lang.String,StreamInfo> getFieldsDeclaration()