Uses of Interface
org.apache.storm.trident.operation.Operation
-
-
Uses of Operation in org.apache.storm.hdfs.trident
Classes in org.apache.storm.hdfs.trident that implement Operation Modifier and Type Class Description classHdfsUpdater -
Uses of Operation in org.apache.storm.hive.trident
Classes in org.apache.storm.hive.trident that implement Operation Modifier and Type Class Description classHiveUpdaterDeprecated, for removal: This API element is subject to removal in a future version. -
Uses of Operation in org.apache.storm.jdbc.trident.state
Classes in org.apache.storm.jdbc.trident.state that implement Operation Modifier and Type Class Description classJdbcQueryclassJdbcUpdater -
Uses of Operation in org.apache.storm.jms.trident
Classes in org.apache.storm.jms.trident that implement Operation Modifier and Type Class Description classJmsUpdater -
Uses of Operation in org.apache.storm.kafka.trident
Classes in org.apache.storm.kafka.trident that implement Operation Modifier and Type Class Description classTridentKafkaStateUpdater<K,V> -
Uses of Operation in org.apache.storm.redis.trident
Classes in org.apache.storm.redis.trident that implement Operation Modifier and Type Class Description classPrintFunction -
Uses of Operation in org.apache.storm.redis.trident.state
Classes in org.apache.storm.redis.trident.state that implement Operation Modifier and Type Class Description classAbstractRedisStateQuerier<T extends State>AbstractRedisStateQuerier is base class of any RedisStateQuerier, which implements BaseQueryFunction.classAbstractRedisStateUpdater<T extends State>AbstractRedisStateUpdater is base class of any RedisStateUpdater, which implements BaseStateUpdater.classRedisClusterStateQuerierBaseQueryFunction implementation for Redis Cluster environment.classRedisClusterStateUpdaterBaseStateUpdater implementation for Redis Cluster environment.classRedisStateQuerierBaseQueryFunction implementation for single Redis environment.classRedisStateUpdaterBaseStateUpdater implementation for single Redis environment. -
Uses of Operation in org.apache.storm.starter.trident
Classes in org.apache.storm.starter.trident that implement Operation Modifier and Type Class Description static classTridentReach.ExpandListstatic classTridentWordCount.Split -
Uses of Operation in org.apache.storm.trident.operation
Subinterfaces of Operation in org.apache.storm.trident.operation Modifier and Type Interface Description interfaceAggregator<T>interfaceEachOperationinterfaceFilterFilters take in a tuple as input and decide whether or not to keep that tuple or not.interfaceFunctionA function takes in a set of input fields and emits zero or more tuples as output.interfaceOperationAwareFlatMapFunctionA one to many transformation function which is aware of Operation (lifecycle of the Trident component).interfaceOperationAwareMapFunctionA one-one transformation function which is aware of Operation (lifecycle of the Trident component).Classes in org.apache.storm.trident.operation that implement Operation Modifier and Type Class Description classBaseAggregator<T>classBaseFilterclassBaseFunctionclassBaseOperationConvenience implementation of theOperationinterface. -
Uses of Operation in org.apache.storm.trident.operation.builtin
Classes in org.apache.storm.trident.operation.builtin that implement Operation Modifier and Type Class Description classComparisonAggregator<T>AbstractAggregatorfor comparing two values in a stream.classDebugFilter for debugging purposes.classEqualsclassFilterNullSimple `Filter` implementation that filters out any tuples that have fields with a value of `null`.static classFirstN.FirstNAggstatic classFirstN.FirstNSortedAggclassMapGetclassMaxThis aggregator computes the maximum of aggregated tuples in a stream.classMaxWithComparator<T>This aggregator computes the maximum of aggregated tuples in a stream.classMinThis aggregator computes the minimum of aggregated tuples in a stream.classMinWithComparator<T>This aggregator computes the minimum of aggregated tuples in a stream.classNegateA `Filter` implementation that inverts another delegate `Filter`.classSnapshotGetclassTupleCollectionGet -
Uses of Operation in org.apache.storm.trident.operation.impl
Classes in org.apache.storm.trident.operation.impl that implement Operation Modifier and Type Class Description classChainedAggregatorImplclassCombinerAggregatorCombineImplclassCombinerAggregatorInitImplclassCombinerAggStateUpdaterclassConsumerExecutorclassFilterExecutorclassFlatMapFunctionExecutorclassGroupedAggregatorclassMapFunctionExecutorclassReducerAggregatorImplclassReducerAggStateUpdaterclassSingleEmitAggregatorclassTrueFilter -
Uses of Operation in org.apache.storm.trident.state
Subinterfaces of Operation in org.apache.storm.trident.state Modifier and Type Interface Description interfaceQueryFunction<S extends State,T>interfaceStateUpdater<S extends State>Classes in org.apache.storm.trident.state that implement Operation Modifier and Type Class Description classBaseQueryFunction<S extends State,T>classBaseStateUpdater<S extends State> -
Uses of Operation in org.apache.storm.trident.state.map
Classes in org.apache.storm.trident.state.map that implement Operation Modifier and Type Class Description classMapCombinerAggStateUpdaterclassMapReducerAggStateUpdater -
Uses of Operation in org.apache.storm.trident.testing
Classes in org.apache.storm.trident.testing that implement Operation Modifier and Type Class Description classCountAsAggregatorclassSplitclassStringLengthclassTrueFilterclassTuplifyArgs -
Uses of Operation in org.apache.storm.trident.windowing
Classes in org.apache.storm.trident.windowing that implement Operation Modifier and Type Class Description classWindowsStateUpdaterStateUpdater<WindowState>instance which removes successfully emitted triggers from store.
-