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

↓ 11 callersMethodgetRaw

get the raw key bytes

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:158

↓ 11 callersMethodgetSearchHandlerWithPort

(int port)

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

↓ 11 callersMethodgetSum

()

storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:137

↓ 11 callersMethodgetTimeout

Returns timeout. @return socket / connection timeout

external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisPoolConfig.java:72

↓ 11 callersMethodgetTopologyInfo

(java.lang.String id)

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

↓ 11 callersMethodgetUniqueStreamId

()

storm-client/src/jvm/org/apache/storm/trident/fluent/UniqueIdGen.java:20

↓ 11 callersMethodget_assigned_memonheap

()

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

↓ 11 callersMethodget_specific_stats

()

storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java:226

↓ 11 callersMethodget_supervisor_id

()

storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:303

↓ 11 callersMethodinc

(long n)

storm-client/src/jvm/org/apache/storm/metrics2/RateCounter.java:61

↓ 11 callersMethodincBy

Increase the count by the given value. @param count number to count

storm-client/src/jvm/org/apache/storm/metric/internal/CountStat.java:95

↓ 11 callersMethodinit

Initializes the processor. This is typically invoked from the underlying storm bolt's prepare method. @param context the processor context

storm-client/src/jvm/org/apache/storm/streams/processors/Processor.java:30

↓ 11 callersMethodis_set_action

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

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

↓ 11 callersMethodis_set_assignments

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

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

↓ 11 callersMethodis_set_aze

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

storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:987

↓ 11 callersMethodis_set_blobKey

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

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

↓ 11 callersMethodis_set_component

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

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

↓ 11 callersMethodis_set_config

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

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

↓ 11 callersMethodis_set_creds

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

storm-client/src/jvm/org/apache/storm/generated/Credentials.java:179

↓ 11 callersMethodis_set_creds

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

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

↓ 11 callersMethodis_set_data

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

storm-client/src/jvm/org/apache/storm/generated/HBMessage.java:218

↓ 11 callersMethodis_set_details

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

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

↓ 11 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/Supervisor.java:1984

↓ 11 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/DistributedRPC.java:963

↓ 11 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/DistributedRPCInvocations.java:3471

↓ 11 callersMethodis_set_execution_command

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

storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java:166

↓ 11 callersMethodis_set_funcArgs

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

storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:470

↓ 11 callersMethodis_set_functionName

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

storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:446

↓ 11 callersMethodis_set_functionName

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

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

↓ 11 callersMethodis_set_heartbeat

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

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

↓ 11 callersMethodis_set_heartbeats

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

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

↓ 11 callersMethodis_set_heatbeat

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

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

↓ 11 callersMethodis_set_host

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

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

↓ 11 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/Supervisor.java:1558

↓ 11 callersMethodis_set_ise

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

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

↓ 11 callersMethodis_set_kae

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

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

↓ 11 callersMethodis_set_metrics

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

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

↓ 11 callersMethodis_set_metrics

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

storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java:174

↓ 11 callersMethodis_set_nimbuses

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

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

↓ 11 callersMethodis_set_node

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

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

↓ 11 callersMethodis_set_owner

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

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

↓ 11 callersMethodis_set_profileRequest

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

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

↓ 11 callersMethodis_set_pulseIds

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

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

↓ 11 callersMethodis_set_pulses

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

storm-client/src/jvm/org/apache/storm/generated/HBRecords.java:174

↓ 11 callersMethodis_set_result

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

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

↓ 11 callersMethodis_set_script

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

storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java:190

↓ 11 callersMethodis_set_topo_ids

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

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

↓ 11 callersMethodis_set_topology_id

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

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

↓ 11 callersMethodis_set_user

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

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

↓ 11 callersMethodis_set_version

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

storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java:312

↓ 11 callersMethodkill

Kill the processes in this container nicely. kill -15 equivalent @throws IOException on any error

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Killable.java:24

↓ 11 callersMethodkillTopology

(String name)

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

↓ 11 callersMethodmkEdMap

(Object[]... args)

storm-server/src/test/java/org/apache/storm/scheduler/multitenant/MultitenantSchedulerTest.java:75

↓ 11 callersMethodmkHaltingTimer

(String name)

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

↓ 11 callersMethodnewDRPCStream

(String function)

storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:561

↓ 11 callersMethodnewSpout

(final String os)

storm-client/test/jvm/org/apache/storm/streams/StreamBuilderTest.java:55

↓ 11 callersMethodnodesAvailable

()

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/IsolatedPool.java:306

↓ 11 callersMethodnow

()

examples/storm-starter/src/jvm/org/apache/storm/starter/tools/NthLastModifiedTimeTracker.java:49

↓ 11 callersMethodpartitionPersist

(StateFactory stateFactory, Fields inputFields, StateUpdater updater, Fields functionFields)

storm-client/src/jvm/org/apache/storm/trident/Stream.java:356

↓ 11 callersMethodpersistentAggregate

(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)

storm-client/src/jvm/org/apache/storm/trident/Stream.java:766

↓ 11 callersMethodprettifyGenericResources

(Map<String, Double> resourceMap)

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

↓ 11 callersMethodputEncodedKeyValueToMap

(NavigableMap<byte[], byte[]> map, byte[] key, byte[] value)

external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateIteratorTest.java:199

↓ 11 callersMethodread

(org.apache.storm.thrift.protocol.TProtocol iprot)

storm-client/src/jvm/org/apache/storm/generated/NullStruct.java:186

↓ 11 callersMethodreadHeartbeat

Read the Heartbeat for the current container. @return the Heartbeat @throws IOException on any error

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Container.java:237

↓ 11 callersMethodrebalance

(String topoName, RebalanceOptions options)

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

↓ 11 callersMethodrunOnClusterAndPrintMetrics

(int durationSec, String topoName, Map<String, Object> topoConf, StormTopology topology)

examples/storm-perf/src/main/java/org/apache/storm/perf/utils/Helper.java:90

↓ 11 callersMethodrun_client_method_and_print_tag

Run a client method for the supplied cluster name, or current cluster name or all clusters. If cluster_name is supplied (in the args)

aws-bin/aws_kafka.py:108

↓ 11 callersMethodsetCommitFrequencyCount

(int commitFrequencyCount)

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:171

↓ 11 callersMethodsetCycle

(boolean cycle)

examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/trident/FixedBatchSpout.java:46

↓ 11 callersMethodsetMaxSpoutPending

(Map<String, Object> conf, int max)

storm-client/src/jvm/org/apache/storm/Config.java:2224

↓ 11 callersMethodset_executor_node_port

(@org.apache.storm.thrift.annotation.Nullable java.util.Map<java.util.List<java.lang.Long>,NodeInfo> executor_

storm-client/src/jvm/org/apache/storm/generated/Assignment.java:346

↓ 11 callersMethodsingleUpdate

(MapState<Object> map, Object key, Long amt)

storm-core/test/jvm/org/apache/storm/trident/StateTest.java:65

↓ 11 callersMethodtask

()

storm-client/src/jvm/org/apache/storm/messaging/TaskMessage.java:26

↓ 11 callersMethodtoString

()

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

↓ 11 callersMethodtotalSlots

()

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

↓ 11 callersMethodupdateBlob

(String key, Subject who)

storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStore.java:240

↓ 11 callersMethodwithPath

(String path)

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SimpleFileNameFormat.java:63

↓ 11 callersMethodwithRotationPolicy

(FileRotationPolicy rotationPolicy)

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/HdfsBolt.java:66

↓ 11 callersMethodwrite

(org.apache.storm.thrift.protocol.TProtocol oprot)

storm-client/src/jvm/org/apache/storm/generated/NullStruct.java:191

↓ 10 callersMethodaccept

Performs an operation on the given argument. @param input the input

storm-client/src/jvm/org/apache/storm/streams/operations/Consumer.java:26

↓ 10 callersMethodactiveStorms

()

storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:100

↓ 10 callersMethodaddToAckMsgs

(KafkaSpoutMessageId msgId)

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java:60

↓ 10 callersMethodassertFull

()

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Container.java:660

↓ 10 callersMethodbeginCommit

(Long txid)

storm-client/src/jvm/org/apache/storm/trident/state/State.java:29

↓ 10 callersMethodcall

(T arg)

storm-server/src/main/java/org/apache/storm/daemon/supervisor/UniFunc.java:16

↓ 10 callersMethodceil

(ZonedDateTime dateTime, int sec)

integration-test/src/main/java/org/apache/storm/st/utils/TimeUtil.java:52

↓ 10 callersMethodcleanup

When running in local mode, called when the local cluster is being shut down.

storm-client/src/jvm/org/apache/storm/trident/operation/Operation.java:40

↓ 10 callersMethodclose

close this connection.

storm-client/src/jvm/org/apache/storm/messaging/IConnection.java:60

↓ 10 callersMethodcreateSchedulingResult

(boolean success, String schedulerClassSimpleName)

storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:456

↓ 10 callersMethodcustomWorkerResourcesEquality

This method compares WorkerResources while considering any resources are NULL to be 0.0 @param first WorkerResources A @param second WorkerResources

storm-server/src/main/java/org/apache/storm/utils/EquivalenceUtils.java:71

↓ 10 callersMethodearliestRetriableOffsets

()

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

↓ 10 callersMethodequals

(Object o)

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTopicPartition.java:48

↓ 10 callersMethodfieldIndex

(String field)

storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:99

↓ 10 callersMethodfilterSysStreams

filter system streams from stats. @param stats { win -> stream id -> value } @param includeSys whether to filter system streams @return filtered

storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:1716

↓ 10 callersMethodforceKill

Kill the processes in this container violently. kill -9 equivalent @throws IOException on any error

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Killable.java:31

↓ 10 callersMethodget

(Map<S, T> m, S key, T def)

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

↓ 10 callersMethodgetAssignedNumWorkers

(TopologyDetails topology)

storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:502

↓ 10 callersMethodgetAvailableSlots

()

storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:441

↓ 10 callersMethodgetCommittedOffset

()

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java:223

↓ 10 callersMethodgetConfig

()

flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:130

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