import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
private boolean startWithParsedSchema = true;
private ExecutorService executor;
private ClassPool classPool;
private boolean startWithParsedSchema = true;
private ExecutorService executor;
private ClassPool classPool;