public void validateSchema()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java [439:456]

• 14 lines of code
• 1 McCabe index (conditional complexity)

  public void validateSchema() {
    verifyTableStructure(SCHEMA_FLUME, TABLE_FL_EVENT_NAME,
        COLUMN_FLE_ID, COLUMN_FLE_PAYLOAD, COLUMN_FLE_CHANNEL,
        COLUMN_FLE_SPILL);

    verifyTableStructure(SCHEMA_FLUME, TABLE_FL_PLSPILL_NAME,
        COLUMN_FLP_EVENT, COLUMN_FLP_SPILL);

    verifyTableStructure(SCHEMA_FLUME, TABLE_FL_HEADER_NAME,
        COLUMN_FLH_ID, COLUMN_FLH_EVENT, COLUMN_FLH_NAME, COLUMN_FLH_VALUE,
        COLUMN_FLH_NMSPILL, COLUMN_FLH_VLSPILL);

    verifyTableStructure(SCHEMA_FLUME, TABLE_FL_NMSPILL_NAME,
        COLUMN_FLN_HEADER, COLUMN_FLN_SPILL);

    verifyTableStructure(SCHEMA_FLUME, TABLE_FL_VLSPILL_NAME,
        COLUMN_FLV_HEADER, COLUMN_FLV_SPILL);
  }