本文整理了Java中org.apache.flume.Context.getParameters()
方法的一些代码示例,展示了Context.getParameters()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Context.getParameters()
方法的具体详情如下:
包路径:org.apache.flume.Context
类名称: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);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!