com.hurence.logisland.component.PropertyValue.isSet()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(60)

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

PropertyValue.isSet介绍

暂无

代码示例

代码示例来源：origin: com.hurence.logisland/logisland-hbase-plugin

@Override
protected Collection<ValidationResult> customValidate(ValidationContext validationContext) {
  final boolean isAvroSerializer = validationContext.getPropertyValue(RECORD_SERIALIZER).asString().toLowerCase().contains("avro");
  final boolean isAvroSchemaSet = validationContext.getPropertyValue(RECORD_SCHEMA).isSet();
  final List<ValidationResult> problems = new ArrayList<>();
  if (isAvroSerializer && !isAvroSchemaSet) {
    problems.add(new ValidationResult.Builder()
        .subject(RECORD_SERIALIZER.getDisplayName())
        .valid(false)
        .explanation("an avro schema must be provided with an avro serializer")
        .build());
  }
  return problems;
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

if (!context.getPropertyValue(MAIL_TO).isSet())
if ( (context.getPropertyValue(SMTP_SECURITY_USERNAME).isSet() && !context.getPropertyValue(SMTP_SECURITY_PASSWORD).isSet())
    || (!context.getPropertyValue(SMTP_SECURITY_USERNAME).isSet() && context.getPropertyValue(SMTP_SECURITY_PASSWORD).isSet()))

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

@Override
protected Collection<ValidationResult> customValidate(ValidationContext context) {
  final List<ValidationResult> validationResults = new ArrayList<>(super.customValidate(context));
  if (context.getPropertyValue(STRATEGY).isSet()) {
    if (context.getPropertyValue(STRATEGY).getRawValue().equals(JAVA_FORMAT_STRING_WITH_FIELDS_STRATEGY.getValue())) {
      if (!context.getPropertyValue(JAVA_FORMAT_STRING).isSet()) {
        validationResults.add(
            new ValidationResult.Builder()
                .input(JAVA_FORMAT_STRING.getName())
                .explanation(String.format("%s must be set when strategy is %s",
                    JAVA_FORMAT_STRING.getName(),
                    context.getPropertyValue(STRATEGY).getRawValue()))
                .valid(false)
                .build());
      }
    }
  }
  return validationResults;
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

if (context.getPropertyValue(KEY_REGEX).isSet() ^ context.getPropertyValue(KEY_FIELDS).isSet()) {
  validationResults.add(
      new ValidationResult.Builder()

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

if (context.getPropertyValue(TIMEBASED_INDEX).isSet()) {
  final SimpleDateFormat sdf = new SimpleDateFormat(context.getPropertyValue(DATE_FORMAT).asString());
  if (context.getPropertyValue(TIMEBASED_INDEX).getRawValue().equals(TODAY_DATE_SUFFIX.getValue())) {
  if (context.getPropertyValue(COLLECTION_FIELD).isSet()) {
    Field eventIndexField = record.getField(context.getPropertyValue(COLLECTION_FIELD).asString());
    if (eventIndexField != null && eventIndexField.getRawValue() != null) {

代码示例来源：origin: com.hurence.logisland/logisland-elasticsearch-plugin

if (context.getPropertyValue(TIMEBASED_INDEX).isSet()) {
  final SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
  if (context.getPropertyValue(TIMEBASED_INDEX).getRawValue().equals(TODAY_DATE_SUFFIX.getValue())) {
  if (context.getPropertyValue(ES_INDEX_FIELD).isSet()) {
    Field eventIndexField = record.getField(context.getPropertyValue(ES_INDEX_FIELD).asString());
    if (eventIndexField != null && eventIndexField.getRawValue() != null) {
  if (context.getPropertyValue(ES_TYPE_FIELD).isSet()) {
    Field eventTypeField = record.getField(context.getPropertyValue(ES_TYPE_FIELD).asString());
    if (eventTypeField != null && eventTypeField.getRawValue() != null) {

代码示例来源：origin: com.hurence.logisland/logisland-querymatcher-plugin

if (context.getPropertyValue(NUMERIC_FIELDS).isSet()) {
  final String[] numericFields = context.getPropertyValue(NUMERIC_FIELDS).asString().split(",");
  for (String numericField : numericFields) {

代码示例来源：origin: com.hurence.logisland/logisland-scripting-plugin

if (context.getPropertyValue(SCRIPT_CODE_PROCESS).isSet())
  if (context.getPropertyValue(SCRIPT_PATH).isSet()) {
  if (!context.getPropertyValue(SCRIPT_PATH).isSet()) {
    if (context.getPropertyValue(SCRIPT_CODE_INIT).isSet()) {
    if (context.getPropertyValue(SCRIPT_CODE_IMPORTS).isSet()) {

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

if (context.getPropertyValue(TIME_ZONE_RECORD_TIME).isSet()) {
  timezone = TimeZone.getTimeZone(context.getPropertyValue(TIME_ZONE_RECORD_TIME).asString());
} else {

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

recordKeyName = context.getPropertyValue(RECORD_KEY_FIELD).evaluate(record).asString();
indexName = context.getPropertyValue(COLLECTION_NAME).evaluate(record).asString();
if (context.getPropertyValue(TYPE_NAME).isSet())
  typeName = context.getPropertyValue(TYPE_NAME).evaluate(record).asString();
includesFieldName = context.getPropertyValue(INCLUDES_FIELD).evaluate(record).asString();

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

@Override
public void init(ProcessContext context) {
  if (context.getPropertyValue(STRATEGY).isSet()) {
    if (context.getPropertyValue(STRATEGY).getRawValue().equals(RANDOM_UUID_STRATEGY.getValue())) {
      idBuilder = new IdBuilder() {

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

boolean addRootRecord = context.getPropertyValue(KEEP_ROOT_RECORD).asBoolean();
boolean includePosition = context.getPropertyValue(INCLUDE_POSITION).asBoolean();
List<String> concatFields = context.getPropertyValue(CONCAT_FIELDS).isSet() ?
    Arrays.asList(context.getPropertyValue(CONCAT_FIELDS).asString().split(",")) :
    Collections.emptyList();

代码示例来源：origin: com.hurence.logisland/logisland-cache_key_value-service-api

try {
  if (context.getPropertyValue(DATABASE_FILE_URI).isSet()) {
    dbUri = context.getPropertyValue(DATABASE_FILE_URI).asString();
  if (context.getPropertyValue(DATABASE_FILE_PATH).isSet()) {
    dbPath = context.getPropertyValue(DATABASE_FILE_PATH).asString();
  if (context.getPropertyValue(CSV_HEADER).isSet()) {
    String[] columnNames = context.getPropertyValue(CSV_HEADER).asString().split(",");
    for (String name : columnNames) {
  } else if (context.getPropertyValue(FIRST_LINE_HEADER).isSet()) {
    format = format.withFirstRecordAsHeader();
  } else {
  if (context.getPropertyValue(ENCODING_CHARSET).isSet()) {
    String encoding = context.getPropertyValue(ENCODING_CHARSET).asString();
    charset =  Charset.forName(encoding);

代码示例来源：origin: com.hurence.logisland/logisland-querymatcher-plugin

if (context.getPropertyValue(NUMERIC_FIELDS).isSet()) {
  final String[] numericFields = context.getPropertyValue(NUMERIC_FIELDS).asString().split(",");
  for (String numericField : numericFields) {

代码示例来源：origin: com.hurence.logisland/logisland-hbase-plugin

@Override
public void init(ProcessContext context) {
  this.clientService = context.getPropertyValue(HBASE_CLIENT_SERVICE).asControllerService(HBaseClientService.class);
  if (context.getPropertyValue(RECORD_SCHEMA).isSet()) {
    serializer = SerializerProvider.getSerializer(
        context.getPropertyValue(RECORD_SERIALIZER).asString(),
        context.getPropertyValue(RECORD_SCHEMA).asString());
  } else {
    serializer = SerializerProvider.getSerializer(context.getPropertyValue(RECORD_SERIALIZER).asString(), null);
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-outlier-detection-plugin

if (context.getPropertyValue(GLOBAL_STATISTICS_MIN).isSet()) {
  globalStatistics.setMin(context.getPropertyValue(GLOBAL_STATISTICS_MIN).asDouble());
if (context.getPropertyValue(GLOBAL_STATISTICS_MAX).isSet()) {
  globalStatistics.setMax(context.getPropertyValue(GLOBAL_STATISTICS_MAX).asDouble());
if (context.getPropertyValue(GLOBAL_STATISTICS_MEAN).isSet()) {
  globalStatistics.setMean(context.getPropertyValue(GLOBAL_STATISTICS_MEAN).asDouble());
if (context.getPropertyValue(GLOBAL_STATISTICS_STDDEV).isSet()) {
  globalStatistics.setStddev(context.getPropertyValue(GLOBAL_STATISTICS_STDDEV).asDouble());
if (context.getPropertyValue(MIN_AMOUNT_TO_PREDICT).isSet()) {
  outlierConfig.getConfig().put(
      SketchyMovingMAD.MIN_AMOUNT_TO_PREDICT,
      context.getPropertyValue(MIN_AMOUNT_TO_PREDICT).asLong());
if (context.getPropertyValue(RESERVOIR_SIZE).isSet()) {
  outlierConfig.getConfig().put(
      SketchyMovingMAD.RESERVOIR_SIZE,
      context.getPropertyValue(RESERVOIR_SIZE).asInteger());
if (context.getPropertyValue(SMOOTH).isSet()) {
  outlierConfig.getConfig().put(
      SketchyMovingMAD.SMOOTH,
      context.getPropertyValue(SMOOTH).asBoolean());
if (context.getPropertyValue(DECAY).isSet()) {
  outlierConfig.getConfig().put(

代码示例来源：origin: com.hurence.logisland/logisland-hbase-plugin

@Override
public void init(final ProcessContext context) {
  clientService = context.getPropertyValue(HBASE_CLIENT_SERVICE).asControllerService(HBaseClientService.class);
  if(clientService == null)
    logger.error("HBase client service is not initialized!");
  if (context.getPropertyValue(RECORD_SCHEMA).isSet()) {
    serializer = SerializerProvider.getSerializer(
        context.getPropertyValue(RECORD_SERIALIZER).asString(),
        context.getPropertyValue(RECORD_SCHEMA).asString());
  } else {
    serializer = SerializerProvider.getSerializer(context.getPropertyValue(RECORD_SERIALIZER).asString(), null);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

PropertyValue

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com