@Test public void testUnRegisterMapping() { InputOutputOperatorMapping.registerOperator( com.huawei.streaming.cql.toolkits.api.TCPServerInputOperator.class, com.huawei.streaming.cql.toolkits.operators.TCPServerInputOperator.class); assertEquals(InputOutputOperatorMapping.getPlatformOperatorByAPI(com.huawei.streaming.cql.toolkits.api.TCPServerInputOperator.class.getName()), com.huawei.streaming.cql.toolkits.operators.TCPServerInputOperator.class.getName()); InputOutputOperatorMapping.unRegisterMapping(com.huawei.streaming.cql.toolkits.api.TCPServerInputOperator.class); assertNull(InputOutputOperatorMapping.getPlatformOperatorByAPI(com.huawei.streaming.cql.toolkits.api.TCPServerInputOperator.class.getName())); InputOutputOperatorMapping.unRegisterMapping(null); }
public static void unRegisterMapping(Class< ? > apiClass) { if (apiClass == null) { LOG.warn("Failed to unRegister operator mapping, apiClass is null."); return; } String className = apiClass.getName(); LOG.warn("UnRegister '{}' from operator mapping.", className); if (API_PLAT_MAPPING.containsKey(className)) { API_PLAT_MAPPING.remove(className); } }
InputOutputOperatorMapping { public static void unRegisterMapping(Class< ? > apiClass) { if (apiClass == null) { LOG.warn("Failed to unRegister operator mapping, apiClass is null."); return; } String className = apiClass.getName(); LOG.warn("UnRegister '{}' from operator mapping.", className); if (API_PLAT_MAPPING.containsKey(className)) { API_PLAT_MAPPING.remove(className); } } }
InputOutputOperatorMapping { public static void unRegisterMapping(Class< ? > apiClass) { if (apiClass == null) { LOG.warn("Failed to unRegister operator mapping, apiClass is null."); return; } String className = apiClass.getName(); LOG.warn("UnRegister '{}' from operator mapping.", className); if (API_PLAT_MAPPING.containsKey(className)) { API_PLAT_MAPPING.remove(className); } }  }
InputOutputOperatorMapping { public static void unRegisterMapping(Class< ? > apiClass) { if (apiClass == null) { LOG.warn("Failed to unRegister operator mapping, apiClass is null."); return; } String className = apiClass.getName(); LOG.warn("UnRegister '{}' from operator mapping.", className); if (API_PLAT_MAPPING.containsKey(className)) { API_PLAT_MAPPING.remove(className); } }  static String getPlatformOperatorByAPI(String apiOperatorClassName); static String getAPIOperatorByPlatform(String platformClassName); static void registerSerDe(Class< ? extends SerDeAPI > apiClass, Class< ? extends StreamSerDe > serdeClass); static void registerOperator(Class< ? extends Operator > apiClass,
     Class< ? extends IStreamOperator > streamClass); static void registerDataSource(Class< ? extends Operator > apiClass,
     Class< ? extends IDataSource > dataSourceClass); static void unRegisterMapping(Class< ? > apiClass); }
InputOutputOperatorMapping { public static void unRegisterMapping(Class< ? > apiClass) { if (apiClass == null) { LOG.warn("Failed to unRegister operator mapping, apiClass is null."); return; } String className = apiClass.getName(); LOG.warn("UnRegister '{}' from operator mapping.", className); if (API_PLAT_MAPPING.containsKey(className)) { API_PLAT_MAPPING.remove(className); } }  static String getPlatformOperatorByAPI(String apiOperatorClassName); static String getAPIOperatorByPlatform(String platformClassName); static void registerSerDe(Class< ? extends SerDeAPI > apiClass, Class< ? extends StreamSerDe > serdeClass); static void registerOperator(Class< ? extends Operator > apiClass,
     Class< ? extends IStreamOperator > streamClass); static void registerDataSource(Class< ? extends Operator > apiClass,
     Class< ? extends IDataSource > dataSourceClass); static void unRegisterMapping(Class< ? > apiClass);  }