@@ -247,9 +247,7 @@ public void testHalt() {
247
247
isHalted = true ;
248
248
}
249
249
@ Override public void onError (Throwable e ) { e .printStackTrace (); }
250
- @ Override public void onNext (Inference output ) {
251
- System .out .println ("output = " + Arrays .toString (output .getSDR ()));
252
- }
250
+ @ Override public void onNext (Inference output ) {}
253
251
});
254
252
255
253
try {
@@ -266,9 +264,9 @@ public void testHalt() {
266
264
@ Test
267
265
public void testReset () {
268
266
Sensor <File > sensor = Sensor .create (
269
- FileSensor ::create ,
270
- SensorParams .create (
271
- Keys ::path , "" , ResourceLocator .path ("rec-center-hourly-4reset.csv" )));
267
+ FileSensor ::create ,
268
+ SensorParams .create (
269
+ Keys ::path , "" , ResourceLocator .path ("rec-center-hourly-4reset.csv" )));
272
270
273
271
Parameters p = NetworkTestHarness .getParameters ().copy ();
274
272
p = p .union (NetworkTestHarness .getHotGymTestEncoderParams ());
@@ -306,9 +304,9 @@ public void testReset() {
306
304
@ Test
307
305
public void testSequenceChangeReset () {
308
306
Sensor <File > sensor = Sensor .create (
309
- FileSensor ::create ,
310
- SensorParams .create (
311
- Keys ::path , "" , ResourceLocator .path ("rec-center-hourly-4seqReset.csv" )));
307
+ FileSensor ::create ,
308
+ SensorParams .create (
309
+ Keys ::path , "" , ResourceLocator .path ("rec-center-hourly-4seqReset.csv" )));
312
310
313
311
Parameters p = NetworkTestHarness .getParameters ().copy ();
314
312
p = p .union (NetworkTestHarness .getHotGymTestEncoderParams ());
@@ -345,15 +343,15 @@ public void testSequenceChangeReset() {
345
343
@ Test
346
344
public void testLayerWithObservableInput () {
347
345
Publisher manual = Publisher .builder ()
348
- .addHeader ("timestamp,consumption" )
349
- .addHeader ("datetime,float" )
350
- .addHeader ("B" )
351
- .build ();
346
+ .addHeader ("timestamp,consumption" )
347
+ .addHeader ("datetime,float" )
348
+ .addHeader ("B" )
349
+ .build ();
352
350
353
351
Sensor <ObservableSensor <String []>> sensor = Sensor .create (
354
- ObservableSensor ::create ,
355
- SensorParams .create (
356
- Keys ::obs , new Object [] {"name" , manual }));
352
+ ObservableSensor ::create ,
353
+ SensorParams .create (
354
+ Keys ::obs , new Object [] {"name" , manual }));
357
355
358
356
Parameters p = NetworkTestHarness .getParameters ().copy ();
359
357
p = p .union (NetworkTestHarness .getHotGymTestEncoderParams ());
@@ -387,9 +385,9 @@ public void testLayerWithObservableInput() {
387
385
388
386
try {
389
387
String [] entries = {
390
- "7/2/10 0:00,21.2" ,
391
- "7/2/10 1:00,34.0" ,
392
- "7/2/10 2:00,40.4" ,
388
+ "7/2/10 0:00,21.2" ,
389
+ "7/2/10 1:00,34.0" ,
390
+ "7/2/10 2:00,40.4" ,
393
391
};
394
392
395
393
// Send inputs through the observable
@@ -407,15 +405,15 @@ public void testLayerWithObservableInput() {
407
405
@ Test
408
406
public void testLayerWithObservableInputIntegerArray () {
409
407
Publisher manual = Publisher .builder ()
410
- .addHeader ("sdr_in" )
411
- .addHeader ("darr" )
412
- .addHeader ("B" )
413
- .build ();
408
+ .addHeader ("sdr_in" )
409
+ .addHeader ("darr" )
410
+ .addHeader ("B" )
411
+ .build ();
414
412
415
413
Sensor <ObservableSensor <String []>> sensor = Sensor .create (
416
- ObservableSensor ::create ,
417
- SensorParams .create (
418
- Keys ::obs , new Object [] {"name" , manual }));
414
+ ObservableSensor ::create ,
415
+ SensorParams .create (
416
+ Keys ::obs , new Object [] {"name" , manual }));
419
417
420
418
Parameters p = Parameters .getAllDefaultParameters ();
421
419
p = p .union (getArrayTestParams ());
@@ -498,10 +496,10 @@ public void testLayerWithGenericObservable() {
498
496
};
499
497
500
498
Network n = Network .create ("Generic Test" , p )
501
- .add (Network .createRegion ("R1" )
502
- .add (Network .createLayer ("L1" , p )
503
- .add (addedFunc )
504
- .add (new SpatialPooler ())));
499
+ .add (Network .createRegion ("R1" )
500
+ .add (Network .createLayer ("L1" , p )
501
+ .add (addedFunc )
502
+ .add (new SpatialPooler ())));
505
503
506
504
@ SuppressWarnings ("unchecked" )
507
505
Layer <int []> l = (Layer <int []>)n .lookup ("R1" ).lookup ("L1" );
@@ -647,7 +645,6 @@ public void testBasicSetupEncoder_AUTO_MODE() {
647
645
@ Override public void onNext (Inference output ) {
648
646
// System.out.println(" seq = " + seq + ", recNum = " + output.getRecordNum() + ", expected = " + Arrays.toString(expected[seq]));
649
647
// System.out.println(" seq = " + seq + ", recNum = " + output.getRecordNum() + ", output = " + Arrays.toString(output.getSDR()));
650
- if (seq == output .getRecordNum ())
651
648
assertTrue (Arrays .equals (expected [seq ], output .getSDR ()));
652
649
seq ++;
653
650
}
@@ -660,7 +657,6 @@ public void testBasicSetupEncoder_AUTO_MODE() {
660
657
@ Override public void onNext (Inference output ) {
661
658
// System.out.println(" seq = " + seq2 + ", recNum = " + output.getRecordNum() + ", expected = " + Arrays.toString(expected[seq2]));
662
659
// System.out.println(" seq = " + seq2 + ", recNum = " + output.getRecordNum() + ", output = " + Arrays.toString(output.getSDR()));
663
- if (seq2 == output .getRecordNum ())
664
660
assertTrue (Arrays .equals (expected [seq2 ], output .getSDR ()));
665
661
seq2 ++;
666
662
}
@@ -725,9 +721,9 @@ public void onNext(Inference spatialPoolerOutput) {
725
721
@ Test
726
722
public void testBasicSetup_SpatialPooler_AUTO_MODE () {
727
723
Sensor <File > sensor = Sensor .create (
728
- FileSensor ::create ,
729
- SensorParams .create (
730
- Keys ::path , "" , ResourceLocator .path ("days-of-week.csv" )));
724
+ FileSensor ::create ,
725
+ SensorParams .create (
726
+ Keys ::path , "" , ResourceLocator .path ("days-of-week.csv" )));
731
727
732
728
Parameters p = NetworkTestHarness .getParameters ().copy ();
733
729
p = p .union (NetworkTestHarness .getDayDemoTestEncoderParams ());
@@ -1117,8 +1113,8 @@ public void testAnomalySetup() {
1117
1113
params .put (KEY_USE_MOVING_AVG , true );
1118
1114
Anomaly anomalyComputer = Anomaly .create (params );
1119
1115
1120
- final Layer <Map <String , Object >> l = new Layer <>(p , me , new SpatialPooler (), new TemporalMemory (),
1121
- Boolean .TRUE , anomalyComputer );
1116
+ final Layer <Map <String , Object >> l = new Layer <>(
1117
+ p , me , new SpatialPooler (), new TemporalMemory (), Boolean .TRUE , anomalyComputer );
1122
1118
1123
1119
l .subscribe (new Observer <Inference >() {
1124
1120
@ Override public void onCompleted () {}
@@ -1312,14 +1308,14 @@ public void testFullLayerFluentAssembly() {
1312
1308
Anomaly anomalyComputer = Anomaly .create (params );
1313
1309
1314
1310
Layer <?> l = Network .createLayer ("TestLayer" , p )
1315
- .alterParameter (KEY .AUTO_CLASSIFY , true )
1316
- .add (anomalyComputer )
1317
- .add (new TemporalMemory ())
1318
- .add (new SpatialPooler ())
1319
- .add (Sensor .create (
1320
- FileSensor ::create ,
1321
- SensorParams .create (
1322
- Keys ::path , "" , ResourceLocator .path ("rec-center-hourly-small.csv" ))));
1311
+ .alterParameter (KEY .AUTO_CLASSIFY , true )
1312
+ .add (anomalyComputer )
1313
+ .add (new TemporalMemory ())
1314
+ .add (new SpatialPooler ())
1315
+ .add (Sensor .create (
1316
+ FileSensor ::create ,
1317
+ SensorParams .create (
1318
+ Keys ::path , "" , ResourceLocator .path ("rec-center-hourly-small.csv" ))));
1323
1319
1324
1320
l .getConnections ().printParameters ();
1325
1321
@@ -1330,10 +1326,9 @@ public void testFullLayerFluentAssembly() {
1330
1326
public void onNext (Inference i ) {
1331
1327
if (flowReceived ) return ; // No need to set this value multiple times
1332
1328
1333
- System .out .println ("classifier size = " + i .getClassifiers ().size ());
1334
1329
flowReceived = i .getClassifiers ().size () == 4 &&
1335
- i .getClassifiers ().get ("timestamp" ) != null &&
1336
- i .getClassifiers ().get ("consumption" ) != null ;
1330
+ i .getClassifiers ().get ("timestamp" ) != null &&
1331
+ i .getClassifiers ().get ("consumption" ) != null ;
1337
1332
}
1338
1333
});
1339
1334
@@ -1349,11 +1344,11 @@ public void onNext(Inference i) {
1349
1344
1350
1345
private Parameters getArrayTestParams () {
1351
1346
Map <String , Map <String , Object >> fieldEncodings = setupMap (
1352
- null ,
1353
- 884 , // n
1354
- 0 , // w
1355
- 0 , 0 , 0 , 0 , null , null , null ,
1356
- "sdr_in" , "darr" , "SDRPassThroughEncoder" );
1347
+ null ,
1348
+ 884 , // n
1349
+ 0 , // w
1350
+ 0 , 0 , 0 , 0 , null , null , null ,
1351
+ "sdr_in" , "darr" , "SDRPassThroughEncoder" );
1357
1352
Parameters p = Parameters .empty ();
1358
1353
p .setParameterByKey (KEY .FIELD_ENCODING_MAP , fieldEncodings );
1359
1354
return p ;
0 commit comments