public class JdbcSinkOperator extends AbstractStreamOperator implements ProcessingTimeCallback, OneInputStreamOperator{ private Map> map; private ListState listState; private int batchSize; private long interval; private Connection connection; private Statement statement; private ProcessingTimeService processingTimeService; private Properties jdbc; public Logger logger ; public JdbcSinkMergeSqlOperator(Properties jdbc) { Object size = jdbc.remove("batch.size"); Object time = jdbc.remove("interval"); this.chainingStrategy = ChainingStrategy.ALWAYS; this.batchSize = size == null ? 1 : Integer.parseInt(size.toString()); this.interval = time == null ? 30000L : Long.parseLong(time.toString()); this.jdbc = jdbc;
上一篇 java实现短信通知、验证码
下一篇 项目架构基础：关系可视化-UML类图
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号：晋ICP备2021003244-6号
