< prev index next >

core/org.openjdk.jmc.flightrecorder/src/main/java/org/openjdk/jmc/flightrecorder/jdk/JdkAggregators.java

Print this page




 210                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "UnlockExperimentalVMOptions")); //$NON-NLS-1$
 211         public static final IAggregator<Boolean, ?> IGNORE_UNRECOGNIZED_VM_OPTIONS = filter(
 212                         Messages.getString(Messages.AGGR_IGNORE_UNRECOGNIZED_VM_OPTIONS), null,
 213                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "IgnoreUnrecognizedVMOptions")); //$NON-NLS-1$
 214         public static final IAggregator<Boolean, ?> USE_STRING_DEDUPLICATION = filter("UseStringDeduplication", null, //$NON-NLS-1$
 215                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "UseStringDeduplication")); //$NON-NLS-1$
 216         public static final IAggregator<Boolean, ?> USE_G1_GC = filter("UseG1GC", null, //$NON-NLS-1$
 217                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "UseG1GC")); //$NON-NLS-1$
 218         public static final IAggregator<Boolean, ?> COMPACT_STRINGS = filter("CompactStrings", null, //$NON-NLS-1$
 219                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "CompactStrings")); //$NON-NLS-1$
 220         public static final IAggregator<IQuantity, ?> LARGEST_MAX_HEAP_SIZE_FROM_FLAG = filter(
 221                         Messages.getString(Messages.AGGR_LARGEST_MAX_HEAP_SIZE_FROM_FLAG), null, max(ULONG_FLAG, FLAG_VALUE_NUMBER),
 222                         ItemFilters.equals(FLAG_NAME, "MaxHeapSize")); //$NON-NLS-1$
 223         public static final IAggregator<IQuantity, ?> OUTSIDE_TLAB_COUNT = Aggregators.count(
 224                         Messages.getString(Messages.AGGR_OUTSIDE_TLAB_COUNT),
 225                         Messages.getString(Messages.AGGR_OUTSIDE_TLAB_COUNT_DESC), ALLOC_OUTSIDE_TLAB);
 226         public static final IAggregator<IQuantity, ?> INSIDE_TLAB_COUNT = Aggregators.count(
 227                         Messages.getString(Messages.AGGR_INSIDE_TLAB_COUNT),
 228                         Messages.getString(Messages.AGGR_INSIDE_TLAB_COUNT_DESC), ALLOC_INSIDE_TLAB);
 229         public static final IAggregator<IQuantity, ?> FILE_WRITE_LONGEST = Aggregators.max(FILE_WRITE, DURATION);


 230         public static final IAggregator<IQuantity, ?> FILE_READ_LONGEST = Aggregators.max(FILE_READ, DURATION);


 231         public static final IAggregator<IQuantity, ?> FILE_WRITE_SIZE = Aggregators.sum(
 232                         Messages.getString(Messages.AGGR_FILE_WRITE_SIZE), Messages.getString(Messages.AGGR_FILE_WRITE_SIZE_DESC),
 233                         FILE_WRITE, IO_FILE_BYTES_WRITTEN);
 234         public static final IAggregator<IQuantity, ?> FILE_READ_SIZE = Aggregators.sum(
 235                         Messages.getString(Messages.AGGR_FILE_READ_SIZE), Messages.getString(Messages.AGGR_FILE_READ_SIZE_DESC),
 236                         FILE_READ, IO_FILE_BYTES_READ);
 237         public static final IAggregator<IQuantity, ?> FILE_WRITE_COUNT = Aggregators.count(
 238                         Messages.getString(Messages.AGGR_FILE_WRITE_COUNT), Messages.getString(Messages.AGGR_FILE_WRITE_COUNT_DESC),
 239                         JdkFilters.FILE_WRITE);
 240         public static final IAggregator<IQuantity, ?> FILE_READ_COUNT = Aggregators.count(
 241                         Messages.getString(Messages.AGGR_FILE_READ_COUNT), Messages.getString(Messages.AGGR_FILE_READ_COUNT_DESC),
 242                         JdkFilters.FILE_READ);
 243         public static final IAggregator<IQuantity, ?> ERROR_COUNT = Aggregators.count(
 244                         Messages.getString(Messages.AGGR_ERROR_COUNT), Messages.getString(Messages.AGGR_ERROR_COUNT_DESC),
 245                         JdkFilters.ERRORS);
 246         public static final IAggregator<IQuantity, ?> EXCEPTIONS_COUNT = Aggregators.count(
 247                         Messages.getString(Messages.AGGR_EXCEPTIONS_COUNT), Messages.getString(Messages.AGGR_EXCEPTIONS_COUNT_DESC),
 248                         JdkFilters.EXCEPTIONS);
 249         public static final IAggregator<IQuantity, ?> THROWABLES_COUNT = Aggregators.count(
 250                         Messages.getString(Messages.AGGR_THROWABLES_COUNT), Messages.getString(Messages.AGGR_THROWABLES_COUNT_DESC),
 251                         JdkFilters.THROWABLES);
 252         public static final IAggregator<IQuantity, ?> CODE_CACHE_FULL_COUNT = Aggregators.count(
 253                         Messages.getString(Messages.AGGR_CODE_CACHE_FULL_COUNT),
 254                         Messages.getString(Messages.AGGR_CODE_CACHE_FULL_COUNT_DESC), CODE_CACHE_FULL);
 255         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_LONGEST = Aggregators.max(SOCKET_WRITE, DURATION);

 256         public static final IAggregator<IQuantity, ?> SOCKET_READ_LONGEST = Aggregators.max(SOCKET_READ, DURATION);


 257         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_SIZE = Aggregators.sum(
 258                         Messages.getString(Messages.AGGR_SOCKET_WRITE_SIZE),
 259                         Messages.getString(Messages.AGGR_SOCKET_WRITE_SIZE_DESC), SOCKET_WRITE, IO_SOCKET_BYTES_WRITTEN);
 260         public static final IAggregator<IQuantity, ?> SOCKET_READ_SIZE = Aggregators.sum(
 261                         Messages.getString(Messages.AGGR_SOCKET_READ_SIZE), Messages.getString(Messages.AGGR_SOCKET_READ_SIZE_DESC),
 262                         SOCKET_READ, IO_SOCKET_BYTES_READ);
 263         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_COUNT = Aggregators.count(
 264                         Messages.getString(Messages.AGGR_SOCKET_WRITE_COUNT),
 265                         Messages.getString(Messages.AGGR_SOCKET_WRITE_COUNT_DESC), JdkFilters.SOCKET_WRITE);
 266         public static final IAggregator<IQuantity, ?> SOCKET_READ_COUNT = Aggregators.count(
 267                         Messages.getString(Messages.AGGR_SOCKET_READ_COUNT),
 268                         Messages.getString(Messages.AGGR_SOCKET_READ_COUNT_DESC), JdkFilters.SOCKET_READ);
 269         public static final IAggregator<IQuantity, ?> NUMBER_OF_DISTINCT_PORTS = Aggregators
 270                         .filter(Aggregators.countDistinct(Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_PORTS),
 271                                         Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_PORTS_DESC), IO_PORT), SOCKET_READ_OR_WRITE);
 272         public static final IAggregator<IQuantity, ?> NUMBER_OF_DISTINCT_HOSTS = Aggregators
 273                         .filter(Aggregators.countDistinct(Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_HOSTS),
 274                                         Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_HOSTS_DESC), IO_ADDRESS), SOCKET_READ_OR_WRITE);
 275         public static final IAggregator<String, ?> HOST_NAMES_DISTINCT = Aggregators
 276                         .filter(Aggregators.distinctAsString(IO_HOST, ","), SOCKET_READ_OR_WRITE); //$NON-NLS-1$




 210                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "UnlockExperimentalVMOptions")); //$NON-NLS-1$
 211         public static final IAggregator<Boolean, ?> IGNORE_UNRECOGNIZED_VM_OPTIONS = filter(
 212                         Messages.getString(Messages.AGGR_IGNORE_UNRECOGNIZED_VM_OPTIONS), null,
 213                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "IgnoreUnrecognizedVMOptions")); //$NON-NLS-1$
 214         public static final IAggregator<Boolean, ?> USE_STRING_DEDUPLICATION = filter("UseStringDeduplication", null, //$NON-NLS-1$
 215                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "UseStringDeduplication")); //$NON-NLS-1$
 216         public static final IAggregator<Boolean, ?> USE_G1_GC = filter("UseG1GC", null, //$NON-NLS-1$
 217                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "UseG1GC")); //$NON-NLS-1$
 218         public static final IAggregator<Boolean, ?> COMPACT_STRINGS = filter("CompactStrings", null, //$NON-NLS-1$
 219                         or(BOOLEAN_FLAG, FLAG_VALUE_BOOLEAN), ItemFilters.equals(FLAG_NAME, "CompactStrings")); //$NON-NLS-1$
 220         public static final IAggregator<IQuantity, ?> LARGEST_MAX_HEAP_SIZE_FROM_FLAG = filter(
 221                         Messages.getString(Messages.AGGR_LARGEST_MAX_HEAP_SIZE_FROM_FLAG), null, max(ULONG_FLAG, FLAG_VALUE_NUMBER),
 222                         ItemFilters.equals(FLAG_NAME, "MaxHeapSize")); //$NON-NLS-1$
 223         public static final IAggregator<IQuantity, ?> OUTSIDE_TLAB_COUNT = Aggregators.count(
 224                         Messages.getString(Messages.AGGR_OUTSIDE_TLAB_COUNT),
 225                         Messages.getString(Messages.AGGR_OUTSIDE_TLAB_COUNT_DESC), ALLOC_OUTSIDE_TLAB);
 226         public static final IAggregator<IQuantity, ?> INSIDE_TLAB_COUNT = Aggregators.count(
 227                         Messages.getString(Messages.AGGR_INSIDE_TLAB_COUNT),
 228                         Messages.getString(Messages.AGGR_INSIDE_TLAB_COUNT_DESC), ALLOC_INSIDE_TLAB);
 229         public static final IAggregator<IQuantity, ?> FILE_WRITE_LONGEST = Aggregators.max(FILE_WRITE, DURATION);
 230         public static final IAggregator<IQuantity, ?> FILE_WRITE_LARGEST = Aggregators.max(FILE_WRITE, IO_FILE_BYTES_WRITTEN);
 231 
 232         public static final IAggregator<IQuantity, ?> FILE_READ_LONGEST = Aggregators.max(FILE_READ, DURATION);
 233         public static final IAggregator<IQuantity, ?> FILE_READ_LARGEST = Aggregators.max(FILE_READ, IO_FILE_BYTES_READ);
 234 
 235         public static final IAggregator<IQuantity, ?> FILE_WRITE_SIZE = Aggregators.sum(
 236                         Messages.getString(Messages.AGGR_FILE_WRITE_SIZE), Messages.getString(Messages.AGGR_FILE_WRITE_SIZE_DESC),
 237                         FILE_WRITE, IO_FILE_BYTES_WRITTEN);
 238         public static final IAggregator<IQuantity, ?> FILE_READ_SIZE = Aggregators.sum(
 239                         Messages.getString(Messages.AGGR_FILE_READ_SIZE), Messages.getString(Messages.AGGR_FILE_READ_SIZE_DESC),
 240                         FILE_READ, IO_FILE_BYTES_READ);
 241         public static final IAggregator<IQuantity, ?> FILE_WRITE_COUNT = Aggregators.count(
 242                         Messages.getString(Messages.AGGR_FILE_WRITE_COUNT), Messages.getString(Messages.AGGR_FILE_WRITE_COUNT_DESC),
 243                         JdkFilters.FILE_WRITE);
 244         public static final IAggregator<IQuantity, ?> FILE_READ_COUNT = Aggregators.count(
 245                         Messages.getString(Messages.AGGR_FILE_READ_COUNT), Messages.getString(Messages.AGGR_FILE_READ_COUNT_DESC),
 246                         JdkFilters.FILE_READ);
 247         public static final IAggregator<IQuantity, ?> ERROR_COUNT = Aggregators.count(
 248                         Messages.getString(Messages.AGGR_ERROR_COUNT), Messages.getString(Messages.AGGR_ERROR_COUNT_DESC),
 249                         JdkFilters.ERRORS);
 250         public static final IAggregator<IQuantity, ?> EXCEPTIONS_COUNT = Aggregators.count(
 251                         Messages.getString(Messages.AGGR_EXCEPTIONS_COUNT), Messages.getString(Messages.AGGR_EXCEPTIONS_COUNT_DESC),
 252                         JdkFilters.EXCEPTIONS);
 253         public static final IAggregator<IQuantity, ?> THROWABLES_COUNT = Aggregators.count(
 254                         Messages.getString(Messages.AGGR_THROWABLES_COUNT), Messages.getString(Messages.AGGR_THROWABLES_COUNT_DESC),
 255                         JdkFilters.THROWABLES);
 256         public static final IAggregator<IQuantity, ?> CODE_CACHE_FULL_COUNT = Aggregators.count(
 257                         Messages.getString(Messages.AGGR_CODE_CACHE_FULL_COUNT),
 258                         Messages.getString(Messages.AGGR_CODE_CACHE_FULL_COUNT_DESC), CODE_CACHE_FULL);
 259         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_LONGEST = Aggregators.max(SOCKET_WRITE, DURATION);
 260         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_LARGEST = Aggregators.max(SOCKET_WRITE, IO_SOCKET_BYTES_WRITTEN);
 261         public static final IAggregator<IQuantity, ?> SOCKET_READ_LONGEST = Aggregators.max(SOCKET_READ, DURATION);
 262         public static final IAggregator<IQuantity, ?> SOCKET_READ_LARGEST = Aggregators.max(SOCKET_READ, IO_SOCKET_BYTES_READ);
 263 
 264         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_SIZE = Aggregators.sum(
 265                         Messages.getString(Messages.AGGR_SOCKET_WRITE_SIZE),
 266                         Messages.getString(Messages.AGGR_SOCKET_WRITE_SIZE_DESC), SOCKET_WRITE, IO_SOCKET_BYTES_WRITTEN);
 267         public static final IAggregator<IQuantity, ?> SOCKET_READ_SIZE = Aggregators.sum(
 268                         Messages.getString(Messages.AGGR_SOCKET_READ_SIZE), Messages.getString(Messages.AGGR_SOCKET_READ_SIZE_DESC),
 269                         SOCKET_READ, IO_SOCKET_BYTES_READ);
 270         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_COUNT = Aggregators.count(
 271                         Messages.getString(Messages.AGGR_SOCKET_WRITE_COUNT),
 272                         Messages.getString(Messages.AGGR_SOCKET_WRITE_COUNT_DESC), JdkFilters.SOCKET_WRITE);
 273         public static final IAggregator<IQuantity, ?> SOCKET_READ_COUNT = Aggregators.count(
 274                         Messages.getString(Messages.AGGR_SOCKET_READ_COUNT),
 275                         Messages.getString(Messages.AGGR_SOCKET_READ_COUNT_DESC), JdkFilters.SOCKET_READ);
 276         public static final IAggregator<IQuantity, ?> NUMBER_OF_DISTINCT_PORTS = Aggregators
 277                         .filter(Aggregators.countDistinct(Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_PORTS),
 278                                         Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_PORTS_DESC), IO_PORT), SOCKET_READ_OR_WRITE);
 279         public static final IAggregator<IQuantity, ?> NUMBER_OF_DISTINCT_HOSTS = Aggregators
 280                         .filter(Aggregators.countDistinct(Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_HOSTS),
 281                                         Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_HOSTS_DESC), IO_ADDRESS), SOCKET_READ_OR_WRITE);
 282         public static final IAggregator<String, ?> HOST_NAMES_DISTINCT = Aggregators
 283                         .filter(Aggregators.distinctAsString(IO_HOST, ","), SOCKET_READ_OR_WRITE); //$NON-NLS-1$


< prev index next >