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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_e

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

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

↓ 6 callersMethodis_set_id

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

storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:2681

↓ 6 callersMethodis_set_id

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

storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:3447

↓ 6 callersMethodis_set_ite

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

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

↓ 6 callersMethodis_set_ite

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

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

↓ 6 callersMethodis_set_ite

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

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

↓ 6 callersMethodis_set_jsonConf

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_key

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

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

↓ 6 callersMethodis_set_knf

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

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

↓ 6 callersMethodis_set_knf

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

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

↓ 6 callersMethodis_set_knf

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

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

↓ 6 callersMethodis_set_knf

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

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

↓ 6 callersMethodis_set_knf

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

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

↓ 6 callersMethodis_set_knf

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

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

↓ 6 callersMethodis_set_location

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

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

↓ 6 callersMethodis_set_meta

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_name

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

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

↓ 6 callersMethodis_set_options

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

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

↓ 6 callersMethodis_set_options

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

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

↓ 6 callersMethodis_set_options

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

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

↓ 6 callersMethodis_set_options

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

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

↓ 6 callersMethodis_set_replication

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

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

↓ 6 callersMethodis_set_samplingPercentage

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

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

↓ 6 callersMethodis_set_session

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

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

↓ 6 callersMethodis_set_session

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

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

↓ 6 callersMethodis_set_session

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

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

↓ 6 callersMethodis_set_session

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

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

↓ 6 callersMethodis_set_topology

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

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

↓ 6 callersMethodis_set_uploadedJarLocation

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

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

↓ 6 callersMethodis_set_window

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

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

↓ 6 callersMethoditerator

()

storm-client/src/jvm/org/apache/storm/utils/ListDelegate.java:51

↓ 6 callersMethoditerator

()

storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorterHostProximity.java:601

↓ 6 callersMethodkillTopology

(java.lang.String name)

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

↓ 6 callersMethodlast

get the last element in list. @param list list to get @return the last element. null if list is null or empty.

storm-webapp/src/main/java/org/apache/storm/daemon/utils/ListFunctionalSupport.java:49

↓ 6 callersMethodleftJoin

Performs left Join with the newStream. SQL : from stream1 left join stream2 on stream2.field = stream1.field1 same as: new WindowedQueryBolt(

storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:103

↓ 6 callersMethodlistLogFiles

Enumerate worker log files for given criteria. @param user username @param port worker's port, null for all workers @param topologyId topology ID, nu

storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogPageHandler.java:126

↓ 6 callersFunctionlog

(msg, level=2)

storm-multilang/python/src/main/resources/resources/storm.py:157

↓ 6 callersMethodmap

Returns a stream consisting of the result of applying the given mapping function to the values of this stream. @param function a mapping function to

storm-client/src/jvm/org/apache/storm/streams/Stream.java:95

↓ 6 callersMethodmetadataIdToString

(KeyType type, int id, Map<Integer, String> lookupCache)

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbStore.java:547

↓ 6 callersMethodmilliSeconds

(long length)

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java:128

↓ 6 callersMethodmkAuthorizationHandler

(String klassName, Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:498

↓ 6 callersMethodmkExecutorInfoList

(int... executors)

storm-server/src/test/java/org/apache/storm/utils/EquivalenceUtilsTest.java:70

↓ 6 callersMethodmkLocalAssignment

(String id, List<ExecutorInfo> exec, WorkerResources resources)

storm-server/src/test/java/org/apache/storm/utils/EquivalenceUtilsTest.java:60

↓ 6 callersMethodmockContext

(List<Integer> availableTaskIds)

storm-client/test/jvm/org/apache/storm/grouping/LoadAwareShuffleGroupingTest.java:62

↓ 6 callersMethodmockLeaderElector

()

storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusClojurePortTest.java:993

↓ 6 callersMethodneedsExtraction

()

storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:358

↓ 6 callersMethodnewCurator

(Map<String, Object> conf, List<String> servers, Object port, String root,

storm-client/src/jvm/org/apache/storm/utils/CuratorUtils.java:41

↓ 6 callersMethodnextTuple_verifyEmitted_ack_resetCollector

Helper method to in sequence do: <li> <ul>spout.nexTuple()</ul> <ul>verify messageId</ul> <ul>spout.ack(msgId)</ul> <ul>reset(collecto

external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutAbstractTest.java:146

↓ 6 callersMethodnode_exists

Check if a node exists and optionally set a watch on the path. @param path The path to check for the existence of a node. @param watch Whether or no

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

↓ 6 callersMethodnoneGrouping

This grouping specifies that you don't care how the stream is grouped.

storm-client/src/jvm/org/apache/storm/topology/InputDeclarer.java:67

↓ 6 callersMethodnotifyTopologyActionListener

(String topoId, String action)

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

↓ 6 callersMethodoptionalArg

Add a named argument that is optional. @param name the name of the argument. @return a builder to be used to continue creating the command line.

storm-core/src/jvm/org/apache/storm/command/CLI.java:162

↓ 6 callersMethodparse

(String nimbusInfo)

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

↓ 6 callersMethodparseConfig

(String config)

storm-client/src/jvm/org/apache/storm/container/cgroup/core/BlkioCore.java:176

↓ 6 callersMethodparseJvmHeapMemByChildOpts

parses the arguments to extract jvm heap memory size in MB. @return the value of the JVM heap memory setting (in MB) in a java command.

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

↓ 6 callersMethodpopulateValue

Fill out the numeric values for a metric. @param metric Metric to populate @return true if the metric was populated, false otherwise @throws MetricE

storm-server/src/main/java/org/apache/storm/metricstore/MetricStore.java:43

↓ 6 callersFunctionpopulate_tag_dicts

(image_tag_to_hash, local_image_tag_to_hash)

bin/docker-to-squash.py:523

↓ 6 callersMethodpreRollback

This is a hook for the component to perform some actions just before the framework rolls back the prepared state.

storm-client/src/jvm/org/apache/storm/topology/IStatefulComponent.java:45

↓ 6 callersMethodprepare

Invoked once immediately after construction. @param conf Storm cluster configuration

storm-client/src/jvm/org/apache/storm/security/auth/IAuthorizer.java:34

↓ 6 callersMethodprepare

(Map<String, Object> conf, StormMetricsRegistry metricsRegistry)

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/MultitenantScheduler.java:37

← previous next →2,001–2,100 of 27,770, ranked by callers