Şu satırı dahil ederiz
import com.hazelcast.jet.core.ProcessorMetaSupplier.Context;
Bu arayüz ProcessorMetaSupplier nesnesinin init() metoduna parametre olarak geçilir. Böylece ProcessorMetaSupplier nesnesi bazı ortam değişkenlerine erişebilir.
Metodlar şöyle
HazelcastInstance hazelcastInstance(); JetInstance jetInstance(); long jobId(); long executionId(); JobConfig jobConfig(); int totalParallelism(); int localParallelism(); int memberCount(); String vertexName(); ILogger logger(); boolean snapshottingEnabled(); ProcessingGuarantee processingGuarantee(); long maxProcessorAccumulatedRecords(); boolean isLightJob(); Map<Address, int[]> partitionAssignment(); ClassLoader classLoader(); DataConnectionService dataConnectionService(); void checkPermission(@Nonnull Permission permission)
Hiç yorum yok:
Yorum Gönder