MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 3 callersMethodcloseUnderlyingLockFile
(FileLock lock)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestFileLock.java:48
↓ 3 callersMethodclose_channel
()
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClient.java:257
↓ 3 callersMethodcluster
(MkClusterParam param, boolean simulated)
storm-server/src/main/java/org/apache/storm/Testing.java:139
↓ 3 callersMethodcollectMapValues
(Map<String, Set<String>> map)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/priority/TestGenericResourceAwareSchedulingPriorityStrategy.java:236
↓ 3 callersMethodcombine
(CombinerAggregator<? super T, A, ? extends R> aggregator)
storm-client/src/jvm/org/apache/storm/streams/Stream.java:461
↓ 3 callersMethodcombineByKey
(CombinerAggregator<? super V, A, ? extends R> aggregator)
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:458
↓ 3 callersMethodcommit
()
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGTKrb5LoginModule.java:68
↓ 3 callersMethodcommit
()
storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreFile.java:53
↓ 3 callersMethodcommitAndVerifyAllMessagesCommitted
(long msgCount)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutAbstractTest.java:172
↓ 3 callersMethodcommitOffsetsForAckedTuples
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java:505
↓ 3 callersMethodcommitProgress
(FileOffset position)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:308
↓ 3 callersMethodcompareTo
(SimpleVersion o)
storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java:69
↓ 3 callersMethodconfigSsl
(Server server, Integer port, String ksPath, String ksPassword, String ksType
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:269
↓ 3 callersMethodconfigureLogHandler
(String className)
storm-client/test/jvm/org/apache/storm/utils/ShellUtilsTest.java:27
↓ 3 callersMethodconnectionEstablished
(Channel channel)
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:270
↓ 3 callersMethodconstructUserCacheDir
(String base, String user)
storm-server/src/test/java/org/apache/storm/localizer/AsyncLocalizerTest.java:353
↓ 3 callersMethodcontainsEmitted
(long offset)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java:214
↓ 3 callersMethodconvertToDouble
(Map<String, Map<String, Number>> raw)
storm-server/src/main/java/org/apache/storm/scheduler/resource/ResourceAwareScheduler.java:467
↓ 3 callersMethodcountByKey
Counts the values for each key of this stream. @return the new stream
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:109
↓ 3 callersMethodcounter
(String name, WorkerTopologyContext context, String componentId, Integer taskId, String streamId)
storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:140
↓ 3 callersMethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/ClientFactory.java:31
↓ 3 callersMethodcreateClusterConfig
(double compPcore, double compOnHeap, double compOffHeap, Map<String, M
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/TestRoundRobinNodeSorterHostProximity.java:87
↓ 3 callersMethodcreateDefaultUncaughtExceptionHandler
()
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1052
↓ 3 callersMethodcreateLoadMapping
(double load1, double load2, double load3)
storm-client/test/jvm/org/apache/storm/grouping/LoadAwareShuffleGroupingTest.java:529
↓ 3 callersMethodcreateQueue
(String name, int queueSize)
storm-client/test/jvm/org/apache/storm/utils/JCQueueTest.java:154
↓ 3 callersMethodcreateSeqFile
(FileSystem fs, Path file, int rowCount)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:103
↓ 3 callersMethodcreateStateInZookeeper
(Map<String, Object> conf, String key, NimbusInfo nimbusInfo)
storm-server/src/main/java/org/apache/storm/blobstore/BlobStoreUtils.java:239
↓ 3 callersMethodcreateTestStormTopology
(StormTopology stormTopology, int priority, String name, Config conf)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestGenericResourceAwareStrategy.java:427
↓ 3 callersMethodcreateTestTuple
(String... values)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/bolt/KafkaBoltTest.java:62
↓ 3 callersMethodcreateTopologyContext
(Map<String, Object> topoConf)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/format/TestSimpleFileNameFormat.java:72
↓ 3 callersMethodcredentialsPath
(String stormId)
storm-client/src/jvm/org/apache/storm/cluster/ClusterUtils.java:194
↓ 3 callersMethodcurrentSubject
Return the current {@link Subject}, equivalent to {@code Subject.current()} on Java 18+ or {@code Subject.getSubject(AccessController.getContext())} o
storm-client/src/jvm/org/apache/storm/security/auth/SubjectCompat.java:51
↓ 3 callersMethoddaemonLogPage
Provides a daemon log file to view. @param fileName file to view @param start start offset, or null if the most recent page is desired @param length
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogPageHandler.java:293
↓ 3 callersMethoddeclareGrouping
(BoltDeclarer boltDeclarer, Node parent, String streamId, GroupingInfo grouping)
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:572
↓ 3 callersMethoddecodeValue
Decode value. @param encodedValue the value of key (VENCODEDT type) @return the decoded value of key (V type)
storm-client/src/jvm/org/apache/storm/state/StateEncoder.java:49
↓ 3 callersMethoddelete
()
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStoreFile.java:68
↓ 3 callersMethoddeleteBlobs
(List<String> keys)
storm-client/src/jvm/org/apache/storm/dependency/DependencyUploader.java:133
↓ 3 callersMethoddeserialize
(byte[] b)
storm-client/src/jvm/org/apache/storm/state/DefaultStateSerializer.java:97
↓ 3 callersMethoddeserializeComponentObject
(ComponentObject obj)
storm-client/src/jvm/org/apache/storm/Thrift.java:188
↓ 3 callersMethoddeserializeFrom
(Input input)
storm-client/src/jvm/org/apache/storm/serialization/KryoValuesDeserializer.java:30
↓ 3 callersMethoddeserializePartitions
(List<Map<String, Object>> tps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutOpaqueCoordinatorTest.java:131
↓ 3 callersMethoddie
(Throwable exception)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:295
↓ 3 callersMethoddirectGrouping
()
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCInputDeclarer.java:45
↓ 3 callersMethoddirectOutputFields
(List<String> fields)
storm-client/src/jvm/org/apache/storm/Thrift.java:75
↓ 3 callersMethoddoCleanup
Cleanup topologies and Jars.
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:2896
↓ 3 callersMethoddoEmitNewBatchTest
(FirstPollOffsetStrategy firstPollOffsetStrategy, TridentCollector collectorMock, TopicPartition tp, Map<Strin
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterEmitTest.java:123
↓ 3 callersMethoddoGet
Protected so we can override this in unit tests. @param api null if we are trying to download artifact, otherwise a string to call REST api, e
storm-server/src/main/java/org/apache/storm/scheduler/utils/ArtifactoryConfigLoader.java:141
↓ 3 callersMethoddownloadDaemonLogFile
Download a daemon log. @param host host address @param fileName file to download @param user username @return a Response which lets browsers download
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogDownloadHandler.java:72
↓ 3 callersMethoddownloadLogFile
Download a worker log. @param host host address @param fileName file to download @param user username @return a Response which lets browsers download
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogDownloadHandler.java:59
↓ 3 callersMethoddownloadMissingBlob
(Map<String, Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)
storm-server/src/main/java/org/apache/storm/blobstore/BlobStoreUtils.java:121
↓ 3 callersFunctionemit
(*args, **kwargs)
storm-multilang/python/src/main/resources/resources/storm.py:101
↓ 3 callersMethodemit
(Values values, String outputStreamId)
storm-client/src/jvm/org/apache/storm/streams/processors/EmittingProcessorContext.java:133
↓ 3 callersMethodemitBatch
Emit a batch for the specified transaction attempt and metadata for the transaction. The metadata was created by the Coordinator in the initializeTran
storm-client/src/jvm/org/apache/storm/trident/spout/ITridentSpout.java:106
↓ 3 callersMethodemptyMockMap
()
storm-client/test/jvm/org/apache/storm/utils/UtilsTest.java:88
↓ 3 callersMethodencodeLength
()
storm-client/src/jvm/org/apache/storm/messaging/netty/INettySerializable.java:24
↓ 3 callersMethodencodeValue
Encode value. @param value the value of value (V type) @return the encoded value of value (VENCODEDT type)
storm-client/src/jvm/org/apache/storm/state/StateEncoder.java:33
↓ 3 callersMethodensureCountLessThanMaxPending
(int count, int maxPending)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:115
↓ 3 callersMethodensureDurationLessThanTimeout
(int duration, int timeout)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:108
↓ 3 callersMethodequals
(Object obj)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpuCore.java:105
↓ 3 callersMethodequals
(Object other)
storm-client/src/jvm/org/apache/storm/tuple/Fields.java:122
↓ 3 callersMethodequals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:611
↓ 3 callersMethodequals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:343
↓ 3 callersMethodequals
(Object o)
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:626
↓ 3 callersMethodequals
(Object other)
storm-server/src/main/java/org/apache/storm/scheduler/SchedulerAssignmentImpl.java:125
↓ 3 callersMethoderrorPath
(String stormId, String componentId)
storm-client/src/jvm/org/apache/storm/cluster/ClusterUtils.java:186
↓ 3 callersFunctionescapeHtml
(str)
storm-webapp/src/main/webapp/lib/jsonFormatter.js:37
↓ 3 callersMethodexec
(String cmd)
storm-client/src/jvm/org/apache/storm/container/cgroup/SystemOperation.java:52
↓ 3 callersMethodexecute
Execute the shell command.
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:423
↓ 3 callersMethodexecute
Performs the function logic on an individual tuple and emits 0 or more tuples. @param tuple The incoming tuple @param collector A collector insta
storm-client/src/jvm/org/apache/storm/trident/operation/Function.java:61
↓ 3 callersMethodexecute
(Server s)
storm-webapp/src/main/java/org/apache/storm/daemon/ui/IConfigurator.java:18
↓ 3 callersMethodexecute
(Tuple tuple)
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java:89
↓ 3 callersMethodexists
(String key)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java:23
↓ 3 callersMethodexpandAverages
Expand the count/average out into total, count. @param avgs a HashMap of values: { win -> GlobalStreamId -> value } @param counts a HashMap of value
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:2281
↓ 3 callersMethodexpandDataPoint
(IMetricsConsumer.DataPoint dataPoint)
storm-client/src/jvm/org/apache/storm/metric/util/DataPointExpander.java:50
↓ 3 callersMethodexpectNullPointerException
(ConnectionProvider provider, String selectQuery, JdbcLookupMapper mapper)
external/storm-jdbc/src/test/java/org/apache/storm/jdbc/bolt/JdbcLookupBoltTest.java:42
↓ 3 callersMethodexternalGroupInputs
(Group g)
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:468
↓ 3 callersMethodextractDirFromJar
(String jarpath, String dir, Path dest)
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:184
↓ 3 callersMethodfetchRequest
(String func)
storm-client/src/jvm/org/apache/storm/drpc/DRPCInvocationsClient.java:77
↓ 3 callersMethodfetchUnzipToTemp
(ClientBlobStore store)
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:132
↓ 3 callersMethodfindByName
Find the _Fields constant that matches name, or null if its not found.
storm-client/src/jvm/org/apache/storm/generated/Bolt.java:81
↓ 3 callersMethodfinish
(List<Measurements> allTime)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:312
↓ 3 callersMethodfinishedId
(Object id)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:240
↓ 3 callersMethodfirst
Get the first element in list. @param list list to get @return the first element. null if list is null or empty.
storm-webapp/src/main/java/org/apache/storm/daemon/utils/ListFunctionalSupport.java:35
↓ 3 callersMethodflush
()
storm-client/src/jvm/org/apache/storm/spout/ISpoutOutputCollector.java:33
↓ 3 callersMethodflush
()
storm-client/src/jvm/org/apache/storm/task/IOutputCollector.java:33
↓ 3 callersMethodfreeSlots
Free everything on the given slots. @param workerSlots the slots to free
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNodes.java:132
↓ 3 callersMethodfromConf
Read the stats from a config. @param conf the config. @return the corresponding stats.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/NormalDistStats.java:46
↓ 3 callersMethodfromJson
(String str)
storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusClojurePortTest.java:890
↓ 3 callersMethodfullCleanup
(long age)
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStore.java:472
↓ 3 callersMethodfullMergeWithSum
equals to clojure's: (merge-with (partial merge-with sum-or-0) acc-out spout-out).
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:1736
↓ 3 callersMethodgenerateAccessControlsInfo
(List<AccessControl> acl)
storm-core/src/jvm/org/apache/storm/command/Blobstore.java:266
↓ 3 callersMethodgenerateId
(Random rand)
storm-client/src/jvm/org/apache/storm/tuple/MessageId.java:34
↓ 3 callersMethodgenerateParallelismHint
()
storm-server/src/test/java/org/apache/storm/nimbus/LocalNimbusTest.java:56
↓ 3 callersMethodgenerateWindowTriggerKey
(String windowTaskId, int triggerId)
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java:98
↓ 3 callersMethodgetActive
()
integration-test/src/test/java/org/apache/storm/st/wrapper/StormCluster.java:69
↓ 3 callersMethodgetAggLevel
()
storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:112
↓ 3 callersMethodgetAllOutputFields
(List streams)
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:493
↓ 3 callersMethodgetAllPids
Get all the pids that are a part of the container. @return all of the pids that are a part of this container
storm-server/src/main/java/org/apache/storm/container/DefaultResourceIsolationManager.java:129
↓ 3 callersMethodgetAllScheduledResourcesForNode
(String nodeId)
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:1114
↓ 3 callersMethodgetAnchors
()
storm-client/src/jvm/org/apache/storm/tuple/MessageId.java:65
← previousnext →3,301–3,400 of 27,770, ranked by callers