13
13
import java .time .ZonedDateTime ;
14
14
import java .time .format .DateTimeFormatter ;
15
15
import java .time .temporal .ChronoUnit ;
16
- import java .util .ArrayList ;
17
16
import java .util .HashMap ;
18
- import java .util .List ;
19
17
import java .util .Map ;
20
18
21
19
public class MetroJourneyResultSetProcessor extends AbstractResultSetProcessor {
@@ -28,7 +26,6 @@ public MetroJourneyResultSetProcessor(final RedisUtils redisUtils, final QueryUt
28
26
public void processResultSet (final ResultSet resultSet ) throws Exception {
29
27
int rowCounter = 0 ;
30
28
int redisCounter = 0 ;
31
- List <String > metroKeys = new ArrayList <>();
32
29
33
30
while (resultSet .next ()) {
34
31
rowCounter ++;
@@ -48,7 +45,6 @@ public void processResultSet(final ResultSet resultSet) throws Exception {
48
45
values .put (TransitdataProperties .KEY_START_STOP_NUMBER , stopNumber );
49
46
50
47
String metroKey = TransitdataProperties .formatMetroId (stopNumber , dateTime );
51
- metroKeys .add (metroKey );
52
48
String response = redisUtils .setValues (metroKey , values );
53
49
if (redisUtils .checkResponse (response )) {
54
50
redisUtils .setExpire (metroKey );
@@ -59,7 +55,6 @@ public void processResultSet(final ResultSet resultSet) throws Exception {
59
55
}
60
56
61
57
log .info ("Inserted {} redis metro id keys for {} DB rows" , redisCounter , rowCounter );
62
- log .info ("Metro keys: " + metroKeys );
63
58
}
64
59
65
60
protected String getQuery () {
0 commit comments