MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 1 callersMethodgroupByKey
Returns a new stream where the values are grouped by the keys. @return the new stream
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:128
↓ 1 callersMethodgroupByKeyAndWindow
Returns a new stream where the values are grouped by keys and the given window. The values that arrive within a window having the same key will be mer
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:139
↓ 1 callersFunctiongroups_to_lines
Convert parsed groups back to lines for writing.
dev-tools/update-license-files.py:243
↓ 1 callersMethodgunzip
(byte[] data)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:945
↓ 1 callersMethodhaltTransferThd
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerTransfer.java:140
↓ 1 callersMethodhaltWorkerTransfer
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:817
↓ 1 callersMethodhandle
(Callback[] callbacks)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/ServerCallbackHandler.java:56
↓ 1 callersMethodhandle
A method used by doFilter which populates the request if it is null and then passes it on to the next entity in the chain. @param request the request
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/ReqContextFilter.java:79
↓ 1 callersMethodhandle
(HttpServletRequest request, HttpServletResponse response, FilterChain chain)
storm-server/src/main/java/org/apache/storm/logging/filters/AccessLoggingFilter.java:43
↓ 1 callersMethodhandle
(TaskInfo taskInfo, Collection<DataPoint> dataPoints, String topologyId)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/HttpForwardingMetricsServer.java:78
↓ 1 callersMethodhandleAck
(Object id)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:215
↓ 1 callersMethodhandleCheckpoint
Sub-classes can implement the logic for handling checkpoint tuple. @param checkpointTuple the checkpoint tuple @param action the action (pre
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java:144
↓ 1 callersMethodhandleCheckpointAck
()
storm-client/src/jvm/org/apache/storm/spout/CheckpointSpout.java:199
↓ 1 callersFunctionhandleClickEvent
(params)
storm-webapp/src/main/webapp/js/visualization.js:199
↓ 1 callersMethodhandleControlMessage
(ChannelHandlerContext ctx, ControlMessage controlMessage)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:89
↓ 1 callersMethodhandleControlMessage
(ChannelHandlerContext ctx, ControlMessage controlMessage)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:95
↓ 1 callersMethodhandleDataPoints
(TaskInfo taskInfo, Collection<DataPoint> dataPoints)
storm-client/src/jvm/org/apache/storm/metric/api/IMetricsConsumer.java:25
↓ 1 callersMethodhandleEmit
(ShellMsg shellMsg)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:235
↓ 1 callersMethodhandleError
(String msg)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:229
↓ 1 callersMethodhandleError
(String msg)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:231
↓ 1 callersMethodhandleEvictedMetadata
(RocksDbKey key, RocksDbValue val)
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbMetricsWriter.java:271
↓ 1 callersMethodhandleFail
(Object id)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:223
↓ 1 callersMethodhandleGetCommand
(IStateStorage cluster, String path)
storm-core/src/jvm/org/apache/storm/command/Heartbeats.java:71
↓ 1 callersMethodhandleKill
State Transitions for KILL state. PRECONDITION: container.kill() was called PRECONDITION: container != null && currentAssignment != null @param dynami
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:569
↓ 1 callersMethodhandleKillAndRelaunch
State Transitions for KILL_AND_RELAUNCH state. PRECONDITION: container.kill() was called PRECONDITION: container != null && currentAssignment != null
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:607
↓ 1 callersMethodhandleKillBlobUpdate
State Transitions for KILL_BLOB_UPDATE state. PRECONDITION: container.kill() was called PRECONDITION: container != null && currentAssignment != null
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:655
↓ 1 callersMethodhandleListCommand
(IStateStorage cluster, String path)
storm-core/src/jvm/org/apache/storm/command/Heartbeats.java:66
↓ 1 callersMethodhandleMetrics
(ShellMsg shellMsg)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:154
↓ 1 callersMethodhandleMetrics
(ShellMsg shellMsg)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:259
↓ 1 callersMethodhandleProcessorNode
(ProcessorNode processorNode, TopologyBuilder topologyBuilder)
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:283
↓ 1 callersMethodhandleRecovery
()
storm-client/src/jvm/org/apache/storm/spout/CheckpointSpout.java:173
↓ 1 callersMethodhandleRecovery
(Tuple input)
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:102
↓ 1 callersMethodhandleRecoveryAck
()
storm-client/src/jvm/org/apache/storm/spout/CheckpointSpout.java:179
↓ 1 callersMethodhandleRelativePath
(String localRepoPath)
storm-submit-tools/src/main/java/org/apache/storm/submit/dependency/DependencyResolver.java:85
↓ 1 callersMethodhandleRunning
State Transitions for RUNNING state. PRECONDITION: container != null && currentAssignment != null @param dynamicState current state @param staticState
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:768
↓ 1 callersMethodhandleSaslMessageToken
(ChannelHandlerContext ctx, SaslMessageToken saslMessageToken)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:114
↓ 1 callersMethodhandleSaslMessageToken
(ChannelHandlerContext ctx, SaslMessageToken saslMessageToken)
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:119
↓ 1 callersMethodhandleTuple
Sub-classes can implement the logic for handling the tuple. @param input the input tuple
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java:135
↓ 1 callersMethodhandleWaitingForBlobLocalization
State Transitions for WAITING_FOR_BLOB_LOCALIZATION state, when the slot is waiting for blobs of the pending assignment to be completely downloaded, b
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:409
↓ 1 callersMethodhandleWaitingForBlobUpdate
State Transitions for WAITING_FOR_BLOB_UPDATE state. <p>PRECONDITION: container is null PRECONDITION: pendingChangingBlobs is not empty (otherwise wh
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:500
↓ 1 callersMethodhandleWaitingForWorkerStart
State Transitions for WAITING_FOR_WORKER_START state. PRECONDITION: container != null && currentAssignment != null @param dynamicState current state @
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:705
↓ 1 callersMethodhandleWaterMarkEvent
Triggers all the pending windows up to the waterMarkEvent timestamp based on the sliding interval count. @param waterMarkEvent the watermark event
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountTriggerPolicy.java:66
↓ 1 callersMethodhandleWaterMarkEvent
Invokes the trigger all pending windows up to the watermark timestamp. The end ts of the window is set in the eviction policy context so that the even
storm-client/src/jvm/org/apache/storm/windowing/WatermarkTimeTriggerPolicy.java:66
↓ 1 callersMethodhandleWorkerUncaughtException
(Throwable t)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:675
↓ 1 callersMethodhasCause
Checks if the given exception or any of its causes is an instance of the expected class.
storm-server/src/test/java/org/apache/storm/security/auth/NimbusAuthTest.java:66
↓ 1 callersMethodhasConstructor
(Class<?> clazz, Class<?> paramClass)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:246
↓ 1 callersMethodhasConstructorArgs
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/ObjectDef.java:77
↓ 1 callersMethodhasExpired
(long lastModifyTime)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:678
↓ 1 callersMethodhasFactory
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/ObjectDef.java:101
↓ 1 callersMethodhasFactoryArgs
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/ObjectDef.java:105
↓ 1 callersMethodhasLeader
Checks if Nimbuses have elected a leader. @return true if there is a leader else false.
storm-server/src/main/java/org/apache/storm/LocalCluster.java:414
↓ 1 callersMethodhasMessages
(Iterator<TaskMessage> msgs)
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:389
↓ 1 callersMethodhasNext
()
storm-client/src/jvm/org/apache/storm/blobstore/NimbusBlobStore.java:251
↓ 1 callersMethodhasOutgoingChild
(ProcessorNode processorNode, Set<ProcessorNode> boltChildren)
storm-client/src/jvm/org/apache/storm/streams/ProcessorBoltDelegate.java:254
↓ 1 callersMethodhasRemoteOutboundTasks
Check if this worker has remote outbound tasks. @return true if this worker has remote outbound tasks; false otherwise.
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:802
↓ 1 callersMethodhasSpouts
Determine if there are non-system spouts. @return true if there is at least one non-system spout, false otherwise
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:278
↓ 1 callersMethodhasStatefulProcessor
(List<ProcessorNode> processorNodes)
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:409
↓ 1 callersMethodhas_jira_id
(self)
dev-tools/github/__init__.py:82
↓ 1 callersMethodhashCode
()
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java:179
↓ 1 callersMethodhashCode
()
storm-client/src/jvm/org/apache/storm/trident/planner/Node.java:49
↓ 1 callersMethodhashCode
()
storm-client/src/jvm/org/apache/storm/streams/Pair.java:90
↓ 1 callersMethodhashCode
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/User.java:211
↓ 1 callersMethodhashCode
All implementations of PortAndAssignment should implement the same hashCode() method.
storm-server/src/main/java/org/apache/storm/localizer/PortAndAssignmentImpl.java:54
↓ 1 callersMethodhashCode
All implementations of PortAndAssignment should implement the same hashCode() method.
storm-server/src/main/java/org/apache/storm/localizer/TimePortAndAssignment.java:60
↓ 1 callersMethodhashCode
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:320
↓ 1 callersMethodhashJoin
(List<Tuple> tuples)
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:194
↓ 1 callersMethodhdel
(NavigableMap<byte[], NavigableMap<byte[], byte[]>> mockMap, byte[] namespace, byte[]... keys)
external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateTest.java:207
↓ 1 callersFunctionhdfs_get
(src, dest, print_stdout=False, print_stderr=False, raise_on_error=True)
bin/docker-to-squash.py:134
↓ 1 callersFunctionhdfs_ls
(file_path, options="", print_stdout=False, print_stderr=False, raise_on_error=True)
bin/docker-to-squash.py:143
↓ 1 callersFunctionhdfs_mkdir
(file_path, print_stdout=False, print_stderr=True, raise_on_error=True, create_parents=False)
bin/docker-to-squash.py:161
↓ 1 callersMethodheartbeatToMasterIfLocalbeatFail
Send a heartbeat to local supervisor first to check if supervisor is ok for heartbeating.
storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java:481
↓ 1 callersMethodhget
(NavigableMap<byte[], NavigableMap<byte[], byte[]>> mockMap, byte[] namespace, byte[] key)
external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateTest.java:200
↓ 1 callersMethodhgetAll
(NavigableMap<byte[], NavigableMap<byte[], byte[]>> mockMap, String key)
external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateTest.java:234
↓ 1 callersFunctionhide_visualization
(sys)
storm-webapp/src/main/webapp/js/script.js:588
↓ 1 callersMethodhostAssignableSlots
(Cluster cluster)
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:307
↓ 1 callersMethodhostAssignments
(Cluster cluster)
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:193
↓ 1 callersMethodhostnameImpl
()
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1800
↓ 1 callersMethodhostnameToNodes
hostname to Ids. @param hostname the hostname. @return the ids n that node.
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/BaseResourceAwareStrategy.java:389
↓ 1 callersMethodhostnameToNodes
hostname to Ids. @param hostname the hostname. @return the ids n that node.
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorterHostProximity.java:692
↓ 1 callersMethodidify
(List<String> names)
storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java:243
↓ 1 callersMethodinactiveExecute
()
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:276
↓ 1 callersMethodincomingGroups
(Group g)
storm-client/src/jvm/org/apache/storm/trident/graph/GraphGrouper.java:102
↓ 1 callersMethodincrBy
(long incrementBy)
storm-client/src/jvm/org/apache/storm/metric/api/CountMetric.java:25
↓ 1 callersMethodincrement
()
storm-client/src/jvm/org/apache/storm/utils/MutableLong.java:30
↓ 1 callersMethodincrement
(TridentCollector[] lengths, int[] indices, int j)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ChainedAggregatorImpl.java:95
↓ 1 callersMethodincrement
(List[] lengths, int[] indices, int j, int overrideIndex)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/PreservingFieldsOrderJoinerMultiReducer.java:156
↓ 1 callersMethodincrement
(List[] lengths, int[] indices, int j, int overrideIndex)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/JoinerMultiReducer.java:124
↓ 1 callersMethodincrementCount
(T obj)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlidingWindowCounter.java:85
↓ 1 callersMethodincrementCurrentSize
()
storm-client/src/jvm/org/apache/storm/trident/windowing/InMemoryWindowsStore.java:119
↓ 1 callersMethodindex
()
storm-client/src/jvm/org/apache/storm/tuple/Fields.java:111
↓ 1 callersMethodinformAllOfChangeAndWaitForConsensus
Inform all of the callbacks that a change is going to happen and then wait for them to all get back that it is OK to make that change. @return A futu
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java:292
↓ 1 callersMethodinformReferencesAndCommitNewVersion
Inform all of the callbacks that a change is going to happen and then wait for them to all get back that it is OK to make that change. Commit the new
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java:280
↓ 1 callersMethodinit
(long txid, Object lastState)
storm-client/src/jvm/org/apache/storm/trident/topology/state/RotatingTransactionalState.java:179
↓ 1 callersMethodinit
(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector, KeyVa
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:66
↓ 1 callersMethodinit
(final ArrayList<Task> idToTask, int idToTaskBase)
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:97
↓ 1 callersMethodinit
(ArrayList<Task> idToTask, int idToTaskBase)
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltExecutor.java:94
↓ 1 callersMethodinit
()
storm-client/src/jvm/org/apache/storm/dependency/DependencyUploader.java:58
↓ 1 callersMethodinit
Initialize the pool. @param cluster the cluster @param nodeIdToNode the mapping of node id to nodes
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/NodePool.java:119
↓ 1 callersMethodinitBatchState
(String batchGroup, Object batchId)
storm-client/src/jvm/org/apache/storm/trident/topology/ITridentBatchBolt.java:28
↓ 1 callersMethodinitCache
()
storm-client/src/jvm/org/apache/storm/windowing/persistence/WindowState.java:217
← previousnext →8,401–8,500 of 27,770, ranked by callers