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

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:212

↓ 3 callersMethodgetUserTopolgyComponents

Returns a representation of the non-system components of the topology graph. Each Component object in the returning map is populated with the list of

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

↓ 3 callersMethodgetValueAndReset

(long now)

storm-client/src/jvm/org/apache/storm/metric/internal/LatencyStat.java:127

↓ 3 callersMethodgetValueSerializer

(Map<String, Object> topoConf, TopologyContext context, StateConfig config)

external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueStateProvider.java:92

↓ 3 callersMethodgetVersionFileName

()

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

↓ 3 callersMethodgetVersionForKey

(String key, NimbusInfo nimbusInfo, CuratorFramework zkClient)

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

↓ 3 callersMethodgetWindowParams

(Set<ProcessorNode> initialProcessors)

storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:428

↓ 3 callersMethodgetWindowState

(int maxEvents)

storm-client/test/jvm/org/apache/storm/windowing/persistence/WindowStateTest.java:206

↓ 3 callersMethodgetWindowTriggerInprocessIdPrefix

(String windowTaskId)

storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java:75

↓ 3 callersMethodgetWorkerHooks

Returns worker hook definitions. @return worker hook definitions

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

↓ 3 callersMethodgetWorkerSlots

()

storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:414

↓ 3 callersMethodgetWorkerTokenInfo

Get and deserialize the WorkerTokenInfo in the worker token. @param wt the token. @return the deserialized info.

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

↓ 3 callersMethodgetWritableStringMetadataCache

Provides the WritableStringMetadataCache interface to the cache instance. @throws MetricException if the cache instance was not created

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadataCache.java:73

↓ 3 callersMethodgetWriter

Get a writer for the given location. @param file the file to write to @return the Writer to use. @throws IOException on any error

storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:281

↓ 3 callersMethodgetWtType

Get the corresponding worker token type for this thrift connection.

storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:177

↓ 3 callersMethodget_assigned_generic_resources

()

storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:829

↓ 3 callersMethodget_bolt_object

()

storm-client/src/jvm/org/apache/storm/generated/Bolt.java:152

↓ 3 callersMethodget_cluster_names

(self)

aws-bin/aws_kafka.py:60

↓ 3 callersMethodget_cpu_guarantee

()

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:485

↓ 3 callersMethodget_cpu_usage

()

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:441

↓ 3 callersMethodget_custom_serialized

()

storm-client/src/jvm/org/apache/storm/generated/Grouping.java:641

↓ 3 callersMethodget_debug_options

()

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:870

↓ 3 callersMethodget_debug_options

()

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:747

↓ 3 callersMethodget_eventlog_port

()

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:725

↓ 3 callersMethodget_execute_ms_avg

()

storm-client/src/jvm/org/apache/storm/generated/BoltStats.java:477

↓ 3 callersMethodget_executed

()

storm-client/src/jvm/org/apache/storm/generated/BoltStats.java:442

↓ 3 callersMethodget_execution_command

()

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

↓ 3 callersMethodget_executor_info

()

storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:207

↓ 3 callersMethodget_fragmented_cpu

()

storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:533

↓ 3 callersMethodget_fragmented_mem

()

storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:511

↓ 3 callersMethodget_hostname

()

storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:276

↓ 3 callersMethodget_id

()

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:544

↓ 3 callersMethodget_id

()

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

↓ 3 callersMethodget_initial_status

@see TopologyInitialStatus

storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java:159

↓ 3 callersMethodget_keys_size

()

storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java:154

↓ 3 callersFunctionget_manifest_from_docker_image

(pull_format, image)

bin/docker-to-squash.py:354

↓ 3 callersMethodget_memory_guarantee

()

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:463

↓ 3 callersMethodget_memory_usage

()

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:419

↓ 3 callersMethodget_num_executors

()

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:682

↓ 3 callersMethodget_num_tasks

()

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:638

↓ 3 callersMethodget_port

()

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

↓ 3 callersMethodget_process_ms_avg

()

storm-client/src/jvm/org/apache/storm/generated/BoltStats.java:407

↓ 3 callersMethodget_requested_generic_resources

()

storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:794

↓ 3 callersMethodget_sched_status

()

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

↓ 3 callersMethodget_scheduler_meta

()

storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:415

↓ 3 callersMethodget_script

()

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

↓ 3 callersMethodget_session

()

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

↓ 3 callersMethodget_shared_resources

()

storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java:363

↓ 3 callersMethodget_sid_to_output_stats

()

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:597

↓ 3 callersMethodget_signature

()

storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:233

↓ 3 callersMethodget_status

()

storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:509

↓ 3 callersMethodget_time_secs

()

storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java:255

↓ 3 callersMethodget_tlsPort

()

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

↓ 3 callersMethodget_topologies_size

()

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

↓ 3 callersMethodget_topologyId

()

storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java:181

↓ 3 callersMethodget_topology_conf

()

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:704

↓ 3 callersMethodget_topology_conf_overrides

()

storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java:323

↓ 3 callersMethodget_topology_name

()

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

↓ 3 callersMethodget_total_shared_off_heap

()

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

↓ 3 callersMethodget_used_generic_resources

()

storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:588

↓ 3 callersMethodget_version

()

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

↓ 3 callersMethodget_window_to_acked

()

storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java:308

↓ 3 callersMethodget_window_to_complete_latencies_ms

()

storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java:273

↓ 3 callersMethodget_window_to_stats

()

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:527

↓ 3 callersMethodget_workers

()

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:932

↓ 3 callersFunctiongit_time

(obj)

dev-tools/github/__init__.py:27

↓ 3 callersMethodglobal

## Repartitioning Operation. <p>All tuples are sent to the same partition. The same partition is chosen for all batches in the stream.

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

↓ 3 callersMethodglobalAmt

(String id, String key)

storm-server/src/main/java/org/apache/storm/testing/TrackedTopology.java:67

↓ 3 callersMethodgsid

Get the global stream id for this input stream. @return the GlobalStreamId for this input stream.

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java:233

↓ 3 callersFunctionhandleNodeClickEvent

(nodeId)

storm-webapp/src/main/webapp/js/visualization.js:205

↓ 3 callersMethodhasAnyPermissions

Validates if the user has any of the permissions mentioned in the mask. @param acl ACL for the key. @param mask mask holds the cumulative value of R

storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreAclHandler.java:269

↓ 3 callersMethodhasCommitted

Checks if this OffsetManager has committed to Kafka. @return true if this OffsetManager has made at least one commit to Kafka, false otherwise

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

↓ 3 callersMethodhasNext

()

storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java:363

↓ 3 callersMethodhasReferences

()

flux/flux-core/src/main/java/org/apache/storm/flux/model/ObjectDef.java:81

↓ 3 callersMethodhasShuffleGroupingFromParentToChild

(Component parent, Component child)

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

↓ 3 callersMethodhashCode

()

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

↓ 3 callersFunctionhdfs_cp

(src, dest, force=False, print_stdout=False, print_stderr=True, raise_on_error=True)

bin/docker-to-squash.py:211

↓ 3 callersMethodhget

(String key, String field)

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

↓ 3 callersMethodhistogram

(String name, TopologyContext context)

storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:175

↓ 3 callersMethodhostnameToNodes

hostname to Ids. @param hostname the hostname. @return the ids n that node.

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

↓ 3 callersMethodhtml_url

(self)

dev-tools/github/__init__.py:42

↓ 3 callersMethodincrement

()

storm-client/src/jvm/org/apache/storm/utils/MutableInt.java:30

↓ 3 callersMethodincrementMaxSequenceNumber

(CuratorFramework zkClient, int count)

storm-server/src/main/java/org/apache/storm/blobstore/KeySequenceNumber.java:215

↓ 3 callersMethodinformChangedBlobs

Informs the async localizer for all of blobs that the worker acknowledged the change of blobs. Worker has stop as of now. <p>PRECONDITION: container

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:349

↓ 3 callersMethodinit

Initializes the cache instance. Should be called only once in the JVM, subsequent calls will be ignored unless preceded by {@link #init(RocksDbMetrics

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadataCache.java:60

↓ 3 callersFunctioninitComponent

()

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

↓ 3 callersMethodinitLocalRecvQueues

()

storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java:51

↓ 3 callersMethodintegerDivided

(int sum, int numPieces)

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

↓ 3 callersMethodisAlive

()

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

↓ 3 callersMethodisBlackListed

(String supervisorId)

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

↓ 3 callersMethodisBlackListed

Check is a given supervisor is on a blacklisted host. @param supervisorId the id of the supervisor @return true if it is else false

storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:89

↓ 3 callersMethodisConnectionReady

(IConnection connection)

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

↓ 3 callersMethodisContain

(String source, String subItem)

storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:474

↓ 3 callersMethodisEquivalentTo

(PortAndAssignment other)

storm-server/src/main/java/org/apache/storm/localizer/PortAndAssignment.java:32

↓ 3 callersMethodisExecutorAssigned

(ExecutorDetails executor)

storm-server/src/main/java/org/apache/storm/scheduler/SchedulerAssignmentImpl.java:198

↓ 3 callersMethodisExpiredResetOnTrue

Checks if a call to this method occurs later than {@code period} since the timer was initiated or reset. If that is the case the method returns true,

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/Timer.java:69

↓ 3 callersMethodisMounted

(Hierarchy hierarchy)

storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCenter.java:131

↓ 3 callersMethodisPunctuation

(Object value)

storm-client/src/jvm/org/apache/storm/streams/StreamUtil.java:43

↓ 3 callersMethodisReady

hint to Storm if the spout is ready for the transaction id. @param txid the id of the transaction @return true, if the spout is ready for the given t

storm-client/src/jvm/org/apache/storm/trident/spout/ITridentSpout.java:88

↓ 3 callersMethodisScheduled

Checks if a specific failed {@link KafkaSpoutMessageId} is scheduled to be retried. The message may or may not be ready to be retried yet. @param msgI

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryService.java:78

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