org.apache.storm.druid.trident

Class DruidBeamState<E>

java.lang.Object

org.apache.storm.druid.trident.DruidBeamState<E>

All Implemented Interfaces:

State

Deprecated.

the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.

@Deprecated
public class DruidBeamState<E>
extends Object
implements State

Trident State implementation for Druid.

Constructor Summary

Constructors

Constructor and Description
DruidBeamState(com.metamx.tranquility.beam.Beam<E> beam, ITupleDruidEventMapper<E> druidEventMapper) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	beginCommit(Long txid) Deprecated.
void	close() Deprecated.
void	commit(Long txid) Deprecated.
List<E>	update(List<TridentTuple> tuples, TridentCollector collector) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidBeamState

public DruidBeamState(com.metamx.tranquility.beam.Beam<E> beam,
                      ITupleDruidEventMapper<E> druidEventMapper)

Deprecated.

Method Detail

update

public List<E> update(List<TridentTuple> tuples,
                      TridentCollector collector)

Deprecated.

close

public void close()

Deprecated.

beginCommit

public void beginCommit(Long txid)

Deprecated.

Specified by:

beginCommit in interface State

commit

public void commit(Long txid)

Deprecated.

Specified by:

commit in interface State