本文整理了Java中org.apache.flume.Context.getParameters()方法的一些代码示例，展示了Context.getParameters()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Context.getParameters()方法的具体详情如下：
包路径：org.apache.flume.Context
类名称：Context
方法名：getParameters

Context.getParameters介绍

[英]Gets a copy of the backing map structure.
[中]获取备份映射结构的副本。

代码示例

代码示例来源：origin: apache/flume

public static void ensureRequiredNonNull(Context context, String... keys) {
 for (String key : keys) {
  if (!context.getParameters().containsKey(key)
    || context.getParameters().get(key) == null) {
   throw new IllegalArgumentException("Required parameter " + key
     + " must exist and may not be null");
  }
 }
}

代码示例来源：origin: apache/flume

public static void ensureOptionalNonNull(Context context, String... keys) {
 for (String key : keys) {
  if (context.getParameters().containsKey(key)
    && context.getParameters().get(key) == null) {
   throw new IllegalArgumentException("Optional parameter " + key
     + " may not be null");
  }
 }
}

代码示例来源：origin: apache/flume

private void runFiltersOnContextMaps(Map<String, Context>... maps) {
 for (Map<String, Context> map: maps) {
  for (Context context : map.values()) {
   for (String key : context.getParameters().keySet()) {
    filterValue(context, key);
   }
  }
 }
}

代码示例来源：origin: apache/flume

@Override
public void configure(Context context) {
 clientProps = new Properties();
 hostname = context.getString("hostname");
 port = context.getInteger("port");
 Preconditions.checkState(hostname != null, "No hostname specified");
 Preconditions.checkState(port != null, "No port specified");
 clientProps.setProperty(RpcClientConfigurationConstants.CONFIG_HOSTS, "h1");
 clientProps.setProperty(RpcClientConfigurationConstants.CONFIG_HOSTS_PREFIX +
   "h1", hostname + ":" + port);
 for (Entry<String, String> entry: context.getParameters().entrySet()) {
  clientProps.setProperty(entry.getKey(), entry.getValue());
 }
 batchSize = AbstractRpcClient.parseBatchSize(clientProps);
 if (sinkCounter == null) {
  sinkCounter = new SinkCounter(getName());
 }
 cxnResetInterval = context.getInteger("reset-connection-interval",
  DEFAULT_CXN_RESET_INTERVAL);
 if (cxnResetInterval == DEFAULT_CXN_RESET_INTERVAL) {
  logger.info("Connection reset is set to " + String.valueOf(DEFAULT_CXN_RESET_INTERVAL) +
        ". Will not reset connection to next hop");
 }
}

代码示例来源：origin: apache/flume

Preconditions.checkNotNull(sinks);
Preconditions.checkArgument(!sinks.isEmpty());
Map<String, String> params = context.getParameters();
SinkProcessor processor;
String typeStr = params.get(TYPE);

代码示例来源：origin: apache/flume

private void createConfigFilters() {
 for (String name: configFilterSet) {
  Context context = configFilterContextMap.get(name);
  ComponentConfiguration componentConfiguration = configFilterConfigMap.get(name);
  try {
   if (context != null) {
    ConfigFilter configFilter = ConfigFilterFactory.create(
      name, context.getString(BasicConfigurationConstants.CONFIG_TYPE)
    );
    configFilter.initializeWithConfiguration(context.getParameters());
    configFiltersInstances.add(configFilter);
    configFilterPatternCache.put(configFilter.getName(),
      createConfigFilterPattern(configFilter));
   } else if (componentConfiguration != null) {
    ConfigFilter configFilter = ConfigFilterFactory.create(
      componentConfiguration.getComponentName(), componentConfiguration.getType()
    );
    configFiltersInstances.add(configFilter);
    configFilterPatternCache.put(configFilter.getName(), 
      createConfigFilterPattern(configFilter));
   }
  } catch (Exception e) {
   LOGGER.error("Error while creating config filter {}", name, e);
  }
 }
}

代码示例来源：origin: org.apache.flume/flume-ng-core

public static void ensureRequiredNonNull(Context context, String... keys) {
 for (String key : keys) {
  if (!context.getParameters().containsKey(key)
    || context.getParameters().get(key) == null) {
   throw new IllegalArgumentException("Required parameter " + key
     + " must exist and may not be null");
  }
 }
}

代码示例来源：origin: org.apache.flume/flume-ng-core

public static void ensureOptionalNonNull(Context context, String... keys) {
 for (String key : keys) {
  if (context.getParameters().containsKey(key)
    && context.getParameters().get(key) == null) {
   throw new IllegalArgumentException("Optional parameter " + key
     + " may not be null");
  }
 }
}

代码示例来源：origin: org.apache.flume/flume-ng-configuration

private void runFiltersOnContextMaps(Map<String, Context>... maps) {
 for (Map<String, Context> map: maps) {
  for (Context context : map.values()) {
   for (String key : context.getParameters().keySet()) {
    filterValue(context, key);
   }
  }
 }
}

代码示例来源：origin: org.apache.flume/flume-ng-core

@Override
public void configure(Context context) {
 clientProps = new Properties();
 hostname = context.getString("hostname");
 port = context.getInteger("port");
 Preconditions.checkState(hostname != null, "No hostname specified");
 Preconditions.checkState(port != null, "No port specified");
 clientProps.setProperty(RpcClientConfigurationConstants.CONFIG_HOSTS, "h1");
 clientProps.setProperty(RpcClientConfigurationConstants.CONFIG_HOSTS_PREFIX +
   "h1", hostname + ":" + port);
 for (Entry<String, String> entry: context.getParameters().entrySet()) {
  clientProps.setProperty(entry.getKey(), entry.getValue());
 }
 batchSize = AbstractRpcClient.parseBatchSize(clientProps);
 if (sinkCounter == null) {
  sinkCounter = new SinkCounter(getName());
 }
 cxnResetInterval = context.getInteger("reset-connection-interval",
  DEFAULT_CXN_RESET_INTERVAL);
 if (cxnResetInterval == DEFAULT_CXN_RESET_INTERVAL) {
  logger.info("Connection reset is set to " + String.valueOf(DEFAULT_CXN_RESET_INTERVAL) +
        ". Will not reset connection to next hop");
 }
}

代码示例来源：origin: thilinamb/flume-ng-kafka-sink

Map<String, String> params = context.getParameters();
producerProps = new Properties();
for (String key : params.keySet()) {

代码示例来源：origin: org.apache.flume/flume-ng-core

Preconditions.checkNotNull(sinks);
Preconditions.checkArgument(!sinks.isEmpty());
Map<String, String> params = context.getParameters();
SinkProcessor processor;
String typeStr = params.get(TYPE);

代码示例来源：origin: org.apache.flume/flume-ng-configuration

private void createConfigFilters() {
 for (String name: configFilterSet) {
  Context context = configFilterContextMap.get(name);
  ComponentConfiguration componentConfiguration = configFilterConfigMap.get(name);
  try {
   if (context != null) {
    ConfigFilter configFilter = ConfigFilterFactory.create(
      name, context.getString(BasicConfigurationConstants.CONFIG_TYPE)
    );
    configFilter.initializeWithConfiguration(context.getParameters());
    configFiltersInstances.add(configFilter);
    configFilterPatternCache.put(configFilter.getName(),
      createConfigFilterPattern(configFilter));
   } else if (componentConfiguration != null) {
    ConfigFilter configFilter = ConfigFilterFactory.create(
      componentConfiguration.getComponentName(), componentConfiguration.getType()
    );
    configFiltersInstances.add(configFilter);
    configFilterPatternCache.put(configFilter.getName(), 
      createConfigFilterPattern(configFilter));
   }
  } catch (Exception e) {
   LOGGER.error("Error while creating config filter {}", name, e);
  }
 }
}