MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodFreshCollector
(TridentContext context)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/FreshCollector.java:29
MethodFreshOutputFactory
(Fields selfFields)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:245
MethodGeneralTopologyContext
(StormTopology topology, Map<String, Object> topoConf, Map<Integer, String>
storm-client/src/jvm/org/apache/storm/task/GeneralTopologyContext.java:50
MethodGenericBolt
Constructs a new <code>GenericBolt</code> instance. @param name The name of the bolt (used in DEBUG logging) @param autoAck Whether
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java:58
MethodGenericResourceAwareStrategyOld
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/GenericResourceAwareStrategyOld.java:23
MethodGetCredentialRenewersTest
()
storm-client/test/jvm/org/apache/storm/security/auth/ClientAuthUtilsTest.java:127
MethodGetInfoOptions
()
storm-client/src/jvm/org/apache/storm/generated/GetInfoOptions.java:115
MethodGlobalGrouper
()
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:184
MethodGlobalStreamId
()
storm-client/src/jvm/org/apache/storm/generated/GlobalStreamId.java:117
MethodGoodToGo
(CountDownLatch latch, Future<Void> doneChanging)
storm-server/src/main/java/org/apache/storm/localizer/GoodToGo.java:33
MethodGoodToGoLatch
(CountDownLatch latch, Future<Void> doneChanging)
storm-server/src/main/java/org/apache/storm/localizer/GoodToGo.java:58
MethodGraphGrouper
(Graph<Node, IndexedEdge> graph, Collection<Group> initialGroups)
storm-client/src/jvm/org/apache/storm/trident/graph/GraphGrouper.java:30
MethodGrasSimulatedUser
(User other, ISchedulingState cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/GenericResourceAwareSchedulingPriorityStrategy.java:90
MethodGrasSimulatedUserComparator
(double cpuAvail, double memAvail, Map<String, Double> genericAvail)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/GenericResourceAwareSchedulingPriorityStrategy.java:166
MethodGroup
(Graph graph, List<Node> nodes)
storm-client/src/jvm/org/apache/storm/trident/graph/Group.java:33
MethodGroupCollector
(TridentCollector collector, ComboList.Factory factory)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupCollector.java:25
MethodGroupedAggregator
(Aggregator agg, Fields group, Fields input, int outSize)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupedAggregator.java:36
MethodGroupedMultiReducerExecutor
(GroupedMultiReducer reducer, List<Fields> groupFields, List<Fields> inputFields)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupedMultiReducerExecutor.java:35
MethodGroupedStream
(Stream stream, Fields groupFields)
storm-client/src/jvm/org/apache/storm/trident/fluent/GroupedStream.java:36
MethodGrouping
()
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:146
MethodGroupingInfo
()
storm-client/src/jvm/org/apache/storm/streams/GroupingInfo.java:22
MethodHBAuthorizationException
()
storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java:110
MethodHBExecutionException
()
storm-client/src/jvm/org/apache/storm/generated/HBExecutionException.java:110
MethodHBMessage
()
storm-client/src/jvm/org/apache/storm/generated/HBMessage.java:131
MethodHBMessageData
()
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:133
MethodHBNodes
()
storm-client/src/jvm/org/apache/storm/generated/HBNodes.java:111
MethodHBPulse
()
storm-client/src/jvm/org/apache/storm/generated/HBPulse.java:117
MethodHBRecords
()
storm-client/src/jvm/org/apache/storm/generated/HBRecords.java:111
MethodHBServerMessageType
(int value)
storm-client/src/jvm/org/apache/storm/generated/HBServerMessageType.java:51
MethodHBaseSecurityUtil
()
external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/HBaseSecurityUtil.java:52
MethodHDFSWriter
(FileRotationPolicy policy, Path path, FSDataOutputStream out, RecordFormat format)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/HDFSWriter.java:34
MethodHadoopCredentialUtil
()
external/storm-autocreds/src/main/java/org/apache/storm/common/HadoopCredentialUtil.java:40
MethodHdfsBlobStoreFile
(Path base, String name, Configuration hconf)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreFile.java:53
MethodHdfsBlobStoreImpl
(Path path, Map<String, Object> conf)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreImpl.java:132
MethodHdfsSecurityUtil
()
external/storm-autocreds/src/main/java/org/apache/storm/hdfs/security/HdfsSecurityUtil.java:51
MethodHdfsSpout
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:85
MethodHdfsState
(Options options)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java:66
MethodHdfsStateFactory
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsStateFactory.java:32
MethodHeaderResponseFilter
(StormMetricsRegistry metricsRegistry)
storm-webapp/src/main/java/org/apache/storm/daemon/ui/filters/HeaderResponseFilter.java:39
MethodHeaderResponseServletFilter
(StormMetricsRegistry metricsRegistry)
storm-webapp/src/main/java/org/apache/storm/daemon/ui/filters/HeaderResponseServletFilter.java:42
MethodHeartbeatCache
Create an empty cache.
storm-server/src/main/java/org/apache/storm/daemon/nimbus/HeartbeatCache.java:103
MethodHeartbeatSendTask
(int taskId, int tryTimes)
storm-server/src/main/java/org/apache/storm/nimbus/NimbusHeartbeatsPressureTest.java:179
MethodHierarchy
(String name, Set<SubSystemType> subSystems, String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/Hierarchy.java:32
MethodHikariCPConnectionProvider
(Map<String, Object> configMap)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/HikariCPConnectionProvider.java:31
MethodHistogramMetric
(final int numberOfSignificantValueDigits)
external/storm-metrics/src/main/java/org/apache/storm/metrics/hdrhistogram/HistogramMetric.java:30
MethodHookType
(String path, List<String> args, List<String> env, int timeout)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:485
MethodHostAssignableSlots
(String hostName, List<WorkerSlot> workerSlots)
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:405
MethodHttpForwardingMetricsServer
Constructor. @param conf the configuration for storm.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/HttpForwardingMetricsServer.java:70
MethodHugePageLimits
(String pageSize, long limit)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1068
MethodIdDictionary
(StormTopology topology)
storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java:217
MethodIdMapping
(int containerId, int hostId, int size)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:642
MethodIdStreamSpec
(String component, String stream)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:291
MethodIdentityBolt
(Fields fields)
storm-client/src/jvm/org/apache/storm/testing/IdentityBolt.java:24
MethodIllegalStateException
()
storm-client/src/jvm/org/apache/storm/generated/IllegalStateException.java:110
MethodImageManifest
()
storm-server/src/main/java/org/apache/storm/container/oci/ImageManifest.java:36
MethodImpersonationACL
(String impersonatingUser, Set<String> authorizedGroups, Set<String> authorizedHosts)
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/ImpersonationAuthorizer.java:167
MethodImplementsClassValidator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:996
MethodInMemoryTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator,
storm-client/src/jvm/org/apache/storm/trident/windowing/InMemoryTridentWindowManager.java:30
MethodInMemoryWindowsStore
()
storm-client/src/jvm/org/apache/storm/trident/windowing/InMemoryWindowsStore.java:35
MethodInProcessZookeeper
()
storm-server/src/main/java/org/apache/storm/testing/InProcessZookeeper.java:31
MethodIncProducer
(JCQueue queue, long _max, long min)
storm-client/test/jvm/org/apache/storm/utils/JCQueueTest.java:168
MethodIndexAndWeights
(int index)
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java:355
MethodIndexHashGrouping
(int index)
storm-client/src/jvm/org/apache/storm/trident/partition/IndexHashGrouping.java:26
MethodIndexedEdge
(T source, T target, int index)
storm-client/src/jvm/org/apache/storm/trident/util/IndexedEdge.java:23
MethodIndifferentAccessMap
(IPersistentMap map)
storm-clojure/src/main/java/org/apache/storm/clojure/IndifferentAccessMap.java:38
MethodInitialReceiver
(String stream, Fields allFields)
storm-client/src/jvm/org/apache/storm/trident/planner/SubtopologyBolt.java:216
MethodInputDeclarerImpl
(Component component)
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCTopologyBuilder.java:197
MethodInputStream
Create a new input stream to a bolt. @param fromComponent the source component of the stream. @param id the id of the stream @param execTime exec time
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java:207
MethodIntelRdt
(String closId, String l3CacheSchema, String memBwSchema)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1179
MethodIntermediateRankingsBolt
()
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/IntermediateRankingsBolt.java:31
MethodInvalidRequestException
()
storm-webapp/src/main/java/org/apache/storm/daemon/ui/InvalidRequestException.java:23
MethodInvalidTopologyException
()
storm-client/src/jvm/org/apache/storm/generated/InvalidTopologyException.java:110
MethodIsolatedPool
(int maxNodes)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/IsolatedPool.java:40
MethodJCQueue
(String queueName, String metricNamePrefix, int size, int overflowLimit, int producerBatchSz,
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:47
MethodJCQueueMetrics
(String metricNamePrefix, String topologyId, String componentId, int taskId, int port,
storm-client/src/jvm/org/apache/storm/utils/JCQueueMetrics.java:35
MethodJarConfigReader
(Yaml yaml, Map<String, Object> defaultsConf, Map<String, Object> stormConf, File file)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1869
MethodJassPasswordProvider
Constructor. @param topoConf the configuration containing the jaas conf to use. @throws IOException if we could not read the Server section in the ja
storm-client/src/jvm/org/apache/storm/security/auth/digest/JassPasswordProvider.java:42
MethodJavaObject
()
storm-client/src/jvm/org/apache/storm/generated/JavaObject.java:118
MethodJavaObjectArg
()
storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java:133
MethodJdbcClient
(ConnectionProvider connectionProvider, int queryTimeoutSecs)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/JdbcClient.java:43
MethodJdbcInsertBolt
(ConnectionProvider connectionProvider, JdbcMapper jdbcMapper)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/JdbcInsertBolt.java:39
MethodJdbcLookupBolt
(ConnectionProvider connectionProvider, String selectQuery, JdbcLookupMapper jdbcLookupMapper)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/JdbcLookupBolt.java:36
MethodJdbcState
(Map<String, Object> map, int partitionIndex, int numPartitions, Options options)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java:43
MethodJdbcStateFactory
(JdbcState.Options options)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcStateFactory.java:24
MethodJedisClusterConfig
()
external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisClusterConfig.java:33
MethodJedisClusterContainer
Constructor. @param jedisCluster JedisCluster instance
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisClusterContainer.java:32
MethodJedisContainer
Constructor. @param jedisPool JedisPool which actually manages Jedis instances
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisContainer.java:38
MethodJedisPoolConfig
()
external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisPoolConfig.java:30
MethodJedisTestHelper
Constructor. @param container Container instance to create a redis client against.
external/storm-redis/src/test/java/org/apache/storm/redis/util/JedisTestHelper.java:29
MethodJmsBatchCoordinator
(String name)
external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java:362
MethodJmsEmitter
(String name, JmsProvider jmsProvider, JmsTupleProducer tupleProducer, int jmsAcknowledgeMode,
external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java:191
MethodJmsMessageID
(long sequence, String jmsId)
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsMessageID.java:24
MethodJmsState
(Options options)
external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsState.java:42
MethodJmsStateFactory
(JmsState.Options options)
external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsStateFactory.java:24
MethodJoinBolt
Calls JoinBolt(Selector.SOURCE, sourceId, fieldName) @param sourceId Id of source component (spout/bolt) from which this bolt is receiving data @pa
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:49
MethodJoinInfo
(FieldSelector field)
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:455
MethodJoinProcessor
(String leftStream, String rightStream, ValueJoiner<V1, V2, R> valueJoiner)
storm-client/src/jvm/org/apache/storm/streams/processors/JoinProcessor.java:38
MethodJoinResult
(String returnComponent)
storm-client/src/jvm/org/apache/storm/drpc/JoinResult.java:38
MethodJoinState
(int numSides, TridentTuple group)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/JoinState.java:25
MethodJoinerMultiReducer
(List<JoinType> types, int numGroupFields, List<Fields> sides)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/JoinerMultiReducer.java:34
← previousnext →11,901–12,000 of 27,770, ranked by callers