public final class BoltPrintSink extends AbstractBoltSink
stdout
.Constructor and Description |
---|
BoltPrintSink(OutputFormatter formatter) |
Modifier and Type | Method and Description |
---|---|
void |
prepareSimple(Map stormConf,
org.apache.storm.task.TopologyContext context) |
void |
writeExternal(String line) |
cleanup, declareOutputFields, execute, getComponentConfiguration, prepare
public BoltPrintSink(OutputFormatter formatter)
public void prepareSimple(Map stormConf, org.apache.storm.task.TopologyContext context)
prepareSimple
in class AbstractBoltSink
public void writeExternal(String line)
writeExternal
in class AbstractBoltSink
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.