MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodcancelBlobUpload
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:7442
MethodcancelBlobUpload
Parameters: - session
storm-client/src/py/storm/Nimbus.py:202
MethodcancelBlobUpload
Parameters: - session
storm-client/src/py/storm/Nimbus.py:1131
MethodcancelBlobUpload
(String session)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:910
MethodcancelBlobUpload
(String session)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:3905
MethodcancelBlobUpload_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:26935
MethodcancelBlobUpload_call
(java.lang.String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.s
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2545
MethodcancelBlobUpload_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:27311
Methodcb
(Metric metric)
storm-server/src/main/java/org/apache/storm/metricstore/MetricStore.java:64
MethodchainEnd
()
storm-client/src/jvm/org/apache/storm/trident/fluent/ChainedAggregatorDeclarer.java:44
MethodchainedAgg
()
storm-client/src/jvm/org/apache/storm/trident/fluent/GroupedStream.java:45
MethodchangeChildCWD
(boolean changeDirectory)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:81
MethodchangeChildCWD
Set if the current working directory of the child process should change to the resources dir from extracted from the jar, or if it should stay the sam
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:123
Methodchanged
(Watcher.Event.EventType type, String path)
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:98
MethodchannelActive
(ChannelHandlerContext ctx)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:41
MethodchannelActive
Implementing IServer.
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:258
MethodchannelActive
(ChannelHandlerContext ctx)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerHandler.java:35
MethodchannelActive
(ChannelHandlerContext ctx)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:45
MethodchannelActive
(ChannelHandlerContext ctx)
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClientHandler.java:33
MethodchannelActive
Implementing IServer.
storm-server/src/main/java/org/apache/storm/pacemaker/PacemakerServer.java:118
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerAuthorizeHandler.java:34
MethodchannelRead
(ChannelHandlerContext ctx, Object message)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:64
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerHandler.java:40
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java:38
MethodchannelRead
(ChannelHandlerContext ctx, Object message)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java:39
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslServerHandler.java:44
MethodchannelRead
(ChannelHandlerContext ctx, Object message)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:72
MethodchannelRead
(ChannelHandlerContext ctx, Object message)
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClientHandler.java:42
MethodchannelReady
(Channel channel)
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:539
MethodchannelReady
(Channel channel)
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClient.java:132
MethodchannelRegistered
(ChannelHandlerContext ctx)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:146
MethodchannelUnregistered
(ChannelHandlerContext ctx)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:152
MethodcheckClientTrusted
(X509Certificate[] chain, String authType)
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509TrustManager.java:45
MethodcheckClientTrusted
(X509Certificate[] chain, String authType)
external/storm-metrics-prometheus/src/test/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporterTest.java:183
MethodcheckClientTrusted
(X509Certificate[] chain, String authType)
external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporter.java:46
MethodcheckLogConfigChanged
()
storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java:468
MethodcheckSchedulingFeasibility
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ConstraintSolverStrategy.java:54
MethodcheckServerTrusted
(X509Certificate[] chain, String authType)
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509TrustManager.java:60
MethodcheckServerTrusted
(X509Certificate[] chain, String authType)
external/storm-metrics-prometheus/src/test/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporterTest.java:187
MethodcheckServerTrusted
(X509Certificate[] chain, String authType)
external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporter.java:50
FunctioncheckStream
(checkBox)
storm-webapp/src/main/webapp/js/visualization.js:379
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:217
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:138
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:192
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java:156
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java:192
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java:138
MethodcheckType
(_Fields setField, java.lang.Object value)
storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java:138
MethodcheckVersionInfo
()
storm-client/test/jvm/org/apache/storm/utils/UtilsTest.java:229
Functioncheck_for_errors
()
dev-tools/validate-license-files.py:180
Functioncheck_non_negative
(value)
bin/storm.py:520
Functioncheck_positive
(value)
bin/storm.py:527
MethodchooseClientAlias
(String[] strings, Principal[] principals, Socket socket)
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509KeyManager.java:87
MethodchooseServerAlias
(String s, Principal[] principals, Socket socket)
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509KeyManager.java:97
MethodchooseTask
Chooses one of the incoming tasks and selects the one that has been selected the fewest times so far.
storm-client/src/jvm/org/apache/storm/grouping/PartialKeyGrouping.java:182
MethodchooseTasks
(int fromTask, List<Object> values)
storm-client/src/jvm/org/apache/storm/trident/partition/IndexHashGrouping.java:42
MethodchooseTasks
(int i, List<Object> list)
storm-client/src/jvm/org/apache/storm/trident/partition/GlobalGrouping.java:33
MethodchooseTasks
(int task, List<Object> values)
storm-client/src/jvm/org/apache/storm/trident/partition/IdentityGrouping.java:45
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:51
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:144
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:172
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:192
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:218
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:234
MethodchooseTasks
(int taskId, List<Object> values)
storm-client/src/jvm/org/apache/storm/testing/NGrouping.java:40
MethodclassIsSerializable
()
storm-client/test/jvm/org/apache/storm/grouping/partialKeyGrouping/RandomTwoTaskAssignmentCreatorTest.java:29
MethodclassIsSerializable
()
storm-client/test/jvm/org/apache/storm/grouping/partialKeyGrouping/BalancedTargetSelectorTest.java:32
MethodcleanUp
()
storm-server/src/test/java/org/apache/storm/TickTupleTest.java:52
MethodcleanUp
()
storm-server/src/test/java/org/apache/storm/blobstore/LocalFsBlobStoreSynchronizerTest.java:65
MethodcleanUp
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Container.java:259
MethodcleanUpForRestart
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java:232
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/utils/TimeCacheMap.java:111
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/utils/VersionedStore.java:124
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/SubtopologyBolt.java:188
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/EachProcessor.java:57
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MultiReducerProcessor.java:60
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/PartitionPersistProcessor.java:59
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/StateQueryProcessor.java:59
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MapProcessor.java:57
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/ProjectedProcessor.java:44
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AggregateProcessor.java:52
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStateUpdater.java:71
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java:143
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutCoordinator.java:72
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutExecutor.java:82
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/MultiReducer.java:29
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/BaseMultiReducer.java:24
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/GroupedMultiReducer.java:29
Methodcleanup
No-op implemnation.
storm-client/src/jvm/org/apache/storm/trident/operation/BaseOperation.java:38
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ReducerAggStateUpdater.java:44
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ChainedAggregatorImpl.java:108
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/IdentityMultiReducer.java:42
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/SingleEmitAggregator.java:69
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/MapFunctionExecutor.java:41
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/FilterExecutor.java:43
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupedMultiReducerExecutor.java:85
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/FlatMapFunctionExecutor.java:42
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/PreservingFieldsOrderJoinerMultiReducer.java:90
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupedAggregator.java:86
Methodcleanup
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CombinerAggregatorCombineImpl.java:57
← previousnext →14,401–14,500 of 27,770, ranked by callers