@@ -986,6 +986,20 @@ private void createLookupAndSourceTables(String lookupTable, int maxRows) {
986986 tEnv .executeSql (lookupTable );
987987 }
988988
989+ private void assertResultsForSpec (TestSpec spec , Collection <Row > rows ) {
990+ if (spec .badStatus ) {
991+ assertEnrichedRowsNoDataBadStatus (rows );
992+ } else if (spec .deserError ) {
993+ assertEnrichedRowsDeserException (rows );
994+ } else if (spec .connectionError ) {
995+ assertEnrichedRowsException (rows );
996+ } else if (spec .useMetadata ) {
997+ assertEnrichedRows (rows , true );
998+ } else {
999+ assertEnrichedRows (rows );
1000+ }
1001+ }
1002+
9891003 private void assertEnrichedRows (Collection <Row > collectedRows ) {
9901004 assertEnrichedRows (collectedRows , false );
9911005 }
@@ -1473,18 +1487,4 @@ private String createLookupTableSql(TestSpec spec) {
14731487 .append (")" );
14741488 return sql .toString ();
14751489 }
1476-
1477- private void assertResultsForSpec (TestSpec spec , Collection <Row > rows ) {
1478- if (spec .badStatus ) {
1479- assertEnrichedRowsNoDataBadStatus (rows );
1480- } else if (spec .deserError ) {
1481- assertEnrichedRowsDeserException (rows );
1482- } else if (spec .connectionError ) {
1483- assertEnrichedRowsException (rows );
1484- } else if (spec .useMetadata ) {
1485- assertEnrichedRows (rows , true );
1486- } else {
1487- assertEnrichedRows (rows );
1488- }
1489- }
14901490}
0 commit comments