org.apache.storm.druid.trident

Class DruidBeamStateUpdater<E>

java.lang.Object

org.apache.storm.trident.operation.BaseOperation

org.apache.storm.trident.state.BaseStateUpdater<DruidBeamState<E>>

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

All Implemented Interfaces:

Serializable, Operation, StateUpdater<DruidBeamState<E>>

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 DruidBeamStateUpdater<E>
extends BaseStateUpdater<DruidBeamState<E>>

Updates Druid Beam State.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DruidBeamStateUpdater() Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	processDiscardedTuples(List<E> discardedTuples) Deprecated. Users can override this method to process the discarded Tuples
void	updateState(DruidBeamState<E> state, List<TridentTuple> tuples, TridentCollector collector) Deprecated.

Methods inherited from class org.apache.storm.trident.operation.BaseOperation

cleanup, prepare

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup, prepare

Constructor Detail

DruidBeamStateUpdater

public DruidBeamStateUpdater()

Deprecated.

Method Detail

updateState

public void updateState(DruidBeamState<E> state,
                        List<TridentTuple> tuples,
                        TridentCollector collector)

Deprecated.

processDiscardedTuples

protected void processDiscardedTuples(List<E> discardedTuples)

Deprecated.

Users can override this method to process the discarded Tuples

Parameters:

discardedTuples -