public final class MergedInputsBoltWrapper<IN,OUT> extends BoltWrapper<StormTuple<IN>,OUT>
MergedInputsBoltWrapper
is a BoltWrapper
that expects input tuples of type StormTuple
. It
can be used to wrap a multi-input bolt and assumes that all input stream got merged into a StormTuple
stream
already.AbstractStreamOperator.CountingOutput<OUT>
bolt, DEFAULT_ID, DEFUALT_BOLT_NAME, flinkCollector
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
Constructor and Description |
---|
MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt)
Instantiates a new
MergedInputsBoltWrapper that wraps the given Storm bolt such that it
can be used within a Flink streaming program. |
MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt,
Collection<String> rawOutputs)
Instantiates a new
MergedInputsBoltWrapper that wraps the given Storm bolt such that it
can be used within a Flink streaming program. |
MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt,
String[] rawOutputs)
Instantiates a new
MergedInputsBoltWrapper that wraps the given Storm bolt such that it
can be used within a Flink streaming program. |
MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt,
String name,
Collection<String> rawOutputs)
Instantiates a new
MergedInputsBoltWrapper that wraps the given Storm bolt such that it
can be used within a Flink streaming program. |
Modifier and Type | Method and Description |
---|---|
void |
processElement(StreamRecord<StormTuple<IN>> element)
Processes one element that arrived at this operator.
|
dispose, open, setStormTopology
close, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, initializeState, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker, processWatermark
close, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, prepareSnapshotPreBarrier, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState
notifyCheckpointComplete
getCurrentKey, setCurrentKey
public MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt) throws IllegalArgumentException
MergedInputsBoltWrapper
that wraps the given Storm bolt
such that it
can be used within a Flink streaming program. The output type will be one of Tuple0
to Tuple25
depending on the bolt's declared number of attributes.bolt
- The Storm bolt
to be used.IllegalArgumentException
- If the number of declared output attributes is not with range [0;25].public MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt, String[] rawOutputs) throws IllegalArgumentException
MergedInputsBoltWrapper
that wraps the given Storm bolt
such that it
can be used within a Flink streaming program. The output type can be any type if parameter rawOutput
is
true
and the bolt's number of declared output tuples is 1. If rawOutput
is false
the
output type will be one of Tuple0
to Tuple25
depending on the bolt's declared number of
attributes.bolt
- The Storm bolt
to be used.rawOutputs
- Contains stream names if a single attribute output stream, should not be of type Tuple1
but be
of a raw type.IllegalArgumentException
- If rawOutput
is true
and the number of declared output attributes is not 1 or if
rawOutput
is false
and the number of declared output attributes is not within range
[1;25].public MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt, Collection<String> rawOutputs) throws IllegalArgumentException
MergedInputsBoltWrapper
that wraps the given Storm bolt
such that it
can be used within a Flink streaming program. The output type can be any type if parameter rawOutput
is
true
and the bolt's number of declared output tuples is 1. If rawOutput
is false
the
output type will be one of Tuple0
to Tuple25
depending on the bolt's declared number of
attributes.bolt
- The Storm bolt
to be used.rawOutputs
- Contains stream names if a single attribute output stream, should not be of type Tuple1
but be
of a raw type.IllegalArgumentException
- If rawOutput
is true
and the number of declared output attributes is not 1 or if
rawOutput
is false
and the number of declared output attributes is not with range
[1;25].public MergedInputsBoltWrapper(org.apache.storm.topology.IRichBolt bolt, String name, Collection<String> rawOutputs) throws IllegalArgumentException
MergedInputsBoltWrapper
that wraps the given Storm bolt
such that it
can be used within a Flink streaming program. The output type can be any type if parameter rawOutput
is
true
and the bolt's number of declared output tuples is 1. If rawOutput
is false
the
output type will be one of Tuple0
to Tuple25
depending on the bolt's declared number of
attributes.bolt
- The Storm bolt
to be used.name
- The name of the bolt.rawOutputs
- Contains stream names if a single attribute output stream, should not be of type Tuple1
but be
of a raw type.IllegalArgumentException
- If rawOutput
is true
and the number of declared output attributes is not 1 or if
rawOutput
is false
and the number of declared output attributes is not with range
[0;25].public void processElement(StreamRecord<StormTuple<IN>> element) throws Exception
OneInputStreamOperator
processElement
in interface OneInputStreamOperator<StormTuple<IN>,OUT>
processElement
in class BoltWrapper<StormTuple<IN>,OUT>
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.