MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

MethodSaslClientCallbackHandler
Set private members using topology token.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyClient.java:99
MethodSaslDigestCallbackHandler
(String topologyName, byte[] token)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java:91
MethodSaslMessageToken
Constructor used for reflection only.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslMessageToken.java:35
MethodSaslNettyClient
Create a SaslNettyClient for authentication with servers.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyClient.java:45
MethodSaslNettyServer
(String topologyName, byte[] token)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java:36
MethodSaslPlainServer
(CallbackHandler callback)
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:33
MethodSaslStormClientHandler
(ISaslClient client)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:35
MethodSaslStormServerAuthorizeHandler
Constructor.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerAuthorizeHandler.java:31
MethodSaslStormServerHandler
(ISaslServer server)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java:33
MethodScheduleRunnable
(int runnableNum)
storm-client/test/jvm/org/apache/storm/TestStormTimer.java:117
MethodSchedulerAssignmentImpl
Create a new assignment. @param topologyId the id of the topology the assignment is for. @param executorToSlot the execut
storm-server/src/main/java/org/apache/storm/scheduler/SchedulerAssignmentImpl.java:57
MethodSchedulerConfigCache
(Map<String, Object> conf, Reloadable<T> reloader)
storm-server/src/main/java/org/apache/storm/scheduler/utils/SchedulerConfigCache.java:39
MethodSchedulingResult
(SchedulingStatus status, String message, String errorMessage)
storm-server/src/main/java/org/apache/storm/scheduler/resource/SchedulingResult.java:34
MethodSchedulingSearcherState
(Map<WorkerSlot, Map<String, Integer>> workerCompAssignmentCnts, Map<RasNo
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:87
MethodSchemeAsMultiScheme
(Scheme scheme)
storm-client/src/jvm/org/apache/storm/spout/SchemeAsMultiScheme.java:23
MethodScopedTopologySet
Constructor. @param client the client used to kill the topologies when this exist.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ScopedTopologySet.java:50
MethodSeccomp
(String defaultAction, List<String> architectures, List<Syscall> syscalls)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1213
MethodSeccompArg
(int index, long value, long valueTwo, String op)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1270
MethodSecurityProvider
()
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:133
MethodSentWithTime
(String streamName, Values keyValue, long time, HistogramMetric histogram)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadSpout.java:58
MethodSepValReporter
(String separator, String path, Map<String, String> query, Map<String, MetricExtractor> extractorsMap)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:655
MethodSeq
(List<String> fields, List<Object> values, int count)
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureTuple.java:117
MethodSequenceFileBolt
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileBolt.java:46
MethodSequenceFileReader
(FileSystem fs, Path file, Map<String, Object> conf)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java:43
MethodSequenceFileWriter
(FileRotationPolicy policy, Path path, SequenceFile.Writer writer, SequenceFormat format)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/SequenceFileWriter.java:31
MethodServer
Starts Netty at the given port. @param topoConf The topology config @param port The port to start Netty at @param cb The callback to deliver incoming
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:78
MethodServerCallbackHandler
(Map<String, Object> topoConf, boolean impersonationAllowed)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/ServerCallbackHandler.java:39
MethodServerConfigUtilsInstaller
(ServerConfigUtils instance)
storm-core/test/jvm/org/apache/storm/utils/staticmocking/ServerConfigUtilsInstaller.java:28
MethodSettableBlobMeta
()
storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java:121
MethodSharedMemory
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:136
MethodSharedOffHeapWithinNode
Create a new request for a shared memory region off heap between workers on a node. @param amount the number of MB to share @param name the name of
storm-client/src/jvm/org/apache/storm/topology/SharedOffHeapWithinNode.java:30
MethodSharedOffHeapWithinWorker
Create a new request for a shared memory region off heap within a worker. @param amount the number of MB to share @param name the name of the share
storm-client/src/jvm/org/apache/storm/topology/SharedOffHeapWithinWorker.java:28
MethodSharedOnHeap
Create a new request for a shared memory region on heap. @param amount the number of MB to share on heap @param name the name of the shared region
storm-client/src/jvm/org/apache/storm/topology/SharedOnHeap.java:30
MethodShellBasedGroupsMapping
()
storm-client/src/jvm/org/apache/storm/security/auth/ShellBasedGroupsMapping.java:42
MethodShellBolt
(ShellComponent component)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:99
MethodShellBoltMessageQueue
(int boltMsgCapacity)
storm-client/src/jvm/org/apache/storm/utils/ShellBoltMessageQueue.java:35
MethodShellCommandExecutor
(String[] execString)
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:383
MethodShellComponent
()
storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java:117
MethodShellProcess
(String[] command)
storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java:43
MethodShellSpout
(ShellComponent component)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:63
MethodShellTimeoutTimerTask
(ShellUtils shell)
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:478
MethodShellUtils
()
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:69
MethodSimpleACLNimbusUserAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:198
MethodSimpleACLTopologyReadOnlyGroupAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:331
MethodSimpleACLTopologyReadOnlyUserAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:224
MethodSimpleACLUserAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:36
MethodSimpleGauge
(T value)
storm-client/src/jvm/org/apache/storm/metrics2/SimpleGauge.java:20
MethodSimpleJdbcLookupMapper
(Fields outputFields, List<Column> queryColumns)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/SimpleJdbcLookupMapper.java:28
MethodSimpleJdbcMapper
(String tableName, ConnectionProvider connectionProvider)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/SimpleJdbcMapper.java:31
MethodSimpleRecordTranslator
(Func<ConsumerRecord<K, V>, List<Object>> func, Fields fields)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/SimpleRecordTranslator.java:32
MethodSimpleSaslClientCallbackHandler
Constructor. @param username the username to use. @param password the password to use.
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SimpleSaslClientCallbackHandler.java:36
MethodSimpleSaslServerCallbackHandler
Constructor with different password providers. @param impersonationAllowed true if impersonation is allowed else false. @param providers w
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SimpleSaslServerCallbackHandler.java:45
MethodSimpleTopology
()
flux/flux-core/src/test/java/org/apache/storm/flux/test/SimpleTopology.java:34
MethodSimpleTopologySource
()
flux/flux-core/src/test/java/org/apache/storm/flux/test/SimpleTopologySource.java:31
MethodSimpleTopologyWithConfigParam
()
flux/flux-core/src/test/java/org/apache/storm/flux/test/SimpleTopologyWithConfigParam.java:33
MethodSimpleTypeValidator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:287
MethodSimpleVersion
(String version)
storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java:26
MethodSimpleWindowPartitionCache
(long maximumSize, RemovalListener<K, V> removalListener, CacheLoader<K, V> cacheLoader)
storm-client/src/jvm/org/apache/storm/windowing/persistence/SimpleWindowPartitionCache.java:40
MethodSimpleWrapProcessor
(TProcessor wrapped)
storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java:125
MethodSimulatedTime
()
storm-client/src/jvm/org/apache/storm/utils/Time.java:203
MethodSimulatedUser
(User other, ISchedulingState cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/DefaultSchedulingPriorityStrategy.java:69
MethodSimulatedUserComparator
(double cpuAvail, double memAvail)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/DefaultSchedulingPriorityStrategy.java:128
MethodSingleEmitAggregator
(Aggregator agg, BatchToPartition batchToPartition)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/SingleEmitAggregator.java:30
MethodSingleEmitState
(Object batchId)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/SingleEmitAggregator.java:83
MethodSingleJoinBolt
(Fields outFields)
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SingleJoinBolt.java:43
MethodSingleThreadedConsumer
(KryoTupleDeserializer deserializer, int numMessages)
storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java:170
MethodSingleTopologyCluster
Create a new cluster that only allows modifications to a single topology. @param other the current cluster to base this off of @param topologyId
storm-server/src/main/java/org/apache/storm/scheduler/SingleTopologyCluster.java:33
MethodSingleUserPrincipal
(String userName)
storm-client/src/jvm/org/apache/storm/security/auth/SingleUserPrincipal.java:24
MethodSinkNode
(IComponent bolt)
storm-client/src/jvm/org/apache/storm/streams/SinkNode.java:26
MethodSkewedRollingTopWords
()
examples/storm-starter/src/jvm/org/apache/storm/starter/SkewedRollingTopWords.java:39
MethodSlidingCountWindow
(int windowLength, int slideLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/SlidingCountWindow.java:24
MethodSlidingCountWindowStrategy
(WindowConfig slidingCountWindow)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/SlidingCountWindowStrategy.java:28
MethodSlidingDurationWindow
(int windowLength, int slideLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/SlidingDurationWindow.java:25
MethodSlidingDurationWindowStrategy
(WindowConfig slidingDurationWindow)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/SlidingDurationWindowStrategy.java:28
MethodSlidingTimeCorrectness
(int windowSec, int slideSec)
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingTimeCorrectness.java:47
MethodSlidingWindowCorrectness
(int windowSize, int slideSize)
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingWindowCorrectness.java:47
MethodSlidingWindowCounter
(int windowLengthInSlots)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlidingWindowCounter.java:73
MethodSlidingWindows
(L windowLength, I slidingInterval)
storm-client/src/jvm/org/apache/storm/streams/windowing/SlidingWindows.java:29
MethodSlot
(AsyncLocalizer localizer, Map<String, Object> conf, ContainerLauncher containerLauncher, Stri
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:79
MethodSlotBasedCounter
(int numSlots)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlotBasedCounter.java:34
MethodSlotMetrics
(StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SlotMetrics.java:36
MethodSlowExecutorPattern
(double maxSlownessMs, int count)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/SlowExecutorPattern.java:74
MethodSmartThread
(Runnable r)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1842
MethodSnapshottableMap
(MapState<T> delegate, List<Object> snapshotKey)
storm-client/src/jvm/org/apache/storm/trident/state/map/SnapshottableMap.java:25
MethodSourceArgs
(boolean singleCount)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:250
MethodSpecificAggregateStats
()
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:109
MethodSplitSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java:63
MethodSplitSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java:249
MethodSplitSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopologyNode.java:56
MethodSplitSentence
(SlowExecutorPattern slowness)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ThroughputVsLatency.java:94
FunctionSplitSentenceBolt
()
examples/storm-starter/multilang/resources/asyncSplitsentence.js:28
FunctionSplitSentenceBolt
()
examples/storm-starter/multilang/resources/splitsentence.js:26
FunctionSpout
* Base class for storm spout. * To create a spout implement the following methods: nextTuple, ack and fail (nextTuple - mandatory, ack and fail * ca
storm-multilang/javascript/src/main/resources/resources/storm.js:348
MethodSpoutAckInfo
(Object messageId, int spoutTaskId, Long completeLatencyMs)
storm-client/src/jvm/org/apache/storm/hooks/info/SpoutAckInfo.java:25
MethodSpoutAggregateStats
()
storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java:113
MethodSpoutComponent
(Object spout, String streamName, Integer parallelism, String batchGroupId)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:308
MethodSpoutDeclarerImpl
(SpoutComponent component)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:359
MethodSpoutDetails
(IRichSpout spout, Integer parallelism, Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/Thrift.java:298
MethodSpoutExecutor
(final WorkerState workerData, final List<Long> executorId, Map<String, String> credentials)
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:71
MethodSpoutExecutorStats
(int rate, int numStatBuckets)
storm-client/src/jvm/org/apache/storm/stats/SpoutExecutorStats.java:24
← previousnext →12,401–12,500 of 27,770, ranked by callers