src/main/java/com/google/solutions/df/log/aggregations/common/Util.java [97:111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      Stream.of(
              Schema.Field.of("subscriber_id", FieldType.STRING).withNullable(true),
              Schema.Field.of("dst_subnet", FieldType.STRING).withNullable(true),
              Schema.Field.of("transaction_time", FieldType.STRING).withNullable(true),
              Schema.Field.of("number_of_records", FieldType.INT32).withNullable(true),
              Schema.Field.of("number_of_unique_ips", FieldType.INT32).withNullable(true),
              Schema.Field.of("number_of_unique_ports", FieldType.INT32).withNullable(true),
              Schema.Field.of("max_tx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("min_tx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("avg_tx_bytes", FieldType.DOUBLE).withNullable(true),
              Schema.Field.of("max_rx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("min_rx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("avg_rx_bytes", FieldType.DOUBLE).withNullable(true),
              Schema.Field.of("max_duration", FieldType.INT32).withNullable(true),
              Schema.Field.of("min_duration", FieldType.INT32).withNullable(true),
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/google/solutions/df/log/aggregations/common/Util.java [115:129]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      Stream.of(
              Schema.Field.of("subscriber_id", FieldType.STRING).withNullable(true),
              Schema.Field.of("dst_subnet", FieldType.STRING).withNullable(true),
              Schema.Field.of("transaction_time", FieldType.STRING).withNullable(true),
              Schema.Field.of("number_of_records", FieldType.INT32).withNullable(true),
              Schema.Field.of("number_of_unique_ips", FieldType.INT32).withNullable(true),
              Schema.Field.of("number_of_unique_ports", FieldType.INT32).withNullable(true),
              Schema.Field.of("max_tx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("min_tx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("avg_tx_bytes", FieldType.DOUBLE).withNullable(true),
              Schema.Field.of("max_rx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("min_rx_bytes", FieldType.INT32).withNullable(true),
              Schema.Field.of("avg_rx_bytes", FieldType.DOUBLE).withNullable(true),
              Schema.Field.of("max_duration", FieldType.INT32).withNullable(true),
              Schema.Field.of("min_duration", FieldType.INT32).withNullable(true),
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -