Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 3 callers
Method
createGetOperation
(Data key, ExpiryPolicy policy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:41
↓ 3 callers
Method
createHazelcastInstance
(Config config)
hazelcast/src/main/java/com/hazelcast/osgi/impl/HazelcastOSGiServiceImpl.java:99
↓ 3 callers
Method
createInboundHandlers
(EndpointQualifier qualifier, ServerConnection connection)
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:122
↓ 3 callers
Method
createIndexFilterForSingleRange
(Range<?> range, QueryDataType hazelcastType)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:735
↓ 3 callers
Method
createIndexesFromRecordedDefinitions
Creates indexes according to the index definitions stored inside this indexes.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:235
↓ 3 callers
Method
createInnerDTO
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:121
↓ 3 callers
Method
createInput
(Data data, InternalSerializationService service,
hazelcast/src/main/java/com/hazelcast/internal/serialization/InputOutputFactory.java:26
↓ 3 callers
Method
createInstanceAndGetMap
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/PostProcessingMapStoreTest.java:179
↓ 3 callers
Method
createInstances
(int nodeCount)
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionLostListenerTest.java:121
↓ 3 callers
Method
createIterator
(Connection connection)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/JoinPredicateScanResultSetIteratorTest.java:122
↓ 3 callers
Method
createJobConfigWithEnabledMetrics
(String jobName)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobLifecycleMetricsTest.java:299
↓ 3 callers
Method
createJoiner
(Node node)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeContext.java:38
↓ 3 callers
Method
createJsonValue
(String type, int innerValue)
hazelcast/src/test/java/com/hazelcast/json/internal/JsonMetadataCreationMigrationTest.java:131
↓ 3 callers
Method
createKey
(KeyType keyType, int i)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:419
↓ 3 callers
Method
createLazyEvictableEntryView
Returns an entry-view instance populated with default values of fields.
hazelcast/src/test/java/com/hazelcast/map/impl/recordstore/LazyEvictableEntryViewTest.java:66
↓ 3 callers
Method
createListener
(boolean lossTolerant, Consumer<Message<T>> messageLi
hazelcast/src/test/java/com/hazelcast/client/topic/ClientReliableTopicOnClusterRestartTest.java:194
↓ 3 callers
Method
createLocalMembersViewMetadata
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:607
↓ 3 callers
Method
createLoggerFactory
(String preferredType)
hazelcast/src/main/java/com/hazelcast/logging/Logger.java:229
↓ 3 callers
Method
createMainPortable
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/integration/AbstractGenericRecordIntegrationTest.java:304
↓ 3 callers
Method
createMapSizeOperationFactory
(String name)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:170
↓ 3 callers
Method
createMapStoreSingleColumnAsValue
()
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapStoreBasicIT.java:507
↓ 3 callers
Method
createMapping
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupportTest.java:99
↓ 3 callers
Method
createMembers
()
hazelcast/src/test/java/com/hazelcast/internal/partition/membergroup/MemberGroupFactoryTest.java:218
↓ 3 callers
Method
createMembersWithNoMetadata
()
hazelcast/src/test/java/com/hazelcast/internal/partition/membergroup/MemberGroupFactoryTest.java:73
↓ 3 callers
Method
createMessageTask
(ClientMessage clientMessage)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/AddMapConfigMessageTaskTest.java:178
↓ 3 callers
Method
createMessageTask
(ClientMessage clientMessage)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/management/SetDiagnosticsConfigMessageTaskTest.java:46
↓ 3 callers
Method
createMockHazelcastProperties
(HazelcastProperty property, String stringValue)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/QueryOptimizerFactoryTest.java:59
↓ 3 callers
Method
createNamedConfig
(String name, String... attributes)
hazelcast/src/test/java/com/hazelcast/map/impl/query/IndexCreateTest.java:224
↓ 3 callers
Method
createNearCacheContext
Creates the {@link NearCacheTestContext} with only a Near Cache instance used by the Near Cache tests. @param <K> key type of the created {@link com.
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:137
↓ 3 callers
Method
createNewConfig
(String mapName)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapLoadAllTest.java:154
↓ 3 callers
Method
createNewPortableInstance
(int factoryId, int classId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:110
↓ 3 callers
Method
createNode
(TestHazelcastInstanceFactory instanceFactory)
hazelcast/src/test/java/com/hazelcast/map/MapIndexBackupTest.java:101
↓ 3 callers
Method
createNode
(TestHazelcastInstanceFactory instanceFactory)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:292
↓ 3 callers
Method
createNonFragmentedReplicationOperations
non-fragmented service replication operation preparation is always executed on partition operation thread
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:68
↓ 3 callers
Method
createNullableType
(RelDataTypeFactory typeFactory, RelDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:178
↓ 3 callers
Method
createOperation
(boolean fail)
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:85
↓ 3 callers
Method
createOutboundHandlers
(EndpointQualifier qualifier, ServerConnection connection)
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:124
↓ 3 callers
Method
createOutput
(int size, InternalSerializationService service)
hazelcast/src/main/java/com/hazelcast/internal/serialization/InputOutputFactory.java:39
↓ 3 callers
Method
createPartitionRunner
Creates an OperationRunner for a given partition. This OperationRunner will only execute generic operations and operations for that given partition.
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationRunnerFactory.java:35
↓ 3 callers
Method
createPartitionState
(int partitionId, PartitionReplica... replicas)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionRuntimeStateTest.java:90
↓ 3 callers
Method
createPartitionState
Creates the current partition runtime state. May return {@code null} if the node should fetch the most recent partition table (e.g. this node is a new
hazelcast/src/main/java/com/hazelcast/internal/partition/InternalPartitionService.java:114
↓ 3 callers
Method
createPausedMigrationCluster
(final TestHazelcastInstanceFactory factory, @Nulla
hazelcast/src/test/java/com/hazelcast/partition/PartitionMigrationListenerTest.java:456
↓ 3 callers
Method
createPlainSourceBuilder
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamSourceStageTest.java:82
↓ 3 callers
Method
createPredicate
(String sql)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:139
↓ 3 callers
Method
createPutIfAbsentOperation
(String name, Data key, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:50
↓ 3 callers
Method
createPutOperation
(String name, Data key, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:44
↓ 3 callers
Method
createPutTransientOperation
(String name, Data key, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:52
↓ 3 callers
Method
createQueryOperation
(Query query)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:91
↓ 3 callers
Method
createQueryPartitionOperation
(Query query)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:93
↓ 3 callers
Method
createRecordStore
(MapContainer mapContainer, int partitionId, MapKeyLoader keyLoader)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:162
↓ 3 callers
Method
createRemoteClient
Creates a remote client using {@code dataConnectionName} or {@code clientXml} in order, depending on availability.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:870
↓ 3 callers
Method
createRemoveAllOperationFactory
(Set<Data> keySet, Integer completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:88
↓ 3 callers
Method
createRemoveOperation
(String name, Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:64
↓ 3 callers
Method
createReplicationOperations
(PartitionReplicationEvent event, boolean nonFra
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:83
↓ 3 callers
Method
createResourcesJarFile
(File jarFile)
hazelcast/src/test/java/com/hazelcast/test/JarUtil.java:37
↓ 3 callers
Method
createResponseAssertTask
(final String message, final TextProtocolClient client, final String expectedSubstring)
hazelcast/src/test/java/com/hazelcast/internal/nio/ascii/AbstractTextProtocolsTestBase.java:39
↓ 3 callers
Method
createSSLContext
(String ksFile, String ksType, char[] ksPass, String tsFile, St
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/SslConf.java:144
↓ 3 callers
Method
createSchemaQuery
(String schemaName)
hazelcast/src/test/java/com/hazelcast/test/jdbc/JdbcObjectProvider.java:69
↓ 3 callers
Method
createSchemaService
Creates and returns a schema service for the member side that is able to replicate schemas across the cluster. @return the member schema service
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:228
↓ 3 callers
Method
createSchemaWithData
(int schemaSuffix)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcWhiteBlackListIntegrationTest.java:281
↓ 3 callers
Method
createServerSocketChannel
Creates and binds {@code ServerSocketChannel} using {@code bindAddress} and {@code initialPort}. <p> If the {@code initialPort} is in use, then an ava
hazelcast/src/main/java/com/hazelcast/instance/impl/ServerSocketHelper.java:66
↓ 3 callers
Method
createServiceConfig
(int backupCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:37
↓ 3 callers
Method
createSetExpiryPolicyOperation
(List<Data> keys, Data expiryPolicy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:80
↓ 3 callers
Method
createSetOperation
(String name, Data dataKey, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:48
↓ 3 callers
Method
createSimpleMap
(K key, V value)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/AuthenticationKeyValuePairConstantsTest.java:201
↓ 3 callers
Method
createSingleLiteMember
()
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapLiteMemberTest.java:103
↓ 3 callers
Method
createSnapshot
(int memberListVersion, Collection<MemberInfo> memberInfos, UUID clusterUuid)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientClusterServiceImpl.java:254
↓ 3 callers
Method
createStoreFile
(int keyCount, KeyType keyType)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:233
↓ 3 callers
Method
createTable
(String connectionUrl, String tableName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectJdbcIT.java:420
↓ 3 callers
Method
createTableWithData
()
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcListenBeforeExistIntegrationTest.java:154
↓ 3 callers
Method
createTableWithData
(String schema, String table)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcListenBeforeExistsIntegrationTest.java:159
↓ 3 callers
Method
createTaskRunner
()
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/SourceConnectorWrapper.java:188
↓ 3 callers
Method
createTimestampedSourceBuilder
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamSourceStageTest.java:70
↓ 3 callers
Method
createTransactionalObject
(String name, Transaction transaction)
hazelcast/src/main/java/com/hazelcast/internal/services/TransactionalService.java:31
↓ 3 callers
Method
createType
(SqlTypeName typeName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeFactory.java:129
↓ 3 callers
Method
createUnitUnderTest
(Properties properties, HazelcastInstance instance,
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapLoaderTest.java:795
↓ 3 callers
Method
createValue
()
hazelcast/src/test/java/com/hazelcast/map/standalone/SimpleFunctionalMapTest.java:122
↓ 3 callers
Method
creationTime
Returns the timestamp of when the session was created
hazelcast/src/main/java/com/hazelcast/cp/session/CPSession.java:87
↓ 3 callers
Method
credentialsEc2
()
hazelcast/src/test/java/com/hazelcast/aws/AwsMetadataApiTest.java:196
↓ 3 callers
Method
current
()
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/ServiceNamespacesContext.java:115
↓ 3 callers
Method
currentThreadId
()
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/txn/xa/XAResourceProxy.java:233
↓ 3 callers
Method
currentThreadId
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:316
↓ 3 callers
Method
currentTimestamp
(Clock clock)
hazelcast/src/main/java/com/hazelcast/aws/AwsRequestUtils.java:40
↓ 3 callers
Method
currentZone
()
hazelcast/src/main/java/com/hazelcast/gcp/GcpMetadataApi.java:52
↓ 3 callers
Method
dataConnectionName
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaTable.java:81
↓ 3 callers
Method
datestamp
(String timestamp)
hazelcast/src/main/java/com/hazelcast/aws/AwsRequestSigner.java:161
↓ 3 callers
Method
deRegisterInvocation
remove invocation @param callId invocation id
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocationServiceInternal.java:63
↓ 3 callers
Method
debeziumJson
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline. <p> Differs from the {@link #debezium(St
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/DebeziumCdcSources.java:105
↓ 3 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/DataPersistenceConfigCodec.java:55
↓ 3 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/PagingPredicateHolderCodec.java:63
↓ 3 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/XidCodec.java:56
↓ 3 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/VectorDocumentCodec.java:50
↓ 3 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/EvictionConfigHolderCodec.java:58
↓ 3 callers
Method
decodeFloat
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/FixedSizeTypesCodec.java:155
↓ 3 callers
Method
decrementLatchAndHandle
(int count)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/InvokeOnPartitions.java:108
↓ 3 callers
Method
decrypt
Decrypts given encrypted variable. @param encryptedStr the encrypted value @return the decrypted value @throws Exception in case of any exceptional c
hazelcast/src/main/java/com/hazelcast/config/replacer/AbstractPbeReplacer.java:141
↓ 3 callers
Method
deductFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperationImpl.java:94
↓ 3 callers
Method
define
(String name, byte[] bytecode)
hazelcast/src/main/java/com/hazelcast/internal/usercodedeployment/impl/ClassSource.java:51
↓ 3 callers
Method
delay
(long ms)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer_IntegrationTest.java:169
↓ 3 callers
Method
delete
(File file)
hazelcast/src/test/java/com/hazelcast/jet/impl/JobRepositoryTest.java:224
← previous
next →
13,801–13,900 of 147,315, ranked by callers