Package org.apache.storm.topology
Class OutputFieldsGetter
- java.lang.Object
-
- org.apache.storm.topology.OutputFieldsGetter
-
- All Implemented Interfaces:
OutputFieldsDeclarer
public class OutputFieldsGetter extends Object implements OutputFieldsDeclarer
-
-
Constructor Summary
Constructors Constructor Description OutputFieldsGetter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddeclare(boolean direct, Fields fields)voiddeclare(Fields fields)Uses default stream id.voiddeclareStream(String streamId, boolean direct, Fields fields)voiddeclareStream(String streamId, Fields fields)Map<String,StreamInfo>getFieldsDeclaration()
-
-
-
Method Detail
-
declare
public void declare(Fields fields)
Description copied from interface:OutputFieldsDeclarerUses default stream id.- Specified by:
declarein interfaceOutputFieldsDeclarer
-
declare
public void declare(boolean direct, Fields fields)- Specified by:
declarein interfaceOutputFieldsDeclarer
-
declareStream
public void declareStream(String streamId, Fields fields)
- Specified by:
declareStreamin interfaceOutputFieldsDeclarer
-
declareStream
public void declareStream(String streamId, boolean direct, Fields fields)
- Specified by:
declareStreamin interfaceOutputFieldsDeclarer
-
getFieldsDeclaration
public Map<String,StreamInfo> getFieldsDeclaration()
-
-