MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodcreateCatalog
Creates the top-level catalog containing the given child schema. @param schema Schema. @return Catalog.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastSchemaUtils.java:43
↓ 2 callersMethodcreateChannelInitializerFn
Creates the channel initializer function.
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:303
↓ 2 callersMethodcreateChars
(int length)
hazelcast/src/test/java/com/hazelcast/internal/json/WritingBuffer_Test.java:154
↓ 2 callersMethodcreateClassFilter
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGeneratorTest.java:591
↓ 2 callersMethodcreateClearOperationFactory
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:86
↓ 2 callersMethodcreateClient
(String connectionString)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/MongoSinkTest.java:229
↓ 2 callersMethodcreateClient
()
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:156
↓ 2 callersMethodcreateClient
(int port)
hazelcast/src/test/java/com/hazelcast/client/impl/connection/tcp/AdvancedNetworkingClientCommunicationIntegrationTest.java:57
↓ 2 callersMethodcreateClient
(String podName, String masterUrl, ClusterTopologyIntentTracker tracker)
hazelcast/src/test/java/com/hazelcast/kubernetes/StsDetermineRootNameTest.java:220
↓ 2 callersMethodcreateClientBwListEntry
(int type, String value)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:246
↓ 2 callersMethodcreateClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/usercodedeployment/ClientUserCodeDeploymentExceptionTest.java:89
↓ 2 callersMethodcreateClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/listeners/AbstractListenersOnReconnectTest.java:380
↓ 2 callersMethodcreateClientConnectingTo
(HazelcastInstance targetInstance)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/SingleMemberClientTest.java:82
↓ 2 callersMethodcreateClusterConfig
()
hazelcast/src/test/java/com/hazelcast/client/stress/StressTestSupport.java:63
↓ 2 callersMethodcreateCompactGenericRecord
(MainDTO mainDTO)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:68
↓ 2 callersMethodcreateCompatibilitySerializationService
Creates and returns a serialization service for (de)serializing objects compatible with a compatibility (3.x) format. @return the compatibility seria
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:220
↓ 2 callersMethodcreateConfig
()
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/ConfigCreator.java:27
↓ 2 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheReadWriteThroughTest.java:65
↓ 2 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/cache/impl/InternalCacheRecordStoreTest.java:69
↓ 2 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/Invocation_NetworkSplitTest.java:154
↓ 2 callersMethodcreateConfig
(Boolean safeSerialization)
hazelcast/src/test/java/com/hazelcast/spi/discovery/multicast/MulticastDiscoveryStrategyDeserializationTest.java:104
↓ 2 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestInstanceMultiendpointTest.java:28
↓ 2 callersMethodcreateConfig
(NearCacheConfig nearCacheConfig, boolean liteMember)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/LiteMemberMapNearCacheSerializationCountTest.java:176
↓ 2 callersMethodcreateConfig
(IMapMapStore mapStore, boolean withNearCache)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/MapNearCacheBasicTest.java:108
↓ 2 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/MemberMapInvalidationMemberAddRemoveTest.java:156
↓ 2 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/MemberMapInvalidationMetadataDistortionTest.java:144
↓ 2 callersMethodcreateConfig
(String mapName, MapStore store, int writeDelaySeconds)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindUponMigrationTest.java:111
↓ 2 callersMethodcreateConfig
(boolean withFilter)
hazelcast/src/test/java/com/hazelcast/cluster/MulticastDeserializationTest.java:109
↓ 2 callersMethodcreateConfigBean
(Node rootNode)
hazelcast-spring/src/main/java/com/hazelcast/spring/HazelcastClientBeanDefinitionParser.java:153
↓ 2 callersMethodcreateConfigForInitiator
()
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/LocalAddressRegistryIntegrationTest.java:192
↓ 2 callersMethodcreateConfigForServer
()
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/LocalAddressRegistryIntegrationTest.java:168
↓ 2 callersMethodcreateConfigWithDisabledGroups
Creates Hazelcast {@link Config} with enabled all but provided {@link RestEndpointGroup RestEndpointGroups}.
hazelcast/src/test/java/com/hazelcast/internal/nio/ascii/RestApiConfigTestBase.java:100
↓ 2 callersMethodcreateConfigWithEnabledGroups
Creates Hazelcast {@link Config} with disabled all but provided {@link RestEndpointGroup RestEndpointGroups}.
hazelcast/src/test/java/com/hazelcast/internal/nio/ascii/RestApiConfigTestBase.java:112
↓ 2 callersMethodcreateConfigWithNearCache
(boolean invalidateOnChange)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/invalidation/StaleReadDetectorTest.java:88
↓ 2 callersMethodcreateConfigWithRestEnabled
()
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestInstanceTest.java:59
↓ 2 callersMethodcreateConnectionProcessListenerRunner
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/discovery/RemoteAddressProviderTest.java:121
↓ 2 callersMethodcreateConnectionsOnEachPlane
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/LocalAddressRegistryIntegrationTest.java:219
↓ 2 callersMethodcreateContainsKeyOperation
(String name, Data dataKey)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:85
↓ 2 callersMethodcreateContext
Creates the data structure specific {@link EventJournalTestContext} used by the event journal tests. @param <K> key type of the created {@link EventJ
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalExpiringTest.java:210
↓ 2 callersMethodcreateCopyMigration
(int partitionId, int copyReplicaIndex, PartitionReplica destination)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:332
↓ 2 callersMethodcreateDagData
()
hazelcast/src/test/java/com/hazelcast/jet/impl/JobRepositoryTest.java:284
↓ 2 callersMethodcreateDataInput
(ByteOrder bo)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInputTest.java:76
↓ 2 callersMethodcreateDataPersistenceConfig
(Node node)
hazelcast/src/main/java/com/hazelcast/internal/config/MemberDomConfigProcessor.java:2112
↓ 2 callersMethodcreateDefaultWriteBehindQueue
()
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueues.java:30
↓ 2 callersMethodcreateDestroyQueryCacheOperation
Creates recovery operation for event loss cases. @param mapName map name @param cacheId ID of cache @return operation or request according to context
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/SubscriberContextSupport.java:54
↓ 2 callersMethodcreateDirectoryIfDoesNotExist
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/DiagnosticsLogFile.java:134
↓ 2 callersMethodcreateDiscoveryStrategyConfigs
Extracts aliased discovery configs from {@code config} and creates a list of {@link DiscoveryStrategyConfig} out of them.
hazelcast/src/main/java/com/hazelcast/client/config/impl/ClientAliasedDiscoveryConfigUtils.java:41
↓ 2 callersMethodcreateDiscoveryWithEmptyInitialResponse
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/discovery/ViridianAddressProviderTest.java:173
↓ 2 callersMethodcreateDummyPipeline
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioOutboundPipelineProbeTest.java:111
↓ 2 callersMethodcreateDurationConfig
(long durationAmount, int timeUnitId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:200
↓ 2 callersMethodcreateEndpointQualifier
(ProtocolType type, Node node)
hazelcast-spring/src/main/java/com/hazelcast/spring/HazelcastConfigBeanDefinitionParser.java:2356
↓ 2 callersMethodcreateEntry
(final Object key, final Object value)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/PredicatesTest.java:389
↓ 2 callersMethodcreateEntryListenerCodec
()
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReplicatedMapProxy.java:308
↓ 2 callersMethodcreateEntryListenerWithPredicateCodec
(final Data predicateData)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReplicatedMapProxy.java:378
↓ 2 callersMethodcreateEntryProcessorOperation
(Data key, Integer completionId, EntryProcessor entryProcessor, Object... args)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:55
↓ 2 callersMethodcreateEntryView
()
hazelcast/src/test/java/com/hazelcast/replicatedmap/impl/record/EntryViewTest.java:54
↓ 2 callersMethodcreateEntrypointAddress
(int customPort, boolean isReady)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesApiEndpointResolverTest.java:166
↓ 2 callersMethodcreateErrorLoggingResponseHandler
(ILogger logger)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationResponseHandlerFactory.java:40
↓ 2 callersMethodcreateEvictOperation
(String name, Data dataKey, boolean asyncBackup)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:81
↓ 2 callersMethodcreateException
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/BadTable.java:56
↓ 2 callersMethodcreateException
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientExceptionFactory.java:376
↓ 2 callersMethodcreateExceptionForMisIndentedConfigProp
(String propName, boolean addNote)
hazelcast/src/main/java/com/hazelcast/internal/config/YamlConfigSchemaValidator.java:157
↓ 2 callersMethodcreateExecutorContainer
(String name, TaskRingBuffer ringBuffer)
hazelcast/src/main/java/com/hazelcast/durableexecutor/impl/DurableExecutorPartitionContainer.java:52
↓ 2 callersMethodcreateExportSnapshotOperation
(long jobId, String name, boolean cancelJob)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:326
↓ 2 callersMethodcreateExtendedRowIfNecessary
(JetSqlRow leftRow)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/JoinPredicateScanRowMapper.java:142
↓ 2 callersMethodcreateFactory
()
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/MetricsDataSerializerHook.java:53
↓ 2 callersMethodcreateFastReadWriteCaches
(Class clazz)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/ReflectiveCompactSerializer.java:171
↓ 2 callersMethodcreateFastRetryConfig
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql_slow/MapScanMigrationStressTest.java:80
↓ 2 callersMethodcreateFetchEntriesOperation
Creates an operation for fetching a segment of a entries from a single partition. @see CacheProxy#iterator(int, int, boolean)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:71
↓ 2 callersMethodcreateFetchKeysOperation
Creates an operation for fetching a segment of a keys from a single partition. @see CacheProxy#iterator(int, int, boolean)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:63
↓ 2 callersMethodcreateFetchKeysOperation
Creates an operation for fetching a segment of a keys from a single partition. @see com.hazelcast.map.impl.proxy.MapProxyImpl#iterator(int, int, bool
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:131
↓ 2 callersMethodcreateFieldDescriptor
(@Nonnull String fieldName, int id)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:276
↓ 2 callersMethodcreateFieldList
(List<MappingField> resolvedFields)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/CsvMetadataResolver.java:59
↓ 2 callersMethodcreateFileName
(byte version)
hazelcast/src/test/java/com/hazelcast/nio/serialization/compatibility/BinaryCompatibilityTest.java:231
↓ 2 callersMethodcreateFileWithDependencyImport
( String dependent, String pathToDependency, Function<String, String> file
hazelcast/src/test/java/com/hazelcast/config/helpers/DeclarativeConfigFileHelper.java:211
↓ 2 callersMethodcreateFillAndDestroyMap
()
hazelcast/src/test/java/com/hazelcast/map/MapDestroyTest.java:111
↓ 2 callersMethodcreateFilterBlocking
(Class<?> blockedClass)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/inject/HazelcastObjectUpsertTargetTest.java:100
↓ 2 callersMethodcreateFilterListBean
(Node node)
hazelcast-spring/src/main/java/com/hazelcast/spring/AbstractHazelcastBeanDefinitionParser.java:762
↓ 2 callersMethodcreateFragment
(long fragmentId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/util/ClientMessageSplitter.java:99
↓ 2 callersMethodcreateFragmentReplicationOperationsOffload
Used for offloaded replication-operation preparation while executing a migration request
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:223
↓ 2 callersMethodcreateFromObject
Returns metadata for given object. Implementing class decides the type of the metadata returned. It is up to the implementating class to verify the t
hazelcast/src/main/java/com/hazelcast/map/impl/MetadataInitializer.java:48
↓ 2 callersMethodcreateFutureProxy
(ScheduledTaskHandler handler)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:361
↓ 2 callersMethodcreateFutureProxy
(int partitionId, String taskName)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:441
↓ 2 callersMethodcreateGcpConfig
()
hazelcast/src/main/java/com/hazelcast/gcp/GcpDiscoveryStrategy.java:80
↓ 2 callersMethodcreateGetAllOperationFactory
(Set<Data> keySet, ExpiryPolicy policy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:82
↓ 2 callersMethodcreateGetAndRemoveOperation
(Data key, int completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:49
↓ 2 callersMethodcreateGetAndReplaceOperation
(Data key, Data value, ExpiryPolicy policy, int completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:53
↓ 2 callersMethodcreateGetEntryViewOperation
(String name, Data dataKey)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:87
↓ 2 callersMethodcreateGetter
(Object obj, String attribute, boolean failOnMissingAttribute, Reflectiv
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ReflectionHelper.java:102
↓ 2 callersMethodcreateGroupConfig
(String[] addressArray)
hazelcast/src/test/java/com/hazelcast/map/LocalMapStatsMultipleNodeTest.java:222
↓ 2 callersMethodcreateHazelcastInstance
()
hazelcast/src/test/java/classloading/AbstractJavaXCacheDependencyTest.java:52
↓ 2 callersMethodcreateHazelcastInstanceFactory0
(Integer nodeCount)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:308
↓ 2 callersMethodcreateHeaders
(String body, AwsCredentials credentials, String awsTargetAction)
hazelcast/src/main/java/com/hazelcast/aws/AwsEcsApi.java:151
↓ 2 callersMethodcreateHeaders
(Map<String, String> attributes, AwsCredentials credentials)
hazelcast/src/main/java/com/hazelcast/aws/AwsEc2Api.java:250
↓ 2 callersMethodcreateHotRestartConfig
(Node node)
hazelcast/src/main/java/com/hazelcast/internal/config/MemberDomConfigProcessor.java:2096
↓ 2 callersMethodcreateIMapEvent
(Data key, Data value, Data oldValue, Data mergingValue, int eventType,
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:2108
↓ 2 callersMethodcreateIdler
( HazelcastProperties props, HazelcastProperty minProp, HazelcastProperty maxProp )
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/TaskletExecutionService.java:256
↓ 2 callersMethodcreateIndexConfig
(String name, int type, List<String> attributes, BitmapIndexOp
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:223
↓ 2 callersMethodcreateIndexRegistry
@param global set {@code true} to create global indexes, otherwise set {@code false} to have partitioned indexes @param partit
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainerImpl.java:161
↓ 2 callersMethodcreateInet6AddressWithScope
(String address, int scopeId)
hazelcast/src/test/java/com/hazelcast/internal/util/AddressUtilTest.java:211
← previousnext →17,201–17,300 of 147,315, ranked by callers