@SuppressWarnings("deprecation") @Test public void hasNewNetworkBufConfOld() throws Exception { Configuration config = new Configuration(); config.setInteger(TaskManagerOptions.NETWORK_NUM_BUFFERS, 1); assertFalse(TaskManagerServicesConfiguration.hasNewNetworkBufConf(config)); }
@SuppressWarnings("deprecation") public static boolean hasNewNetworkBufConf(final Configuration config) { return config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX) || !config.contains(TaskManagerOptions.NETWORK_NUM_BUFFERS); }
TaskManagerServicesConfiguration { @SuppressWarnings("deprecation") public static boolean hasNewNetworkBufConf(final Configuration config) { return config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX) || !config.contains(TaskManagerOptions.NETWORK_NUM_BUFFERS); } }
TaskManagerServicesConfiguration { @SuppressWarnings("deprecation") public static boolean hasNewNetworkBufConf(final Configuration config) { return config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX) || !config.contains(TaskManagerOptions.NETWORK_NUM_BUFFERS); } TaskManagerServicesConfiguration(
			InetAddress taskManagerAddress,
			String[] tmpDirPaths,
			String[] localRecoveryStateRootDirectories,
			boolean localRecoveryEnabled,
			NetworkEnvironmentConfiguration networkConfig,
			@Nullable QueryableStateConfiguration queryableStateConfig,
			int numberOfSlots,
			long configuredMemory,
			MemoryType memoryType,
			boolean preAllocateMemory,
			float memoryFraction,
			long timerServiceShutdownTimeout,
			RetryingRegistrationConfiguration retryingRegistrationConfiguration,
			Optional<Time> systemResourceMetricsProbingInterval); }
TaskManagerServicesConfiguration { @SuppressWarnings("deprecation") public static boolean hasNewNetworkBufConf(final Configuration config) { return config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX) || !config.contains(TaskManagerOptions.NETWORK_NUM_BUFFERS); } TaskManagerServicesConfiguration(
			InetAddress taskManagerAddress,
			String[] tmpDirPaths,
			String[] localRecoveryStateRootDirectories,
			boolean localRecoveryEnabled,
			NetworkEnvironmentConfiguration networkConfig,
			@Nullable QueryableStateConfiguration queryableStateConfig,
			int numberOfSlots,
			long configuredMemory,
			MemoryType memoryType,
			boolean preAllocateMemory,
			float memoryFraction,
			long timerServiceShutdownTimeout,
			RetryingRegistrationConfiguration retryingRegistrationConfiguration,
			Optional<Time> systemResourceMetricsProbingInterval); InetAddress getTaskManagerAddress(); String[] getTmpDirPaths(); String[] getLocalRecoveryStateRootDirectories(); boolean isLocalRecoveryEnabled(); NetworkEnvironmentConfiguration getNetworkConfig(); QueryableStateConfiguration getQueryableStateConfig(); int getNumberOfSlots(); float getMemoryFraction(); MemoryType getMemoryType(); long getConfiguredMemory(); boolean isPreAllocateMemory(); long getTimerServiceShutdownTimeout(); Optional<Time> getSystemResourceMetricsProbingInterval(); RetryingRegistrationConfiguration getRetryingRegistrationConfiguration(); static TaskManagerServicesConfiguration fromConfiguration(
			Configuration configuration,
			InetAddress remoteAddress,
			boolean localCommunication); @SuppressWarnings("deprecation") static boolean hasNewNetworkBufConf(final Configuration config); }
TaskManagerServicesConfiguration { @SuppressWarnings("deprecation") public static boolean hasNewNetworkBufConf(final Configuration config) { return config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN) || config.contains(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX) || !config.contains(TaskManagerOptions.NETWORK_NUM_BUFFERS); } TaskManagerServicesConfiguration(
			InetAddress taskManagerAddress,
			String[] tmpDirPaths,
			String[] localRecoveryStateRootDirectories,
			boolean localRecoveryEnabled,
			NetworkEnvironmentConfiguration networkConfig,
			@Nullable QueryableStateConfiguration queryableStateConfig,
			int numberOfSlots,
			long configuredMemory,
			MemoryType memoryType,
			boolean preAllocateMemory,
			float memoryFraction,
			long timerServiceShutdownTimeout,
			RetryingRegistrationConfiguration retryingRegistrationConfiguration,
			Optional<Time> systemResourceMetricsProbingInterval); InetAddress getTaskManagerAddress(); String[] getTmpDirPaths(); String[] getLocalRecoveryStateRootDirectories(); boolean isLocalRecoveryEnabled(); NetworkEnvironmentConfiguration getNetworkConfig(); QueryableStateConfiguration getQueryableStateConfig(); int getNumberOfSlots(); float getMemoryFraction(); MemoryType getMemoryType(); long getConfiguredMemory(); boolean isPreAllocateMemory(); long getTimerServiceShutdownTimeout(); Optional<Time> getSystemResourceMetricsProbingInterval(); RetryingRegistrationConfiguration getRetryingRegistrationConfiguration(); static TaskManagerServicesConfiguration fromConfiguration(
			Configuration configuration,
			InetAddress remoteAddress,
			boolean localCommunication); @SuppressWarnings("deprecation") static boolean hasNewNetworkBufConf(final Configuration config);  }