WriterBatchConfig.java 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. package org.dbsyncer.sdk.config;
  2. import org.dbsyncer.sdk.model.Field;
  3. import java.util.List;
  4. import java.util.Map;
  5. public class WriterBatchConfig {
  6. /**
  7. * 表名
  8. */
  9. private final String tableName;
  10. /**
  11. * 事件
  12. */
  13. private final String event;
  14. /**
  15. * 执行命令
  16. */
  17. private final Map<String, String> command;
  18. /**
  19. * 字段信息
  20. */
  21. private final List<Field> fields;
  22. /**
  23. * 集合数据
  24. */
  25. private final List<Map> data;
  26. /**
  27. * 覆盖写入
  28. */
  29. private final boolean forceUpdate;
  30. /**
  31. * 是否启用字段解析器
  32. */
  33. private final boolean enableSchemaResolver;
  34. public WriterBatchConfig(String tableName, String event, Map<String, String> command, List<Field> fields, List<Map> data, boolean forceUpdate, boolean enableSchemaResolver) {
  35. this.tableName = tableName;
  36. this.event = event;
  37. this.command = command;
  38. this.fields = fields;
  39. this.data = data;
  40. this.forceUpdate = forceUpdate;
  41. this.enableSchemaResolver = enableSchemaResolver;
  42. }
  43. public String getTableName() {
  44. return tableName;
  45. }
  46. public String getEvent() {
  47. return event;
  48. }
  49. public Map<String, String> getCommand() {
  50. return command;
  51. }
  52. public List<Field> getFields() {
  53. return fields;
  54. }
  55. public List<Map> getData() {
  56. return data;
  57. }
  58. public boolean isForceUpdate() {
  59. return forceUpdate;
  60. }
  61. public boolean isEnableSchemaResolver() {
  62. return enableSchemaResolver;
  63. }
  64. }