MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodConfigValue
Utility classes should not have a public constructor.
storm-core/src/jvm/org/apache/storm/command/ConfigValue.java:29
MethodConnect
(InetSocketAddress address)
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:579
MethodCons
(MpscArrayQueue<Object> queue)
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/Cons.java:29
MethodConsList
()
storm-client/src/jvm/org/apache/storm/trident/tuple/ConsList.java:24
MethodConsoleSize
(int height, int width)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:342
MethodConstBolt
()
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/spout/HdfsSpoutTopology.java:152
MethodConstSpout
(String value)
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/ConstSpout.java:40
MethodConstraintSolverConfig
(TopologyDetails topo)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ConstraintSolverConfig.java:59
MethodConsumer
(JCQueue queue)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Consumer.java:29
MethodConsumerExecutor
(Consumer consumer)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ConsumerExecutor.java:24
MethodConsumerThd
(JCQueue queue, JCQueue.Consumer handler)
storm-client/test/jvm/org/apache/storm/utils/JCQueueTest.java:191
MethodContainer
Create a new Container. @param type the type of container being made. @param conf the supervisor config @param supervisorId the ID of the supervisor
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Container.java:110
MethodContainerLauncher
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/ContainerLauncher.java:36
MethodContainerMemoryTracker
(StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/ContainerMemoryTracker.java:28
MethodContainerRecoveryException
(String message)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/ContainerRecoveryException.java:20
MethodContainerType
(boolean recovery, boolean onlyKillable)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Container.java:651
MethodControlMessage
(short code)
storm-client/src/jvm/org/apache/storm/messaging/netty/ControlMessage.java:28
MethodCoordSpec
()
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:343
MethodCoordType
(boolean singleCount)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:302
MethodCoordinatedBolt
(IRichBolt delegate)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:54
MethodCoordinatedOutputCollector
(IOutputCollector delegate)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:388
MethodCoordinatedOutputCollector
(IOutputCollector delegate)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:307
MethodCoordinator
(Map<String, Object> conf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/trident/spout/OpaquePartitionedTridentSpoutExecutor.java:75
MethodCoordinator
(Map<String, Object> conf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/trident/spout/PartitionedTridentSpoutExecutor.java:76
MethodCount
(int value)
storm-client/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java:256
MethodCountEvictionPolicy
(int count)
storm-client/src/jvm/org/apache/storm/windowing/CountEvictionPolicy.java:27
MethodCountMetric
()
storm-client/src/jvm/org/apache/storm/metric/api/CountMetric.java:18
MethodCountStat
Constructor. @param numBuckets the number of buckets to divide the time periods into.
storm-client/src/jvm/org/apache/storm/metric/internal/CountStat.java:51
MethodCountSyncPolicy
(int count)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/sync/CountSyncPolicy.java:26
MethodCountSyncPolicy
(int count)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/sync/CountSyncPolicy.java:26
MethodCountTriggerPolicy
(int count, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy)
storm-client/src/jvm/org/apache/storm/windowing/CountTriggerPolicy.java:29
MethodCpu
(long shares, long quota, long period, long realtimeRuntime, long realtimePerio
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:889
MethodCpuCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpuCore.java:31
MethodCpuacctCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpuacctCore.java:30
MethodCpusetCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpusetCore.java:37
MethodCredentials
()
storm-client/src/jvm/org/apache/storm/generated/Credentials.java:120
MethodCustomIsExactlyOneOfValidators
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:856
MethodCycleDetectionScenario
()
storm-client/test/jvm/org/apache/storm/utils/UtilsTest.java:252
MethodDRPC
(StormMetricsRegistry metricsRegistry, Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/daemon/drpc/DRPC.java:79
MethodDRPCApplication
Constructor. Creates new instance of DRPCResource, DRPCExceptionMapper and AuthorizationExceptionMapper and adds them to a set which can be retrieved
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/DRPCApplication.java:43
MethodDRPCClient
(DistributedRPC.Iface override)
storm-client/src/jvm/org/apache/storm/utils/DRPCClient.java:40
MethodDRPCClientBuilder
(String server, int port, Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java:274
MethodDRPCExceptionType
(int value)
storm-client/src/jvm/org/apache/storm/generated/DRPCExceptionType.java:36
MethodDRPCExecutionException
()
storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java:122
MethodDRPCInvocationsClient
(Map<String, Object> conf, String host, int port)
storm-client/src/jvm/org/apache/storm/drpc/DRPCInvocationsClient.java:35
MethodDRPCMessageId
(String id, int index)
storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java:263
MethodDRPCRequest
()
storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java:117
MethodDRPCResource
(DRPC drpc, StormMetricsRegistry metricsRegistry)
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/DRPCResource.java:41
MethodDRPCServer
Constructor. @param conf Drpc conf for the servers @param metricsRegistry The metrics registry
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/DRPCServer.java:142
MethodDRPCSpout
(String function)
storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java:63
MethodDRPCThrift
(DRPC drpc)
storm-server/src/main/java/org/apache/storm/daemon/drpc/DRPCThrift.java:31
MethodDataPoint
()
storm-client/src/jvm/org/apache/storm/metric/api/IMetricsConsumer.java:65
MethodDataPoint
()
storm-server/src/main/java/org/apache/storm/metric/api/DataPoint.java:19
MethodDataPointExpander
(boolean expandMapType, String metricNameSeparator)
storm-client/src/jvm/org/apache/storm/metric/util/DataPointExpander.java:31
MethodDebug
()
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/Debug.java:30
MethodDebugMemoryMapState
(String id)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/DebugMemoryMapState.java:39
MethodDebugOptions
()
storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java:121
MethodDecoratedLogLine
(String logLine)
integration-test/src/test/java/org/apache/storm/st/wrapper/DecoratedLogLine.java:39
MethodDefaultEvictionContext
(Long referenceTime)
storm-client/src/jvm/org/apache/storm/windowing/DefaultEvictionContext.java:21
MethodDefaultResourceAwareStrategyOld
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/DefaultResourceAwareStrategyOld.java:23
MethodDefaultSequenceFormat
(String keyField, String valueField)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/DefaultSequenceFormat.java:37
MethodDefaultSequenceFormat
(String keyField, String valueField)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/DefaultSequenceFormat.java:37
MethodDefaultShellLogHandler
Default constructor; used when loading with Class.forName(...).newInstance().
storm-client/src/jvm/org/apache/storm/utils/DefaultShellLogHandler.java:34
MethodDefaultStateEncoder
(Serializer<K> keySerializer, Serializer<V> valueSerializer)
storm-client/src/jvm/org/apache/storm/state/DefaultStateEncoder.java:30
MethodDefaultStateSerializer
Constructs a {@link DefaultStateSerializer} instance with the given list of classes registered in kryo. @param classesToRegister the classes to regis
storm-client/src/jvm/org/apache/storm/state/DefaultStateSerializer.java:72
MethodDefaultTopicSelector
(final String topicName)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/selector/DefaultTopicSelector.java:27
MethodDefaultTopicSelector
(final String topicName)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/DefaultTopicSelector.java:27
MethodDeletionMeta
(long deletedSize, int deletedFiles)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/DeletionMeta.java:27
MethodDependencyResolver
Constuctor. @param localRepoPath the directory of local repository
storm-submit-tools/src/main/java/org/apache/storm/submit/dependency/DependencyResolver.java:55
MethodDependencyUploader
()
storm-client/src/jvm/org/apache/storm/dependency/DependencyUploader.java:53
MethodDerivedTypeValidator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:315
MethodDeserializingConnectionCallback
(final Map<String, Object> conf, final GeneralTopologyContext context,
storm-client/src/jvm/org/apache/storm/messaging/DeserializingConnectionCallback.java:52
MethodDevice
(int major, int minor)
storm-client/src/jvm/org/apache/storm/container/cgroup/Device.java:23
MethodDevice
(String type, String path, long major, long minor, int fileMode, int uid, int gi
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:676
MethodDevice
(boolean allow, String type, long major, long minor, String access)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:791
MethodDevicesCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/DevicesCore.java:40
MethodDimensionalReporter
Constructor. @param metricRegistryProvider MetricRegistryProvider tracking task-specific metrics. @param unstartedReporter ScheduledReporter to
storm-client/src/jvm/org/apache/storm/metrics2/DimensionalReporter.java:54
MethodDirLock
(FileSystem fs, Path lockFile)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/DirLock.java:34
MethodDirLockingThread
(int thdNum, FileSystem fs, Path dir)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestDirLock.java:139
MethodDirectInserter
(JCQueue queue)
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:271
MethodDirectoryCleaner
(StormMetricsRegistry metricsRegistry)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/DirectoryCleaner.java:60
MethodDisallowedStrategyException
(String attemptedClass, List<String> allowedStrategies)
storm-client/src/jvm/org/apache/storm/utils/DisallowedStrategyException.java:28
MethodDissoc
(K key)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:5248
MethodDistributeTask
(AssignmentDistributionService service, Integer index)
storm-server/src/main/java/org/apache/storm/nimbus/AssignmentDistributionService.java:268
MethodDockerCommand
(String command)
storm-server/src/main/java/org/apache/storm/container/docker/DockerCommand.java:24
MethodDockerExecCommand
(String containerName)
storm-server/src/main/java/org/apache/storm/container/docker/DockerExecCommand.java:27
MethodDockerInspectCommand
(String containerName)
storm-server/src/main/java/org/apache/storm/container/docker/DockerInspectCommand.java:26
MethodDockerPsCommand
()
storm-server/src/main/java/org/apache/storm/container/docker/DockerPsCommand.java:28
MethodDockerRmCommand
(String containerName)
storm-server/src/main/java/org/apache/storm/container/docker/DockerRmCommand.java:26
MethodDockerRunCommand
The Construction function. @param containerName the container name @param userInfo the info of the user, e.g. "uid:gid" @param image the container ima
storm-server/src/main/java/org/apache/storm/container/docker/DockerRunCommand.java:39
MethodDockerStopCommand
(String containerName)
storm-server/src/main/java/org/apache/storm/container/docker/DockerStopCommand.java:26
MethodDockerWaitCommand
(String containerName)
storm-server/src/main/java/org/apache/storm/container/docker/DockerWaitCommand.java:26
MethodDownloadBlobs
(PortAndAssignment pna, BlobChangingCallback cb)
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:703
MethodDownloadMeta
(Path downloadPath, long version)
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java:414
MethodDriver
(String name, int id)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfDevicesTopology.java:139
MethodDriver
(String name, int id)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfVehiclesTopology.java:117
MethodDuration
(int value, TimeUnit timeUnit)
storm-client/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java:304
MethodDynamicState
(final LocalAssignment currentAssignment, Container container, final LocalAssignment newAssignment,
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:1246
MethodEachProcessor
(Fields inputFields, Function function)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/EachProcessor.java:35
MethodEdge
(Node source, Node target)
storm-client/src/jvm/org/apache/storm/streams/Edge.java:24
← previousnext →11,701–11,800 of 27,770, ranked by callers