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

Context.getString介绍

[英]Gets value mapped to key, returning null if unmapped.
[中]获取映射到键的值，如果未映射，则返回null。

代码示例

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

@Override
public void configure(Context context) {
 port = Integer.parseInt(context.getString("port"));
 host = context.getString("host");
}

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

@Override
public void configure(Context context) {
 port = Integer.parseInt(context.getString("port"));
 host = context.getString("host");
}

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

@Override
public void configure(Context context) {
 this.commaSeparatedHeaders = context.getString(MANDATORY_PARAMETERS,
                         DEFAULT_MANDATORY_PARAMETERS);
 this.mandatoryHeaders = commaSeparatedHeaders.split(PARAMETER_SEPARATOR);
}

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

public DefaultPathManager(Context context) {
 filePrefix = context.getString(FILE_PREFIX, DEFAULT_FILE_PREFIX);
 extension = context.getString(FILE_EXTENSION, DEFAULT_FILE_EXTENSION);
 seriesTimestamp = System.currentTimeMillis();
 fileIndex = new AtomicInteger();
}

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

protected UUIDInterceptor(Context context) {
 headerName = context.getString(HEADER_NAME, "id");
 preserveExisting = context.getBoolean(PRESERVE_EXISTING_NAME, true);
 prefix = context.getString(PREFIX_NAME, "");
}

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

@Override
public void configure(Context context) {
 syncIntervalBytes =
   context.getInteger(SYNC_INTERVAL_BYTES, DEFAULT_SYNC_INTERVAL_BYTES);
 compressionCodec =
   context.getString(COMPRESSION_CODEC, DEFAULT_COMPRESSION_CODEC);
 staticSchemaURL = context.getString(STATIC_SCHEMA_URL, DEFAULT_STATIC_SCHEMA_URL);
}

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

@Override
public void configure(Context context) {
 String pattern = context.getString("pattern");
 Preconditions.checkArgument(!StringUtils.isEmpty(pattern),
   "Must configure with a valid pattern");
 formatter = DateTimeFormat.forPattern(pattern);
}

代码示例来源：origin: stackoverflow.com

public static String getApplicationName(Context context) {
  ApplicationInfo applicationInfo = context.getApplicationInfo();
  int stringId = applicationInfo.labelRes;
  return stringId == 0 ? applicationInfo.nonLocalizedLabel.toString() : context.getString(stringId);
}

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

/**
 * Sink configurations with Ignite-specific settings.
 *
 * @param context Context for sink.
 */
@Override public void configure(Context context) {
  springCfgPath = context.getString(IgniteSinkConstants.CFG_PATH);
  cacheName = context.getString(IgniteSinkConstants.CFG_CACHE_NAME);
  eventTransformerCls = context.getString(IgniteSinkConstants.CFG_EVENT_TRANSFORMER);
  batchSize = context.getInteger(IgniteSinkConstants.CFG_BATCH_SIZE, DFLT_BATCH_SIZE);
  if (sinkCounter == null)
    sinkCounter = new SinkCounter(getName());
}

代码示例来源：origin: stackoverflow.com

public class MyActivity extends Activity {
  private BroadcastReceiver mBroadcastReceiver = new BroadcastReceiver() {
    @Override
    public void onReceive(Context context, Intent intent) {
      final boolean connected = intent.getBooleanExtra(context.getString(R.string.connected), false);
      if (connected) {
        // Do something.
      }
    }
  };
}

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

@Override
public void configure(Context context) {
 String regexString = context.getString(REGEX, DEFAULT_REGEX);
 regex = Pattern.compile(regexString);
 excludeEvents = context.getBoolean(EXCLUDE_EVENTS,
   DEFAULT_EXCLUDE_EVENTS);
}

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

@Override
 public JMSMessageConverter build(Context context) {
  return new DefaultJMSMessageConverter(context.getString(
    JMSSourceConfiguration.CONVERTER_CHARSET,
    JMSSourceConfiguration.CONVERTER_CHARSET_DEFAULT).trim());
 }
}

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

@Override
public void configure(Context context) {
 String regexString = context.getString(REGEX);
 Preconditions.checkArgument(!StringUtils.isEmpty(regexString),
   "Must supply a valid regex string");
 regex = Pattern.compile(regexString);
 regex.pattern();
 regex.matcher("").groupCount();
 configureSerializers(context);
}

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

@Override
public void configure(Context context) {
 Configurables.ensureRequiredNonNull(
   context, CONFIG_PORT);
 port = context.getInteger(CONFIG_PORT);
 host = context.getString(CONFIG_HOST);
 remoteHostHeader = context.getString(REMOTE_ADDRESS_HEADER);
}

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

@Override
public void configure(Context context) {
 preserveExisting = context.getBoolean(CONFIG_PRESERVE, DEFAULT_PRESERVE);
 header = context.getString(CONFIG_HEADER_NAME, DEFAULT_HEADER_NAME);
}

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

@Override
public void configure(Context context) {
 if (context.getString(FaultTolerance.RECOVERABLE_EXCEPTION_CLASSES) == null) {
  context.put(FaultTolerance.RECOVERABLE_EXCEPTION_CLASSES, 
    "org.apache.solr.client.solrj.SolrServerException");      
 }
 super.configure(context);
}

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

@Override
public void configure(Context context) {
 preserveExisting = context.getBoolean(PRESERVE, PRESERVE_DFLT);
 useIP = context.getBoolean(USE_IP, USE_IP_DFLT);
 header = context.getString(HOST_HEADER, HOST);
}

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

@Override
public void configure(Context context) {
 super.configure(context);
 serializerType = context.getString("serializer", "TEXT");
 useRawLocalFileSystem = context.getBoolean("hdfs.useRawLocalFileSystem",
   false);
 serializerContext =
   new Context(context.getSubProperties(EventSerializer.CTX_PREFIX));
 logger.info("Serializer = " + serializerType + ", UseRawLocalFileSystem = "
   + useRawLocalFileSystem);
}

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

@Override
public void configure(Context context) {
 super.configure(context);
 serializerType = context.getString("serializer", "TEXT");
 useRawLocalFileSystem = context.getBoolean("hdfs.useRawLocalFileSystem",
   false);
 serializerContext = new Context(
   context.getSubProperties(EventSerializer.CTX_PREFIX));
 logger.info("Serializer = " + serializerType + ", UseRawLocalFileSystem = "
   + useRawLocalFileSystem);
}

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

@Override
public void configure(Context context) {
 this.pollFrequency = context.getInteger(this.CONF_POLL_FREQUENCY, 60);
 String localHosts = context.getString(this.CONF_HOSTS);
 if (localHosts == null || localHosts.isEmpty()) {
  throw new ConfigurationException("Hosts list cannot be empty.");
 }
 this.hosts = this.getHostsFromString(localHosts);
 this.isGanglia3 = context.getBoolean(this.CONF_ISGANGLIA3, false);
}