Giriş
Şu satırı dahil ederiz
import com.hazelcast.jet.sql.impl.schema.TablesStorage;
put metodu
Kodu şöyle. com.hazelcast.sql.impl.schema.Mapping nesnesini __sql.catalog isimli IMap'e ekler.
boolean putIfAbsent(String name, Mapping mapping) {
return storage().putIfAbsent(name, mapping) == null;
}
IMap<String, Object> storage() {
return nodeEngine.getHazelcastInstance()
.getMap(JetServiceBackend.SQL_CATALOG_MAP_NAME);
}
Hiç yorum yok:
Yorum Gönder