< 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         public static final IAggregator<IQuantity, ?> FILE_READ_LONGEST = Aggregators.max(FILE_READ, DURATION);
 232         public static final IAggregator<IQuantity, ?> FILE_READ_LARGEST = Aggregators.max(FILE_READ, IO_FILE_BYTES_READ);
 233         public static final IAggregator<IQuantity, ?> FILE_WRITE_SIZE = Aggregators.sum(
 234                         Messages.getString(Messages.AGGR_FILE_WRITE_SIZE), Messages.getString(Messages.AGGR_FILE_WRITE_SIZE_DESC),
 235                         FILE_WRITE, IO_FILE_BYTES_WRITTEN);
 236         public static final IAggregator<IQuantity, ?> FILE_READ_SIZE = Aggregators.sum(
 237                         Messages.getString(Messages.AGGR_FILE_READ_SIZE), Messages.getString(Messages.AGGR_FILE_READ_SIZE_DESC),
 238                         FILE_READ, IO_FILE_BYTES_READ);
 239         public static final IAggregator<IQuantity, ?> FILE_WRITE_COUNT = Aggregators.count(
 240                         Messages.getString(Messages.AGGR_FILE_WRITE_COUNT), Messages.getString(Messages.AGGR_FILE_WRITE_COUNT_DESC),
 241                         JdkFilters.FILE_WRITE);
 242         public static final IAggregator<IQuantity, ?> FILE_READ_COUNT = Aggregators.count(
 243                         Messages.getString(Messages.AGGR_FILE_READ_COUNT), Messages.getString(Messages.AGGR_FILE_READ_COUNT_DESC),
 244                         JdkFilters.FILE_READ);
 245         public static final IAggregator<IQuantity, ?> ERROR_COUNT = Aggregators.count(
 246                         Messages.getString(Messages.AGGR_ERROR_COUNT), Messages.getString(Messages.AGGR_ERROR_COUNT_DESC),
 247                         JdkFilters.ERRORS);
 248         public static final IAggregator<IQuantity, ?> EXCEPTIONS_COUNT = Aggregators.count(
 249                         Messages.getString(Messages.AGGR_EXCEPTIONS_COUNT), Messages.getString(Messages.AGGR_EXCEPTIONS_COUNT_DESC),
 250                         JdkFilters.EXCEPTIONS);
 251         public static final IAggregator<IQuantity, ?> THROWABLES_COUNT = Aggregators.count(
 252                         Messages.getString(Messages.AGGR_THROWABLES_COUNT), Messages.getString(Messages.AGGR_THROWABLES_COUNT_DESC),
 253                         JdkFilters.THROWABLES);
 254         public static final IAggregator<IQuantity, ?> CODE_CACHE_FULL_COUNT = Aggregators.count(
 255                         Messages.getString(Messages.AGGR_CODE_CACHE_FULL_COUNT),
 256                         Messages.getString(Messages.AGGR_CODE_CACHE_FULL_COUNT_DESC), CODE_CACHE_FULL);
 257         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_LONGEST = Aggregators.max(SOCKET_WRITE, DURATION);
 258         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_LARGEST = Aggregators.max(SOCKET_WRITE, IO_SOCKET_BYTES_WRITTEN);
 259         public static final IAggregator<IQuantity, ?> SOCKET_READ_LONGEST = Aggregators.max(SOCKET_READ, DURATION);
 260         public static final IAggregator<IQuantity, ?> SOCKET_READ_LARGEST = Aggregators.max(SOCKET_READ, IO_SOCKET_BYTES_READ);
 261         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_SIZE = Aggregators.sum(
 262                         Messages.getString(Messages.AGGR_SOCKET_WRITE_SIZE),
 263                         Messages.getString(Messages.AGGR_SOCKET_WRITE_SIZE_DESC), SOCKET_WRITE, IO_SOCKET_BYTES_WRITTEN);
 264         public static final IAggregator<IQuantity, ?> SOCKET_READ_SIZE = Aggregators.sum(
 265                         Messages.getString(Messages.AGGR_SOCKET_READ_SIZE), Messages.getString(Messages.AGGR_SOCKET_READ_SIZE_DESC),
 266                         SOCKET_READ, IO_SOCKET_BYTES_READ);
 267         public static final IAggregator<IQuantity, ?> SOCKET_WRITE_COUNT = Aggregators.count(
 268                         Messages.getString(Messages.AGGR_SOCKET_WRITE_COUNT),
 269                         Messages.getString(Messages.AGGR_SOCKET_WRITE_COUNT_DESC), JdkFilters.SOCKET_WRITE);
 270         public static final IAggregator<IQuantity, ?> SOCKET_READ_COUNT = Aggregators.count(
 271                         Messages.getString(Messages.AGGR_SOCKET_READ_COUNT),
 272                         Messages.getString(Messages.AGGR_SOCKET_READ_COUNT_DESC), JdkFilters.SOCKET_READ);
 273         public static final IAggregator<IQuantity, ?> NUMBER_OF_DISTINCT_PORTS = Aggregators
 274                         .filter(Aggregators.countDistinct(Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_PORTS),
 275                                         Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_PORTS_DESC), IO_PORT), SOCKET_READ_OR_WRITE);
 276         public static final IAggregator<IQuantity, ?> NUMBER_OF_DISTINCT_HOSTS = Aggregators
 277                         .filter(Aggregators.countDistinct(Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_HOSTS),
 278                                         Messages.getString(Messages.AGGR_NUMBER_OF_DISTINCT_HOSTS_DESC), IO_ADDRESS), SOCKET_READ_OR_WRITE);
 279         public static final IAggregator<String, ?> HOST_NAMES_DISTINCT = Aggregators
 280                         .filter(Aggregators.distinctAsString(IO_HOST, ","), SOCKET_READ_OR_WRITE); //$NON-NLS-1$


< prev index next >