MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodLogConfigManagerUnderTest
(AtomicReference<TreeMap<String, LogLevel>> latestLogConfig)
storm-client/test/jvm/org/apache/storm/daemon/worker/LogConfigManagerTest.java:257
MethodLogEntry
(long eventtime, String componentId, String fileOffset)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:283
MethodLogFileDownloader
Constructor. @param logRoot root worker log directory @param daemonLogRoot root daemon log directory @param resourceAuthorizer {@link ResourceAuthori
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/LogFileDownloader.java:49
MethodLogLevel
()
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:146
MethodLogLevelAction
(int value)
storm-client/src/jvm/org/apache/storm/generated/LogLevelAction.java:35
MethodLogLevelsParser
(LogLevelAction action)
storm-core/src/jvm/org/apache/storm/command/SetLogLevel.java:75
MethodLogUserGroupWhitelist
(Set<String> userWhitelist, Set<String> groupWhitelist)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/ResourceAuthorizer.java:154
MethodLogWriter
(InputStream in, Logger logger)
storm-client/src/jvm/org/apache/storm/LogWriter.java:30
MethodLogin
Login constructor. The constructor starts the thread used to periodically re-login to the Kerberos Ticket Granting Server. @param loginContextName
storm-client/src/jvm/org/apache/storm/messaging/netty/Login.java:82
MethodLoginCacheKey
(SortedMap<String, ?> authConf)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/KerberosSaslTransportPlugin.java:287
MethodLogviewerApplication
Constructor.
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/webapp/LogviewerApplication.java:58
MethodLogviewerConstant
()
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/LogviewerConstant.java:25
MethodLogviewerLogDownloadHandler
Constructor. @param logRoot root worker log directory @param daemonLogRoot root daemon log directory @param workerLogs {@link WorkerLogs} @param reso
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogDownloadHandler.java:44
MethodLogviewerLogPageHandler
Constructor. @param logRoot root worker log directory @param daemonLogRoot root daemon log directory @param workerLogs {@link WorkerLogs} @param reso
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogPageHandler.java:102
MethodLogviewerLogSearchHandler
Constructor. @param stormConf storm configuration @param logRoot log root directory @param daemonLogRoot daemon log root directory @param resourceAut
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:115
MethodLogviewerProfileHandler
Constructor. @param logRoot worker log root directory @param resourceAuthorizer {@link ResourceAuthorizer} @param metricsRegistry The logviewer metri
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerProfileHandler.java:66
MethodLogviewerResource
Constructor. @param logviewerParam {@link LogviewerLogPageHandler} @param profileHandler {@link LogviewerProfileHandler} @param logDownloadHandler {@
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/webapp/LogviewerResource.java:93
MethodLogviewerResponseBuilder
()
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/LogviewerResponseBuilder.java:46
MethodLogviewerServer
Constructor. @param conf Logviewer conf for the servers @param metricsRegistry The metrics registry
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/LogviewerServer.java:123
MethodLruCache
(int initialCapacity, float loadFactor)
external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/LocalOrHdfsImageTagToManifestPlugin.java:287
MethodLruMap
(int maxSize)
storm-server/src/main/java/org/apache/storm/utils/LruMap.java:22
MethodMapCombinerAggStateUpdater
(CombinerAggregator agg, Fields groupFields, Fields inputFields)
storm-client/src/jvm/org/apache/storm/trident/state/map/MapCombinerAggStateUpdater.java:41
MethodMapEntryCustomValidator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:661
MethodMapEntryTypeValidator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:637
MethodMapFunctionExecutor
(MapFunction function)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/MapFunctionExecutor.java:27
MethodMapProcessor
(Fields inputFields, Function function)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MapProcessor.java:40
MethodMapProcessor
(Function<T, R> function)
storm-client/src/jvm/org/apache/storm/streams/processors/MapProcessor.java:20
MethodMapReducerAggStateUpdater
(ReducerAggregator agg, Fields groupFields, Fields inputFields)
storm-client/src/jvm/org/apache/storm/trident/state/map/MapReducerAggStateUpdater.java:42
MethodMapValuesProcessor
(Function<V, R> function)
storm-client/src/jvm/org/apache/storm/streams/processors/MapValuesProcessor.java:21
MethodMasterBatchCoordinator
(List<String> spoutIds, List<ITridentSpout> spouts)
storm-client/src/jvm/org/apache/storm/trident/topology/MasterBatchCoordinator.java:58
MethodMatched
Constructor. @param fileOffset offset (index) of the files @param searchString search string @param matches map representing matched search result @p
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:773
MethodMax
(String inputFieldName)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/Max.java:21
MethodMaxWithComparator
(Comparator<T> comparator)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/MaxWithComparator.java:24
MethodMeasurements
Constructor. @param histo latency histogram. @param userMs user CPU in ms. @param sysMs system CPU in ms. @param gcMs GC CPU in ms.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:121
MethodMemory
(long limit, long reservation, long swap, long kernel, long kernelTcp, long
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:834
MethodMemoryCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:37
MethodMemoryMapState
(String id)
storm-client/src/jvm/org/apache/storm/trident/testing/MemoryMapState.java:44
MethodMemoryMapStateBacking
(String id)
storm-client/src/jvm/org/apache/storm/trident/testing/MemoryMapState.java:130
MethodMergeAggregateByKeyProcessor
(CombinerAggregator<V, A, R> aggregator)
storm-client/src/jvm/org/apache/storm/streams/processors/MergeAggregateByKeyProcessor.java:24
MethodMergeAggregateProcessor
(CombinerAggregator<T, A, R> aggregator)
storm-client/src/jvm/org/apache/storm/streams/processors/MergeAggregateProcessor.java:21
MethodMessageBatch
(int bufferSize)
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageBatch.java:25
MethodMessageBuffer
(int mesageBatchSize)
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageBuffer.java:24
MethodMessageDecoder
(KryoValuesDeserializer deser)
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageDecoder.java:30
MethodMessageId
(Map<Long, Long> anchorsToIds)
storm-client/src/jvm/org/apache/storm/tuple/MessageId.java:30
MethodMessageId
(long msgNumber, Path fullPath, FileOffset offset)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:796
MethodMetric
Metric constructor.
storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:49
MethodMetricException
(String message)
storm-server/src/main/java/org/apache/storm/metricstore/MetricException.java:18
MethodMetricExtractor
(BiFunction<Measurements, TimeUnit, Object> func)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:470
MethodMetricNames
(String longName, String shortName)
storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:439
MethodMetricsCleaner
(RocksDbStore store, int retentionHours, int hourlyPeriod, Meter failureMeter, StormMetricsRegistry metricsReg
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/MetricsCleaner.java:34
MethodMetricsCollectorConfig
(String topoName, Map<String, Object> topoConfig)
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/BasicMetricsCollector.java:257
MethodMetricsConsumerBolt
(String consumerClassName, Object registrationArgument, int maxRetainMetricTuples,
storm-client/src/jvm/org/apache/storm/metric/MetricsConsumerBolt.java:46
MethodMetricsState
(long lastTime, long lastStatted)
storm-core/src/jvm/org/apache/storm/utils/Monitor.java:172
MethodMetricsTask
(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints)
storm-client/src/jvm/org/apache/storm/metric/MetricsConsumerBolt.java:110
MethodMicroBatchIBackingMap
(final Options options, final IBackingMap<T> delegate)
storm-client/src/jvm/org/apache/storm/trident/state/map/MicroBatchIBackingMap.java:25
MethodMin
(String inputFieldName)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/Min.java:21
MethodMinWithComparator
(String inputFieldName, Comparator<T> comparator)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/MinWithComparator.java:24
MethodMiniDFSClusterExtension
()
external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtension.java:41
MethodMiniDFSClusterExtension
()
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtension.java:40
MethodMiniDFSClusterExtensionClassLevel
()
external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtensionClassLevel.java:39
MethodMiniDFSClusterExtensionClassLevel
()
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtensionClassLevel.java:38
MethodMockBasicContainer
(ContainerType type, Map<String, Object> conf, String supervisorId, int supervisorPort,
storm-server/src/test/java/org/apache/storm/daemon/supervisor/BasicContainerTest.java:679
MethodMockBinaryStateIterator
Constructor. @param pendingPrepareIterator The iterator of pendingPrepare @param pendingCommitIterator The iterator of pendingCommit
storm-client/test/jvm/org/apache/storm/state/BaseBinaryStateIteratorTest.java:149
MethodMockCollector
()
storm-client/test/jvm/org/apache/storm/bolt/TestJoinBolt.java:314
MethodMockCollector
()
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:714
MethodMockContainer
(ContainerType type, Map<String, Object> conf, String supervisorId, int supervisorPort,
storm-server/src/test/java/org/apache/storm/daemon/supervisor/ContainerTest.java:223
MethodMockContext
(String[] fieldNames)
storm-client/test/jvm/org/apache/storm/bolt/TestJoinBolt.java:330
MethodMockDirectoryBuilder
Constructor.
storm-webapp/src/test/java/org/apache/storm/daemon/logviewer/testsupport/MockDirectoryBuilder.java:35
MethodMockFileBuilder
Constructor.
storm-webapp/src/test/java/org/apache/storm/daemon/logviewer/testsupport/MockFileBuilder.java:35
MethodMockJmsProvider
()
external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockJmsProvider.java:36
MethodMockLeaderElector
()
storm-core/src/jvm/org/apache/storm/testing/MockLeaderElector.java:26
MethodMockTextFailingReader
(FileSystem fs, Path file, Map<String, Object> conf)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:755
MethodMockTopologyContext
(int componentId, Map<String, Object> topoConf)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:775
MethodMockTupleHelpers
()
storm-client/test/jvm/org/apache/storm/utils/MockTupleHelpers.java:21
MethodMockZookeeperClientBuilder
()
storm-server/src/test/java/org/apache/storm/blobstore/MockZookeeperClientBuilder.java:38
MethodMockedClientZookeeper
(ClientZookeeper inst)
storm-core/src/jvm/org/apache/storm/testing/staticmocking/MockedClientZookeeper.java:25
MethodMockedCluster
(ClusterUtils inst)
storm-core/src/jvm/org/apache/storm/testing/staticmocking/MockedCluster.java:19
MethodMockedSources
()
storm-client/src/jvm/org/apache/storm/testing/MockedSources.java:28
MethodMockedSupervisorUtils
(SupervisorUtils inst)
storm-core/src/jvm/org/apache/storm/testing/staticmocking/MockedSupervisorUtils.java:19
MethodMockedZookeeper
(Zookeeper inst)
storm-core/src/jvm/org/apache/storm/testing/staticmocking/MockedZookeeper.java:19
MethodMultiCountMetric
()
storm-client/src/jvm/org/apache/storm/metric/api/MultiCountMetric.java:21
MethodMultiCountStat
Constructor. @param numBuckets the number of buckets to divide the time periods into.
storm-client/src/jvm/org/apache/storm/metric/internal/MultiCountStat.java:34
MethodMultiLatencyStat
Constructor. @param numBuckets the number of buckets to divide the time periods into.
storm-client/src/jvm/org/apache/storm/metric/internal/MultiLatencyStat.java:32
MethodMultiReducedMetric
(IReducer reducer)
storm-client/src/jvm/org/apache/storm/metric/api/MultiReducedMetric.java:22
MethodMultiReducerProcessor
(List<Fields> inputFields, MultiReducer reducer)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MultiReducerProcessor.java:38
MethodMultiThriftServer
(String name)
storm-client/src/jvm/org/apache/storm/security/auth/MultiThriftServer.java:34
MethodMutableInt
(int val)
storm-client/src/jvm/org/apache/storm/utils/MutableInt.java:18
MethodMutableLong
(long val)
storm-client/src/jvm/org/apache/storm/utils/MutableLong.java:18
MethodMutableObject
()
storm-client/src/jvm/org/apache/storm/utils/MutableObject.java:18
MethodMyThd
(String thdName)
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/MyThd.java:26
MethodMyThread
(String thdName)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/MyThread.java:25
MethodNGrouping
(Integer n)
storm-client/src/jvm/org/apache/storm/testing/NGrouping.java:26
MethodNamedTopicFilter
Create filter based on a set of topic names. @param topics The topic names the filter will pass.
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/NamedTopicFilter.java:42
MethodNamespace
(String type, String path)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:626
MethodNegate
(Filter delegate)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/Negate.java:44
MethodNetClsCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/NetClsCore.java:26
MethodNetPrioCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/NetPrioCore.java:29
MethodNettyRenameThreadFactory
(String name)
storm-client/src/jvm/org/apache/storm/messaging/netty/NettyRenameThreadFactory.java:26
MethodNettySerializableMessageEncoder
()
storm-client/src/jvm/org/apache/storm/messaging/netty/NettySerializableMessageEncoder.java:25
MethodNetwork
(int classId, List<NetworkPriority> priorities)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1091
← previousnext →12,101–12,200 of 27,770, ranked by callers