Modifier and Type | Method and Description |
---|---|
ColumnList |
TridentHBaseMapper.columns(TridentTuple tuple)
Given a tuple, return a list of HBase columns to insert.
|
ColumnList |
SimpleTridentHBaseMapper.columns(TridentTuple tuple) |
byte[] |
TridentHBaseMapper.rowKey(TridentTuple tuple)
Given a tuple, return the HBase rowkey.
|
byte[] |
SimpleTridentHBaseMapper.rowKey(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseQuery.execute(TridentTuple tuples,
List<Values> values,
TridentCollector tridentCollector) |
Modifier and Type | Method and Description |
---|---|
List<List<Values>> |
HBaseQuery.batchRetrieve(HBaseState hBaseState,
List<TridentTuple> tridentTuples) |
List<List<Values>> |
HBaseState.batchRetrieve(List<TridentTuple> tridentTuples) |
void |
HBaseUpdater.updateState(HBaseState hBaseState,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
HBaseState.updateState(List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
HdfsState.HdfsFileOptions.execute(List<TridentTuple> tuples) |
void |
HdfsState.SequenceFileOptions.execute(List<TridentTuple> tuples) |
void |
HdfsUpdater.updateState(HdfsState state,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
HdfsState.updateState(List<TridentTuple> tuples,
TridentCollector tridentCollector) |
Modifier and Type | Method and Description |
---|---|
byte[] |
RecordFormat.format(TridentTuple tuple) |
byte[] |
DelimitedRecordFormat.format(TridentTuple tuple) |
org.apache.hadoop.io.Writable |
SequenceFormat.key(TridentTuple tuple)
Given a tuple, return the key that should be written to the sequence file.
|
org.apache.hadoop.io.Writable |
DefaultSequenceFormat.key(TridentTuple tuple) |
org.apache.hadoop.io.Writable |
SequenceFormat.value(TridentTuple tuple)
Given a tuple, return the value that should be written to the sequence file.
|
org.apache.hadoop.io.Writable |
DefaultSequenceFormat.value(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
boolean |
TimedRotationPolicy.mark(TridentTuple tuple,
long offset)
Called for every tuple the HdfsBolt executes.
|
boolean |
NoRotationPolicy.mark(TridentTuple tuple,
long offset) |
boolean |
FileSizeRotationPolicy.mark(TridentTuple tuple,
long offset) |
boolean |
FileRotationPolicy.mark(TridentTuple tuple,
long offset)
Called for every tuple the HdfsBolt executes.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SyncPolicy.mark(TridentTuple tuple,
long offset)
Called for every tuple the HdfsBolt executes.
|
boolean |
CountSyncPolicy.mark(TridentTuple tuple,
long offset) |
Modifier and Type | Method and Description |
---|---|
void |
TridentKafkaState.updateState(List<TridentTuple> tuples,
TridentCollector collector) |
void |
TridentKafkaUpdater.updateState(TridentKafkaState state,
List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
K |
TridentTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple) |
K |
FieldNameBasedTupleToKafkaMapper.getKeyFromTuple(TridentTuple tuple) |
V |
TridentTupleToKafkaMapper.getMessageFromTuple(TridentTuple tuple) |
V |
FieldNameBasedTupleToKafkaMapper.getMessageFromTuple(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
String |
KafkaTopicSelector.getTopic(TridentTuple tuple) |
String |
DefaultTopicSelector.getTopic(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
TridentWordCount.Split.execute(TridentTuple tuple,
TridentCollector collector) |
void |
TridentReach.ExpandList.execute(TridentTuple tuple,
TridentCollector collector) |
Integer |
TridentReach.One.init(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
ReturnResultsReducer.execute(ReturnResultsReducer.ReturnResultsState state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
Aggregator.aggregate(T val,
TridentTuple tuple,
TridentCollector collector) |
void |
GroupedMultiReducer.complete(T state,
TridentTuple group,
TridentCollector collector) |
void |
MultiReducer.execute(T state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
void |
GroupedMultiReducer.execute(T state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
void |
Function.execute(TridentTuple tuple,
TridentCollector collector) |
T |
GroupedMultiReducer.init(TridentCollector collector,
TridentTuple group) |
T |
CombinerAggregator.init(TridentTuple tuple) |
boolean |
Filter.isKeep(TridentTuple tuple) |
T |
ReducerAggregator.reduce(T curr,
TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
FirstN.FirstNAgg.aggregate(storm.trident.operation.builtin.FirstN.FirstNAgg.State val,
TridentTuple tuple,
TridentCollector collector) |
void |
FirstN.FirstNSortedAgg.aggregate(PriorityQueue state,
TridentTuple tuple,
TridentCollector collector) |
void |
TupleCollectionGet.execute(TridentTuple tuple,
Iterator<List<Object>> tuplesIterator,
TridentCollector collector) |
void |
SnapshotGet.execute(TridentTuple tuple,
Object result,
TridentCollector collector) |
void |
MapGet.execute(TridentTuple tuple,
Object result,
TridentCollector collector) |
Number |
Sum.init(TridentTuple tuple) |
Long |
Count.init(TridentTuple tuple) |
boolean |
Negate.isKeep(TridentTuple tuple) |
boolean |
FilterNull.isKeep(TridentTuple tuple) |
boolean |
Equals.isKeep(TridentTuple tuple) |
boolean |
Debug.isKeep(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
List<Object> |
MapGet.batchRetrieve(ReadOnlyMapState map,
List<TridentTuple> keys) |
List<Object> |
SnapshotGet.batchRetrieve(ReadOnlySnapshottable state,
List<TridentTuple> args) |
List<Iterator<List<Object>>> |
TupleCollectionGet.batchRetrieve(State state,
List<TridentTuple> args) |
Modifier and Type | Method and Description |
---|---|
Map<TridentTuple,Object> |
GroupedMultiReducerExecutor.init(TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
ChainedAggregatorImpl.aggregate(ChainedResult val,
TridentTuple tuple,
TridentCollector collector) |
void |
GroupedAggregator.aggregate(Object[] arr,
TridentTuple tuple,
TridentCollector collector) |
void |
ReducerAggregatorImpl.aggregate(Result val,
TridentTuple tuple,
TridentCollector collector) |
void |
CombinerAggregatorCombineImpl.aggregate(Result val,
TridentTuple tuple,
TridentCollector collector) |
void |
SingleEmitAggregator.aggregate(storm.trident.operation.impl.SingleEmitAggregator.SingleEmitState val,
TridentTuple tuple,
TridentCollector collector) |
void |
JoinerMultiReducer.complete(JoinerMultiReducer.JoinState state,
TridentTuple group,
TridentCollector collector) |
void |
JoinerMultiReducer.execute(JoinerMultiReducer.JoinState state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector) |
void |
GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state,
int streamIndex,
TridentTuple full,
TridentCollector collector) |
void |
IdentityMultiReducer.execute(Object state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
void |
FilterExecutor.execute(TridentTuple tuple,
TridentCollector collector) |
void |
CombinerAggregatorInitImpl.execute(TridentTuple tuple,
TridentCollector collector) |
JoinerMultiReducer.JoinState |
JoinerMultiReducer.init(TridentCollector collector,
TridentTuple group) |
boolean |
TrueFilter.isKeep(TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
GroupedMultiReducerExecutor.complete(Map<TridentTuple,Object> state,
TridentCollector collector) |
void |
GroupedMultiReducerExecutor.execute(Map<TridentTuple,Object> state,
int streamIndex,
TridentTuple full,
TridentCollector collector) |
void |
ReducerAggStateUpdater.updateState(Snapshottable state,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
CombinerAggStateUpdater.updateState(Snapshottable state,
List<TridentTuple> tuples,
TridentCollector collector) |
Constructor and Description |
---|
JoinState(int numSides,
TridentTuple group) |
Modifier and Type | Method and Description |
---|---|
void |
TupleReceiver.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
BridgeReceiver.execute(ProcessorContext context,
String streamId,
TridentTuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
StateQueryProcessor.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
ProjectedProcessor.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
PartitionPersistProcessor.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
MultiReducerProcessor.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
EachProcessor.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
AggregateProcessor.execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
AppendCollector.setContext(ProcessorContext pc,
TridentTuple t) |
Modifier and Type | Method and Description |
---|---|
void |
QueryFunction.execute(TridentTuple tuple,
T result,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
List<T> |
QueryFunction.batchRetrieve(S state,
List<TridentTuple> args) |
void |
StateUpdater.updateState(S state,
List<TridentTuple> tuples,
TridentCollector collector) |
Constructor and Description |
---|
ReducerValueUpdater(ReducerAggregator agg,
List<TridentTuple> tuples) |
Modifier and Type | Method and Description |
---|---|
void |
MapReducerAggStateUpdater.updateState(MapState map,
List<TridentTuple> tuples,
TridentCollector collector) |
void |
MapCombinerAggStateUpdater.updateState(MapState map,
List<TridentTuple> tuples,
TridentCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
CountAsAggregator.aggregate(storm.trident.testing.CountAsAggregator.State state,
TridentTuple tuple,
TridentCollector collector) |
void |
TuplifyArgs.execute(TridentTuple input,
TridentCollector collector) |
void |
StringLength.execute(TridentTuple tuple,
TridentCollector collector) |
void |
Split.execute(TridentTuple tuple,
TridentCollector collector) |
boolean |
TrueFilter.isKeep(TridentTuple tuple) |
Modifier and Type | Class and Description |
---|---|
class |
TridentTupleView |
Modifier and Type | Method and Description |
---|---|
TridentTuple |
TridentTupleView.FreshOutputFactory.create(List<Object> selfVals) |
TridentTuple |
TridentTupleView.ProjectionFactory.create(TridentTuple parent) |
TridentTuple |
TridentTupleView.OperationOutputFactory.create(TridentTupleView parent,
List<Object> selfVals) |
TridentTuple |
TridentTupleView.RootFactory.create(Tuple parent) |
static TridentTuple |
TridentTupleView.createFreshTuple(Fields fields,
List<Object> values) |
static TridentTuple |
TridentTupleView.createFreshTuple(Fields fields,
Object... values) |
Modifier and Type | Method and Description |
---|---|
TridentTuple |
TridentTupleView.ProjectionFactory.create(TridentTuple parent) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.