org.apache.storm.sql.runtime.datasource.socket.trident

Class TridentSocketSpout

java.lang.Object

org.apache.storm.sql.runtime.datasource.socket.trident.TridentSocketSpout

All Implemented Interfaces:

Serializable, IBatchSpout, ITridentDataSource

public class TridentSocketSpout
extends Object
implements IBatchSpout

Trident Spout for Socket data. Only available for Storm SQL, and only use for test purposes.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TridentSocketSpout(Scheme scheme, String host, int port)

Method Summary

Modifier and Type	Method and Description
void	ack(long batchId)
void	close()
void	emitBatch(long batchId, TridentCollector collector)
Map<String,Object>	getComponentConfiguration()
Fields	getOutputFields()
void	open(Map conf, TopologyContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentSocketSpout

public TridentSocketSpout(Scheme scheme,
                          String host,
                          int port)

Method Detail

open

public void open(Map conf,
                 TopologyContext context)

Specified by:

open in interface IBatchSpout

emitBatch

public void emitBatch(long batchId,
                      TridentCollector collector)

Specified by:

emitBatch in interface IBatchSpout

ack

public void ack(long batchId)

Specified by:

ack in interface IBatchSpout

close

public void close()

Specified by:

close in interface IBatchSpout

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface IBatchSpout

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface IBatchSpout