Mapper
Class Hierarchy for Mapper ClassesClasses that implement HBaseMapper Interface
Classes that implement HBaseValueMapper Interface
Classes that implement JdbcLookupMapper Interface
Classes that implement JdbcMapper Interface
Classes that implement TridentHBaseMapper Interface
Classes that implement TridentTupleMapper Interface
Classes that implement TridentTupleToKafkaMapper Interface
Classes that implement TupleToKafkaMapper Interface
List of Mapper Classes and Interfaces
Name | Type | Package | Detail |
DelimitedRecordHiveMapper | Class | bolt.mapper | Detail |
FieldNameBasedTupleToKafkaMapper | Class | trident.mapper | Detail |
FieldNameBasedTupleToKafkaMapper | Class | bolt.mapper | Detail |
HBaseMapper | Interface | bolt.mapper | Detail |
HBaseValueMapper | Interface | bolt.mapper | Detail |
JdbcLookupMapper | Interface | jdbc.mapper | Detail |
JdbcMapper | Interface | jdbc.mapper | Detail |
JsonRecordHiveMapper | Class | bolt.mapper | Detail |
SimpleHBaseMapper | Class | bolt.mapper | Detail |
SimpleJdbcLookupMapper | Class | jdbc.mapper | Detail |
SimpleJdbcMapper | Class | jdbc.mapper | Detail |
SimpleTridentHBaseMapper | Class | trident.mapper | Detail |
TridentHBaseMapper | Interface | trident.mapper | Detail |
TridentTupleMapper | Interface | trident.mapper | Detail |
TridentTupleToKafkaMapper | Interface | trident.mapper | Detail |
TupleToKafkaMapper | Interface | bolt.mapper | Detail |
Splitter
Class Hierarchy for Splitter ClassesList of Splitter Classes and Interfaces
Name | Type | Package | Detail |
Aggregator
Class Hierarchy for Aggregator ClassesClasses that implement Aggregator Interface
Classes that implement ChainedFullAggregatorDeclarer Interface
Classes that implement ChainedPartitionAggregatorDeclarer Interface
Classes that implement CombinerAggregator Interface
Classes that implement IChainedAggregatorDeclarer Interface
Classes that implement ReducerAggregator Interface
List of Aggregator Classes and Interfaces
Name | Type | Package | Detail |
Aggregator | Interface | trident.operation | Detail |
BaseAggregator | Class | trident.operation | Detail |
ChainedAggregatorDeclarer | Class | trident.fluent | Detail |
ChainedAggregatorImpl | Class | operation.impl | Detail |
ChainedFullAggregatorDeclarer | Interface | trident.fluent | Detail |
ChainedPartitionAggregatorDeclarer | Interface | trident.fluent | Detail |
CombinerAggregator | Interface | trident.operation | Detail |
CombinerAggregatorCombineImpl | Class | operation.impl | Detail |
CombinerAggregatorInitImpl | Class | operation.impl | Detail |
CountAsAggregator | Class | trident.testing | Detail |
GroupedAggregator | Class | operation.impl | Detail |
IChainedAggregatorDeclarer | Interface | trident.fluent | Detail |
ReducerAggregator | Interface | trident.operation | Detail |
ReducerAggregatorImpl | Class | operation.impl | Detail |
SingleEmitAggregator | Class | operation.impl | Detail |
Reader
Class Hierarchy for Reader ClassesClasses that implement IBrokerReader Interface
List of Reader Classes and Interfaces
Name | Type | Package | Detail |
DynamicBrokersReader | Class | storm.kafka | Detail |
IBrokerReader | Interface | kafka.trident | Detail |
StaticBrokerReader | Class | kafka.trident | Detail |
ZkBrokerReader | Class | kafka.trident | Detail |
Combiner
Class Hierarchy for Combiner ClassesClasses that implement CombinerAggregator Interface
Classes that implement ICombiner Interface
List of Combiner Classes and Interfaces
Name | Type | Package | Detail |
CombinerAggStateUpdater | Class | operation.impl | Detail |
CombinerAggregator | Interface | trident.operation | Detail |
CombinerAggregatorCombineImpl | Class | operation.impl | Detail |
CombinerAggregatorInitImpl | Class | operation.impl | Detail |
CombinerValueUpdater | Class | trident.state | Detail |
ICombiner | Interface | metric.api | Detail |
MapCombinerAggStateUpdater | Class | state.map | Detail |
Reducer
Class Hierarchy for Reducer ClassesClasses that implement GroupedMultiReducer Interface
Classes that implement IReducer Interface
Classes that implement MultiReducer Interface
Classes that implement ReducerAggregator Interface
List of Reducer Classes and Interfaces
Name | Type | Package | Detail |
BaseMultiReducer | Class | trident.operation | Detail |
GroupedMultiReducer | Interface | trident.operation | Detail |
GroupedMultiReducerExecutor | Class | operation.impl | Detail |
IReducer | Interface | metric.api | Detail |
IdentityMultiReducer | Class | operation.impl | Detail |
JoinerMultiReducer | Class | operation.impl | Detail |
MapReducerAggStateUpdater | Class | state.map | Detail |
MeanReducer | Class | metric.api | Detail |
MultiReducer | Interface | trident.operation | Detail |
MultiReducerProcessor | Class | planner.processor | Detail |
ReducerAggStateUpdater | Class | operation.impl | Detail |
ReducerAggregator | Interface | trident.operation | Detail |
ReducerAggregatorImpl | Class | operation.impl | Detail |
ReducerValueUpdater | Class | trident.state | Detail |
ReturnResultsReducer | Class | trident.drpc | Detail |
TridentMultiReducerContext | Class | trident.operation | Detail |
Partitioner
Class Hierarchy for Partitioner ClassesList of Partitioner Classes and Interfaces
Name | Type | Package | Detail |
Comparator
Class Hierarchy for Comparator ClassesList of Comparator Classes and Interfaces
Name | Type | Package | Detail |