Şu satırı dahil ederiz
import com.hazelcast.jet.sql.impl.SqlPlanImpl;
CreateJobPlan sınıfı SqlPlanImpl içinde. Kod şöyle
static class CreateJobPlan extends SqlPlanImpl { private final JobConfig jobConfig; private final boolean ifNotExists; private final DmlPlan dmlPlan; private final String query; private final boolean infiniteRows; private final PlanExecutor planExecutor; ... }
infiniteRows Stream Job olduğunu belirtir
Hiç yorum yok:
Yorum Gönder