MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

⨍ Functions 147,315◇ Types & classes 15,944
↓ 2 callersMethodextractAdditionalPropertiesFrom
(JsonValue endpointAddressJson)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiProvider.java:71
↓ 2 callersMethodextractBoundedness
(RelNode rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMetadataQuery.java:50
↓ 2 callersMethodextractCallerUuid
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/operations/PartitionIteratingOperation.java:210
↓ 2 callersMethodextractComparisonOperands
Extracts comparison operands, removing CAST when possible. @param node original comparison node @return a pair of operands
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1418
↓ 2 callersMethodextractConnector
(@Nonnull String dataConnection)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/TableResolverImpl.java:193
↓ 2 callersMethodextractDynamicFunction
(LogicalTableFunctionScan scan)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/FunctionLogicalRules.java:126
↓ 2 callersMethodextractEndpointAddress
(JsonValue endpointAddressJson, Integer endpointPort, boolean isReady)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiEndpointProvider.java:78
↓ 2 callersMethodextractEqualityCondition
( Table table, RexCall call, Set<String> partitioningColumns )
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/prunability/PartitionStrategyConditionExtractor.java:114
↓ 2 callersMethodextractFrom
(Object parentObject)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/AbstractMultiValueGetter.java:51
↓ 2 callersMethodextractInputFormat
(Configuration configuration)
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/ReadHadoopNewApiP.java:131
↓ 2 callersMethodextractMapStringValue
( String functionName, HazelcastTableFunctionParameter parameter, SqlNode
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastDynamicTableFunction.java:206
↓ 2 callersMethodextractMemberMetadata
(Member member, InternalCompletableFuture future,
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/InvalidationMetaDataFetcher.java:89
↓ 2 callersMethodextractMetrics
(Collection<Object> responses)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:1128
↓ 2 callersMethodextractNewValue
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperator.java:367
↓ 2 callersMethodextractNodeName
(EndpointAddress endpointAddress, Map<EndpointAddress, String> nodes)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:299
↓ 2 callersMethodextractNodes
(JsonObject jsonObject, List<String> addresses)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiProvider.java:47
↓ 2 callersMethodextractOperand
(LogicalTableFunctionScan function, int index)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/WatermarkRules.java:142
↓ 2 callersMethodextractPermissions
(PhysicalRel physicalRel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/CalciteSqlOptimizerImpl.java:720
↓ 2 callersMethodextractPort
(JsonValue subsetJson)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiProvider.java:50
↓ 2 callersMethodextractRelsFromSubset
(RelNode input, Predicate<RelNode> predicate)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:243
↓ 2 callersMethodextractResult
(Object currentValue)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/GetOperation.java:54
↓ 2 callersMethodextractSearchPaths
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlSchemaPropagationTest.java:113
↓ 2 callersMethodextractServices
(JsonObject jsonObject, List<String> addresses)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiProvider.java:44
↓ 2 callersMethodextractShort
(int value, boolean lowerBits)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:298
↓ 2 callersMethodextractSpecificFunction
(LogicalTableFunctionScan scan)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/FunctionLogicalRules.java:114
↓ 2 callersMethodextractStringValue
(SqlLiteral literal)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastDynamicTableFunction.java:181
↓ 2 callersMethodextractTable
(LogicalTableFunctionScan scan)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/FunctionLogicalRules.java:56
↓ 2 callersMethodextractTable
(SqlIdentifier identifier)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/HazelcastSqlValidator.java:386
↓ 2 callersMethodextractUserCodeNamespaceConfigs
(Config config, Node n)
hazelcast/src/main/java/com/hazelcast/internal/config/YamlMemberDomConfigProcessor.java:362
↓ 2 callersMethodextractValue
(GenericRecord record, String path)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/extract/AvroQueryTarget.java:51
↓ 2 callersMethodextractValue
( String functionName, HazelcastTableFunctionParameter parameter, SqlNode
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastDynamicTableFunction.java:150
↓ 2 callersMethodextractor
(String name, String extractor)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/NestedPredicateWithExtractorTest.java:70
↓ 2 callersMethodf4
Returns the value of the field 4.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/Tuple5.java:95
↓ 2 callersMethodfailPrepare
()
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:47
↓ 2 callersMethodfailUnwantedException
(String methodName)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapUnboundReturnValuesTestSupport.java:173
↓ 2 callersMethodfailed_stores_does_not_change_item_count_in_write_behind_queue_without_coalescing
(boolean batchingEnabled)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindFailAndRetryTest.java:61
↓ 2 callersMethodfailureDetectorConfigXmlGenerator
(XmlGenerator gen, IcmpFailureDetectorConfig icmpFai
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:855
↓ 2 callersMethodfailureDetectorConfigYamlGenerator
( Map<String, Object> parent, IcmpFailureDetectorConfig icmpFailureDetectorConfig
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:983
↓ 2 callersMethodfastResultsDoNotGetLost
(int noOfResults)
hazelcast/src/test/java/com/hazelcast/jet/core/ObservableResultsTest.java:444
↓ 2 callersMethodfetch
(QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/LimitPhysicalRel.java:85
↓ 2 callersMethodfetch
Fetches the next page.
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientResult.java:251
↓ 2 callersMethodfetchAccessToken
()
hazelcast/src/main/java/com/hazelcast/gcp/GcpClient.java:133
↓ 2 callersMethodfetchInternal
( QueryClientState clientCursor, int cursorBufferSize, InternalSerializationService se
hazelcast/src/main/java/com/hazelcast/sql/impl/state/QueryClientStateRegistry.java:127
↓ 2 callersMethodfetchMembersMetadataFor
(List<String> names)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/InvalidationMetaDataFetcher.java:95
↓ 2 callersMethodfetchNext
Fetches at most {@code size} keys starting at the given {@code pointers} and invokes the {@code entryConsumer} for each key-value pair. @param pointe
hazelcast/src/main/java/com/hazelcast/internal/util/SampleableConcurrentHashMap.java:96
↓ 2 callersMethodfetchNextChunk
()
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/IMapInputStream.java:86
↓ 2 callersMethodfetchPartitionState
(Member m)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1515
↓ 2 callersMethodfetchZones
(String region)
hazelcast/src/main/java/com/hazelcast/gcp/GcpClient.java:107
↓ 2 callersMethodfield
(String name)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/ParserOperationsTest.java:218
↓ 2 callersMethodfieldNames
Return the desired list of fields that is used with {@code String[]} class.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/file/CsvFileFormat.java:82
↓ 2 callersMethodfields
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlBasicTest.java:351
↓ 2 callersMethodfields
(String... fields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:952
↓ 2 callersMethodfields
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/Metadata.java:43
↓ 2 callersMethodfields
Don't modify the returned list!
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/SourceMetadata.java:110
↓ 2 callersMethodfieldsAreAnnotated
()
hazelcast/src/test/java/com/hazelcast/test/AbstractParameterizedHazelcastClassRunner.java:117
↓ 2 callersMethodfieldsIf
(boolean condition, String... fields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:957
↓ 2 callersMethodfieldsToString
Returns field names with values as concatenated String, so it can be used in child classes' toString() methods.
hazelcast/src/main/java/com/hazelcast/config/CollectionConfig.java:394
↓ 2 callersMethodfileDoesNotExist
(String newJarName)
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/upload/JobUploadClientFailureTest.java:485
↓ 2 callersMethodfileNameFromUrl
Extracts the file name from the URL. File name is the part of {@code url.getPath()} after the last '/' character. Returns empty string if the path end
hazelcast/src/main/java/com/hazelcast/jet/impl/util/IOUtil.java:132
↓ 2 callersMethodfileReader
(File textFile)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/SourceBuilderTest.java:596
↓ 2 callersMethodfileWatcher
A source to stream lines added to files in a directory. This is a streaming source, it will watch directory and emit lines as they are appended to fil
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:1300
↓ 2 callersMethodfilesBuilder
Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API. The source reads records from
extensions/avro/src/main/java/com/hazelcast/jet/avro/AvroSources.java:55
↓ 2 callersMethodfillAddressMap
Returns a list of addresses with the {@code 127.0.0.1} host and starting with the {@value #DEFAULT_INITIAL_PORT} port or an empty list in case mock ne
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:558
↓ 2 callersMethodfillBaseFactoryWithPropertiesConfig
(Node node, T factoryConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractDomConfigProcessor.java:368
↓ 2 callersMethodfillFactoryWithPropertiesConfig
(Node node, T factoryConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractDomConfigProcessor.java:381
↓ 2 callersMethodfillMap
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorDuringExpirationTest.java:137
↓ 2 callersMethodfillMapsAndAssertMapSizeEventually
(TestHazelcastInstanceFactory nodeFactory, Config config, String mapName)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapLoadingTest.java:59
↓ 2 callersMethodfillNativeMemoryConfig
(Node node, NativeMemoryConfig nativeMemoryConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractDomConfigProcessor.java:389
↓ 2 callersMethodfillNonTerminalComponents
Given the list of column filters, flatten their expressions and allow-null flags. <p> The operation is performed for all filters except for the last o
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1311
↓ 2 callersMethodfillToUpperLimit
(IMap<Integer, Integer> fillMap, IMap<Integer, Integer> queryMap)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapUnboundReturnValuesTestSupport.java:153
↓ 2 callersMethodfinalizeFreshIndexStats
Finalizes the aggregation of the freshly obtained on-demand index statistics by computing the final average values which are accumulated as total sums
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:458
↓ 2 callersMethodfinalizeJob
(@Nullable final Throwable failure)
hazelcast/src/main/java/com/hazelcast/jet/impl/LightMasterContext.java:196
↓ 2 callersMethodfinalizeJobIfAutoScalingOff
(MasterContext masterContext)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1368
↓ 2 callersMethodfinalizeMigration
(MigrationInfo migrationInfo)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:235
↓ 2 callersMethodfinalizePutAll
(Map<? extends K, ? extends V> map, Map<Integer, List<Entry<Data, Data>>> entryMap)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:1700
↓ 2 callersMethodfinalizeTransactionRemotely
(Xid xid, boolean isCommit)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/txn/xa/XAResourceProxy.java:159
↓ 2 callersMethodfinalizeTransactionRemotely
(Xid xid, boolean isCommit)
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:180
↓ 2 callersMethodfinalizeTransactionsOf
(UUID callerUuid)
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionManagerServiceImpl.java:200
↓ 2 callersMethodfindAttribute
Looks for the attribute with the given name only in current object. If found, parser points to the value of the given attribute when this method retur
hazelcast/src/main/java/com/hazelcast/query/impl/getters/AbstractJsonGetter.java:208
↓ 2 callersMethodfindAuthorOwnedBy
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:358
↓ 2 callersMethodfindAwaitingFlushesAndSendNotification
( long lastSequenceInQueue)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindStore.java:379
↓ 2 callersMethodfindCacheConfig
(String simpleName)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:479
↓ 2 callersMethodfindEntryType
( RelDataTypeFactory typeFactory, List<RelDataType> argTypes )
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/special/HazelcastMapValueConstructor.java:107
↓ 2 callersMethodfindFieldOrdinal
(PartitionedMapTable table, String fieldName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/index/SqlIndexResolutionTest.java:188
↓ 2 callersMethodfindFlakeIdGeneratorConfig
Returns a {@link ClientFlakeIdGeneratorConfig} configuration for the given flake ID generator name. <p> The name is matched by pattern to the configur
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:488
↓ 2 callersMethodfindIPv4NonLoopbackInterface
()
hazelcast/src/test/java/com/hazelcast/instance/impl/DefaultAddressPickerTest.java:427
↓ 2 callersMethodfindMainClassNameForJar
(String jarPath, String mainClassName)
hazelcast/src/main/java/com/hazelcast/instance/impl/executejar/ExecuteJarHelper.java:29
↓ 2 callersMethodfindMainMethodForJar
(ClassLoader classLoader, String mainClassName)
hazelcast/src/main/java/com/hazelcast/instance/impl/executejar/ExecuteJarHelper.java:41
↓ 2 callersMethodfindManagers
(BundleContext context)
hazelcast/src/main/java/com/hazelcast/osgi/impl/OSGiScriptEngineManager.java:238
↓ 2 callersMethodfindMember
(@Nullable UUID memberUuid)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/PartitionServiceProxy.java:286
↓ 2 callersMethodfindMetadataResolver
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolvers.java:169
↓ 2 callersMethodfindMetadataResolver
(Map<String, ?> options)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/MetadataResolvers.java:67
↓ 2 callersMethodfindNext
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2LongHashMap.java:411
↓ 2 callersMethodfindOptimizableSelectorClass
(Selector selector)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/SelectorOptimizer.java:112
↓ 2 callersMethodfindOwner
(BigInteger startingHashKey)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardTracker.java:73
↓ 2 callersMethodfindPNCounterConfig
Returns a read-only {@link PNCounterConfig} configuration for the given name. <p> The name is matched by pattern to the configuration and by stripping
hazelcast/src/main/java/com/hazelcast/config/Config.java:1891
↓ 2 callersMethodfindPermissionTypeByFilter
(Predicate<PermissionType> filterPredicate)
hazelcast/src/main/java/com/hazelcast/config/PermissionConfig.java:254
↓ 2 callersMethodfindPersistableNamespaceConfig
Retrieve a namespace from the list of dynamically added or updated namespaces. <p> Only those namespaces that are not statically configured should be
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ClusterWideConfigurationService.java:420
↓ 2 callersMethodfindPortableVersion
(int factoryId, int classId, Portable portable)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:99
↓ 2 callersMethodfindPrimaryKeyIndex
Returns the index of the primary key field in the given `table`. If there's no primary key, or if there's more than ona primary key field, it returns
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:464
← previousnext →17,801–17,900 of 147,315, ranked by callers