Functions — github.com/apache/storm

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363

flux/flux-core/src/test/java/org/apache/storm/flux/test/TestBolt.java:47

Lists files in directory. Note that to avoid memory problem, we only return the first 1024 files in a directory. @param dir directory to get file lis

storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/DirectoryCleaner.java:199

↓ 7 callersMethodgetGroupMappingServiceProviderPlugin

Construct a group mapping service provider plugin. @param conf daemon configuration @return the plugin

storm-client/src/jvm/org/apache/storm/security/auth/ClientAuthUtils.java:205

↓ 7 callersMethodgetHost

()

storm-client/src/jvm/org/apache/storm/nimbus/NimbusInfo.java:107

↓ 7 callersMethodgetId

()

storm-client/src/jvm/org/apache/storm/scheduler/WorkerSlot.java:41

↓ 7 callersMethodgetIncompatibleComponentSets

Return an object that maps component names to a set of other components which are incompatible and their executor instances cannot co-exist on the s

storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ConstraintSolverConfig.java:179

↓ 7 callersMethodgetKeyDir

(String key)

external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreImpl.java:255

↓ 7 callersMethodgetKryo

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java:54

↓ 7 callersMethodgetMeasured

()

storm-server/src/main/java/org/apache/storm/metric/timed/Timed.java:28

↓ 7 callersMethodgetMetadataTypes

()

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadata.java:46

↓ 7 callersMethodgetMetricsDurationUnit

(Map<String, Object> reporterConf)

storm-client/src/jvm/org/apache/storm/daemon/metrics/ClientMetricsUtils.java:32

↓ 7 callersMethodgetMetricsRateUnit

(Map<String, Object> reporterConf)

storm-client/src/jvm/org/apache/storm/daemon/metrics/ClientMetricsUtils.java:28

↓ 7 callersMethodgetMinor

()

storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java:47

↓ 7 callersMethodgetNodeById

get node object from nodeId.

storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNodes.java:123

↓ 7 callersMethodgetNodeIdToTotalSharedOffHeapNodeMemory

Get the total shared off heap node memory mapping. @return host to total shared off heap node memory mapping.

storm-server/src/main/java/org/apache/storm/scheduler/SchedulerAssignment.java:90

↓ 7 callersMethodgetParallelism

()

storm-client/src/jvm/org/apache/storm/streams/Node.java:98

↓ 7 callersMethodgetPort

Get port. @return The port this transport is using. This is not known until {@link #getServer(org.apache.storm.thrift.TProcessor)} has been called

storm-client/src/jvm/org/apache/storm/security/auth/ITransportPlugin.java:58

↓ 7 callersMethodgetRateCounter

(String metricName, String streamId)

storm-client/src/jvm/org/apache/storm/metrics2/TaskMetrics.java:122

↓ 7 callersMethodgetResources

Get resource. @return a name of resource name -> amount of that resource. Return should never be null!

storm-client/src/jvm/org/apache/storm/trident/operation/ITridentResource.java:28

↓ 7 callersMethodgetRunningTopologies

Get a collection of the topology ids currently running on this node.

storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:183

↓ 7 callersMethodgetRunningTopologies

Get running topologies. @return a collection of the topology ids currently running on this node

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/Node.java:147

↓ 7 callersMethodgetSSLFilesFromConf

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/security/auth/AutoSSL.java:101

↓ 7 callersMethodgetSaslToken

Read accessor for SASL token. @return saslToken SASL token

storm-client/src/jvm/org/apache/storm/messaging/netty/SaslMessageToken.java:68

↓ 7 callersMethodgetSchema

(String fingerPrint)

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/AvroSchemaRegistry.java:21

↓ 7 callersMethodgetStormClusterState

()

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:251

↓ 7 callersMethodgetStubbedSearchHandler

()

storm-webapp/src/test/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandlerTest.java:847

↓ 7 callersMethodgetSubject

()

storm-client/src/jvm/org/apache/storm/messaging/netty/Login.java:287

↓ 7 callersMethodgetTaskObject

()

storm-client/src/jvm/org/apache/storm/daemon/Task.java:201

↓ 7 callersMethodgetTopologiesOwnedBy

Get all topologies submitted/owned by a given user. @param user the name of the user @return all of the topologies submitted by this user.

storm-server/src/main/java/org/apache/storm/scheduler/Topologies.java:119

↓ 7 callersMethodgetTopologyInfoByNameWithOpts

(java.lang.String name, GetInfoOptions options)

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:124

↓ 7 callersMethodgetTopologyPageInfo

(java.lang.String id, java.lang.String window, boolean is_include_sys)

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:128

↓ 7 callersMethodgetTopologySubmitter

Get the user that submitted this topology.

storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:580

↓ 7 callersMethodgetTotalMemoryMb

()

storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourceOffer.java:64

↓ 7 callersMethodgetTotalRequestedCpu

Note: The public API relevant to resource aware scheduling is unstable as of May 2015. We reserve the right to change them. @return the total cpu req

storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:491

↓ 7 callersMethodgetTotalRequestedMemOffHeap

Note: The public API relevant to resource aware scheduling is unstable as of May 2015. We reserve the right to change them. @return the total off-hea

storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:461

↓ 7 callersMethodgetTotalRequestedMemOnHeap

Note: The public API relevant to resource aware scheduling is unstable as of May 2015. We reserve the right to change them. @return the total on-heap

storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:431

↓ 7 callersMethodgetWindowHint

getWindowHint. @param window window @return getWindowHint

storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1137

↓ 7 callersMethodgetWorkerTopologyContext

()

storm-client/src/jvm/org/apache/storm/executor/Executor.java:678

↓ 7 callersMethodgetWorkerTopologyContext

()

storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:618

↓ 7 callersMethodget_acked

()

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:292

↓ 7 callersMethodget_complete_ms_avg

()

storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java:294

↓ 7 callersMethodget_component_debug

()

storm-client/src/jvm/org/apache/storm/generated/StormBase.java:508

↓ 7 callersMethodget_emitted

()

storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java:224

↓ 7 callersMethodget_emitted

()

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:248

↓ 7 callersMethodget_error_time_secs

()

storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java:202

↓ 7 callersMethodget_failed

()

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:314

↓ 7 callersFunctionget_log4j2_conf_dir

(storm_config_opts, args)

bin/storm.py:1224

↓ 7 callersMethodget_name

()

storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:390

↓ 7 callersMethodget_pulseIds

()

storm-client/src/jvm/org/apache/storm/generated/HBNodes.java:157

↓ 7 callersMethodget_replication_factor

()

storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java:198

↓ 7 callersMethodget_task_start

()

storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java:156

↓ 7 callersMethodget_topo_ids

()

storm-client/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java:157

↓ 7 callersMethodget_topologies

()

storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java:236

↓ 7 callersMethodget_topology_version

()

storm-client/src/jvm/org/apache/storm/generated/StormBase.java:556

↓ 7 callersMethodget_transferred

()

storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java:259

↓ 7 callersMethodget_transferred

()

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:270

↓ 7 callersMethodget_version

Gets the 'version' of the node at a path. Optionally sets a watch on that node. The version should increase whenever a write happens. @param path Th

storm-client/src/jvm/org/apache/storm/cluster/IStateStorage.java:95

↓ 7 callersMethodhashCode

()

storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:874

↓ 7 callersMethodhscan

(byte[] key, byte[] cursor, ScanParams params)

external/storm-redis/src/main/java/org/apache/storm/redis/common/commands/RedisCommands.java:59

↓ 7 callersMethodhset

(String key, String field, String value)

external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java:35

↓ 7 callersMethodidle

Implementations of this method should be thread-safe (preferably no side-effects and lock-free). <p>Supports static or dynamic backoff. Dynamic backo

storm-client/src/jvm/org/apache/storm/policy/IWaitStrategy.java:54

↓ 7 callersMethodinitHdfs

(String dirName)

external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/BlobStoreTest.java:147

↓ 7 callersMethodisAnyProcessAlive

Are any of the processes alive and running for the specified user. If collection is empty or null then the return value is trivially false. @param pi

storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:892

↓ 7 callersMethodisImpersonating

Check whether context is impersonating. @return true if this request is an impersonation request.

storm-client/src/jvm/org/apache/storm/security/auth/ReqContext.java:152

↓ 7 callersMethodisTotallyFree

()

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/Node.java:151

↓ 7 callersMethodisZkAuthenticationConfiguredTopology

Is the topology configured to have ZooKeeper authentication. @param conf the topology configuration @return true if ZK is configured else false

storm-client/src/jvm/org/apache/storm/utils/Utils.java:632

↓ 7 callersMethodis_set_enable

Returns true if field enable is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:19407

↓ 7 callersMethodis_set_secretVersion

Returns true if field secretVersion is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:244

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:18936

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:21838

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:23832

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:24795

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:28133

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:30069

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:31032

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:36160

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:38647

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:39396

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:40141

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:40912

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:41816

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:42784

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:43627

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:45356

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:46324

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:47401

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:48478

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:49649

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:50820

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:52095

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:53063

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:54026

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:54994

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:55949

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:56832

↓ 7 callersMethodis_set_success

Returns true if field success is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:57723

↓ 7 callersMethodissueMapCallback

(ConcurrentHashMap<String, Runnable> callbackConcurrentHashMap, String key)

storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:175

↓ 7 callersMethoditerator

()

storm-client/src/jvm/org/apache/storm/windowing/persistence/WindowState.java:84

↓ 7 callersMethodjavaDeserialize

(byte[] serialized, Class<T> clazz)

storm-client/src/jvm/org/apache/storm/utils/Utils.java:539

↓ 7 callersMethodlaunchServer

()

storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:1417

← previous next →1,601–1,700 of 27,770, ranked by callers